Index
All Classes and Interfaces|All Packages|Constant Field Values
A
- AbstractWorkflow<S> - Class in kalix.javasdk.workflow
- AbstractWorkflow() - Constructor for class kalix.javasdk.workflow.AbstractWorkflow
- AbstractWorkflow.AsyncCallStep<CallInput,
CallOutput, FailoverInput> - Class in kalix.javasdk.workflow - AbstractWorkflow.CallStep<CallInput,
DefCallInput, DefCallOutput, FailoverInput> - Class in kalix.javasdk.workflow - AbstractWorkflow.Effect<T> - Interface in kalix.javasdk.workflow
-
An Effect is a description of what Kalix needs to do after the command is handled.
- AbstractWorkflow.Effect.Builder<S> - Interface in kalix.javasdk.workflow
-
Construct the effect that is returned by the command handler or a step transition.
- AbstractWorkflow.Effect.ErrorEffect<T> - Interface in kalix.javasdk.workflow
- AbstractWorkflow.Effect.PersistenceEffectBuilder<T> - Interface in kalix.javasdk.workflow
- AbstractWorkflow.Effect.TransitionalEffect<T> - Interface in kalix.javasdk.workflow
-
A workflow effect type that contains information about the transition to the next step.
- AbstractWorkflow.RecoverStrategy<T> - Class in kalix.javasdk.workflow
- AbstractWorkflow.RecoverStrategy.MaxRetries - Class in kalix.javasdk.workflow
-
Retry strategy without failover configuration
- AbstractWorkflow.Step - Interface in kalix.javasdk.workflow
- AbstractWorkflow.StepConfig - Class in kalix.javasdk.workflow
- AbstractWorkflow.WorkflowDef<S> - Class in kalix.javasdk.workflow
- accepted() - Static method in class kalix.javasdk.HttpResponse
-
Creates a 202 ACCEPTED response.
- ACCEPTED - Enum constant in enum kalix.javasdk.StatusCode.Success
- Action - Class in kalix.javasdk.action
-
Actions are stateless components that can be used to implement different uses cases, such as:
- Action() - Constructor for class kalix.javasdk.action.Action
- Action.Effect<T> - Interface in kalix.javasdk.action
-
An Effect is a description of what Kalix needs to do after the command is handled.
- Action.Effect.Builder - Interface in kalix.javasdk.action
-
Construct the effect that is returned by the command handler.
- actionContext() - Method in class kalix.javasdk.action.Action
-
Additional context and metadata for a message handler.
- ActionContext - Interface in kalix.javasdk.action
-
Context for action calls.
- ActionCreationContext - Interface in kalix.javasdk.action
-
Creation context for
Action
components. - ActionFactory - Interface in kalix.javasdk.impl
-
Low level interface to implement
Action
components. - ActionOptions - Interface in kalix.javasdk.action
-
Options for actions
- ActionProvider<A extends Action> - Interface in kalix.javasdk.action
-
Register an Action in {
Kalix
} using anActionProvider
. - add(E) - Method in interface kalix.javasdk.replicatedentity.ReplicatedSet
-
Add an element to this set if it is not already present.
- add(String, String) - Method in interface kalix.javasdk.Metadata
-
Add the string value for the given key.
- addAll(Collection<E>) - Method in interface kalix.javasdk.replicatedentity.ReplicatedSet
-
Add elements to this set if they're not already present.
- addBinary(String, ByteBuffer) - Method in interface kalix.javasdk.Metadata
-
Add the binary value for the given key.
- addCustomDataToJsonMap(Map<String, Object>, ILoggingEvent) - Method in class kalix.javasdk.logging.LogbackJsonLayout
- additionalDescriptors() - Method in interface kalix.javasdk.action.ActionProvider
- additionalDescriptors() - Method in interface kalix.javasdk.eventsourcedentity.EventSourcedEntityProvider
- additionalDescriptors() - Method in interface kalix.javasdk.replicatedentity.ReplicatedEntityProvider
- additionalDescriptors() - Method in interface kalix.javasdk.valueentity.ValueEntityProvider
- additionalDescriptors() - Method in interface kalix.javasdk.view.ViewProvider
- additionalDescriptors() - Method in interface kalix.javasdk.workflow.WorkflowProvider
- addSideEffect(SideEffect...) - Method in interface kalix.javasdk.action.Action.Effect
-
Attach the given side effects to this reply.
- addSideEffects(Collection<SideEffect>) - Method in interface kalix.javasdk.action.Action.Effect
-
Attach the given side effects to this reply.
- addSideEffects(Collection<SideEffect>) - Method in interface kalix.javasdk.eventsourcedentity.EventSourcedEntity.Effect
-
Attach the given side effects to this reply.
- addSideEffects(Collection<SideEffect>) - Method in interface kalix.javasdk.replicatedentity.ReplicatedEntity.Effect
-
Attach the given side effects to this reply.
- addSideEffects(Collection<SideEffect>) - Method in interface kalix.javasdk.valueentity.ValueEntity.Effect
-
Attach the given side effects to this reply.
- addSideEffects(SideEffect...) - Method in interface kalix.javasdk.eventsourcedentity.EventSourcedEntity.Effect
-
Attach the given effects to this reply.
- addSideEffects(SideEffect...) - Method in interface kalix.javasdk.replicatedentity.ReplicatedEntity.Effect
-
Attach the given effects to this reply.
- addSideEffects(SideEffect...) - Method in interface kalix.javasdk.valueentity.ValueEntity.Effect
-
Attach the given effects to this reply.
- addStep(AbstractWorkflow.Step) - Method in class kalix.javasdk.workflow.AbstractWorkflow.WorkflowDef
-
Add step to workflow definition.
- addStep(AbstractWorkflow.Step, AbstractWorkflow.RecoverStrategy<?>) - Method in class kalix.javasdk.workflow.AbstractWorkflow.WorkflowDef
-
Add step to workflow definition with a dedicated
AbstractWorkflow.RecoverStrategy
. - ALL - Enum constant in enum kalix.javasdk.replicatedentity.WriteConsistency
-
Updates will be written immediately to all replicas.
- allClaimNames() - Method in interface kalix.javasdk.JwtClaims
-
Returns the names of all the claims in this request.
- ALREADY_REPORTED - Enum constant in enum kalix.javasdk.StatusCode.Success
- alternativeCodec() - Method in interface kalix.javasdk.action.ActionProvider
- alternativeCodec() - Method in interface kalix.javasdk.eventsourcedentity.EventSourcedEntityProvider
- alternativeCodec() - Method in interface kalix.javasdk.valueentity.ValueEntityProvider
- alternativeCodec() - Method in interface kalix.javasdk.view.ViewProvider
- alternativeCodec() - Method in interface kalix.javasdk.workflow.WorkflowProvider
- andThen(Class<CallOutput>, Function<CallOutput, AbstractWorkflow.Effect.TransitionalEffect<Void>>) - Method in class kalix.javasdk.workflow.ProtoStepBuilder.AsyncCallStepBuilder
-
Transition to the next step based on the result of the step call.
- andThen(Class<CallOutput>, Function<CallOutput, AbstractWorkflow.Effect.TransitionalEffect<Void>>) - Method in class kalix.javasdk.workflow.StepBuilder.AsyncCallStepBuilder
-
Transition to the next step based on the result of the step call.
- andThen(Class<DefCallOutput>, Function<DefCallOutput, AbstractWorkflow.Effect.TransitionalEffect<Void>>) - Method in class kalix.javasdk.workflow.ProtoStepBuilder.CallStepBuilder
-
Transition to the next step based on the result of the step call.
- andThen(Class<DefCallOutput>, Function<DefCallOutput, AbstractWorkflow.Effect.TransitionalEffect<Void>>) - Method in class kalix.javasdk.workflow.StepBuilder.CallStepBuilder
-
Transition to the next step based on the result of the step call.
- asCloudEvent() - Method in interface kalix.javasdk.Metadata
-
Return a CloudEvent representation of this Metadata.
- asCloudEvent(String, URI, String) - Method in interface kalix.javasdk.Metadata
-
Convert this metadata to a CloudEvent, adding the given required CloudEvent fields.
- asMap() - Method in interface kalix.javasdk.JwtClaims
-
Returns all the claims as a map of strings to strings.
- asMetadata() - Method in interface kalix.javasdk.CloudEvent
-
Return this CloudEvent represented as Metadata.
- asOpenTelemetryContext() - Method in interface kalix.javasdk.TraceContext
-
Allows retrieving the trace context as an OpenTelemetry context for easier construction of child spans.
- asyncCall(Class<Input>, Function<Input, CompletionStage<Output>>) - Method in class kalix.javasdk.workflow.ProtoStepBuilder
-
Build a step action with an async call.
- asyncCall(Class<Input>, Function<Input, CompletionStage<Output>>) - Method in class kalix.javasdk.workflow.StepBuilder
-
Build a step action with an async call.
- asyncCall(Supplier<CompletionStage<Output>>) - Method in class kalix.javasdk.workflow.ProtoStepBuilder
-
Build a step action with an async call.
- asyncCall(Supplier<CompletionStage<Output>>) - Method in class kalix.javasdk.workflow.StepBuilder
-
Build a step action with an async call.
- AsyncCallStep(String, Class<CallInput>, Function<CallInput, CompletionStage<CallOutput>>, Class<CallOutput>, Function<CallOutput, AbstractWorkflow.Effect.TransitionalEffect<Void>>) - Constructor for class kalix.javasdk.workflow.AbstractWorkflow.AsyncCallStep
- AsyncCallStepBuilder(String, Class<CallInput>, Function<CallInput, CompletionStage<CallOutput>>) - Constructor for class kalix.javasdk.workflow.ProtoStepBuilder.AsyncCallStepBuilder
- AsyncCallStepBuilder(String, Class<CallInput>, Function<CallInput, CompletionStage<CallOutput>>) - Constructor for class kalix.javasdk.workflow.StepBuilder.AsyncCallStepBuilder
- asyncEffect(CompletionStage<Action.Effect<S>>) - Method in interface kalix.javasdk.action.Action.Effect.Builder
-
Create a reply from an async operation result returning an effect.
- asyncReply(CompletionStage<S>) - Method in interface kalix.javasdk.action.Action.Effect.Builder
-
Create a message reply from an async operation result.
- asyncReply(CompletionStage<S>, Metadata) - Method in interface kalix.javasdk.action.Action.Effect.Builder
-
Create a message reply from an async operation result with custom Metadata.
- audience() - Method in interface kalix.javasdk.JwtClaims
-
Get the audience, that is, the aud claim, as described in RFC 7519 section 4.1.3.
B
- BACKOFFICE - Enum constant in enum kalix.javasdk.Principal.Basic
- BACKOFFICE - Static variable in interface kalix.javasdk.Principal
-
Abstract principal representing all requests from the backoffice
- BAD_REQUEST - Enum constant in enum kalix.javasdk.StatusCode.ErrorCode
- bodyAsJson(Class<T>) - Method in class kalix.javasdk.HttpResponse
-
Parses an HTTP body to a specified JSON type using Jackson deserializer.
C
- call() - Method in interface kalix.javasdk.SideEffect
-
The service call that is executed as this effect.
- call(Class<Input>, Function<Input, DeferredCall<DefCallInput, DefCallOutput>>) - Method in class kalix.javasdk.workflow.ProtoStepBuilder
-
Build a step action with a call to an existing Kalix component via
DeferredCall
. - call(Class<Input>, Function<Input, DeferredCall<DefCallInput, DefCallOutput>>) - Method in class kalix.javasdk.workflow.StepBuilder
-
Build a step action with a call to an existing Kalix component via
DeferredCall
. - call(Supplier<DeferredCall<DefCallInput, DefCallOutput>>) - Method in class kalix.javasdk.workflow.ProtoStepBuilder
-
Build a step action with a call to an existing Kalix component via
DeferredCall
. - call(Supplier<DeferredCall<DefCallInput, DefCallOutput>>) - Method in class kalix.javasdk.workflow.StepBuilder
-
Build a step action with a call to an existing Kalix component via
DeferredCall
. - callFunc - Variable in class kalix.javasdk.workflow.AbstractWorkflow.AsyncCallStep
- callFunc - Variable in class kalix.javasdk.workflow.AbstractWorkflow.CallStep
- callInputClass - Variable in class kalix.javasdk.workflow.AbstractWorkflow.AsyncCallStep
- callInputClass - Variable in class kalix.javasdk.workflow.AbstractWorkflow.CallStep
- CallStep(String, Class<CallInput>, Function<CallInput, DeferredCall<DefCallInput, DefCallOutput>>, Class<DefCallOutput>, Function<DefCallOutput, AbstractWorkflow.Effect.TransitionalEffect<Void>>) - Constructor for class kalix.javasdk.workflow.AbstractWorkflow.CallStep
- CallStepBuilder(String, Class<Input>, Function<Input, DeferredCall<DefCallInput, DefCallOutput>>) - Constructor for class kalix.javasdk.workflow.ProtoStepBuilder.CallStepBuilder
- CallStepBuilder(String, Class<Input>, Function<Input, DeferredCall<DefCallInput, DefCallOutput>>) - Constructor for class kalix.javasdk.workflow.StepBuilder.CallStepBuilder
- cancel(String) - Method in interface kalix.javasdk.timer.TimerScheduler
-
Cancel an existing timer.
- canHaveSideEffects() - Method in interface kalix.javasdk.action.Action.Effect
- clear() - Method in interface kalix.javasdk.Metadata
-
Clear all metadata entries.
- clear() - Method in interface kalix.javasdk.replicatedentity.ReplicatedCounterMap
-
Remove all mappings from this counter map.
- clear() - Method in interface kalix.javasdk.replicatedentity.ReplicatedMap
-
Remove all entries from this map.
- clear() - Method in interface kalix.javasdk.replicatedentity.ReplicatedMultiMap
-
Remove all key-value pairs from the multi-map, leaving it empty.
- clear() - Method in interface kalix.javasdk.replicatedentity.ReplicatedRegisterMap
-
Remove all mappings from this register map.
- clear() - Method in interface kalix.javasdk.replicatedentity.ReplicatedSet
-
Remove all elements from this set.
- clearDatacontenttype() - Method in interface kalix.javasdk.CloudEvent
-
Clear the data content type of this CloudEvent, if set.
- clearDataschema() - Method in interface kalix.javasdk.CloudEvent
-
Clear the data schema of this CloudEvent, if set.
- clearSubject() - Method in interface kalix.javasdk.CloudEvent
-
Clear the subject of this CloudEvent, if set.
- clearTime() - Method in interface kalix.javasdk.CloudEvent
-
Clear the time of this CloudEvent, if set.
- CloudEvent - Interface in kalix.javasdk
-
CloudEvent representation of Metadata.
- commandContext() - Method in class kalix.javasdk.eventsourcedentity.EventSourcedEntity
-
Additional context and metadata for a command handler.
- commandContext() - Method in class kalix.javasdk.replicatedentity.ReplicatedEntity
-
Additional context and metadata for a command handler.
- commandContext() - Method in class kalix.javasdk.valueentity.ValueEntity
-
Additional context and metadata for a command handler.
- commandContext() - Method in class kalix.javasdk.workflow.AbstractWorkflow
-
Additional context and metadata for a command handler.
- CommandContext - Interface in kalix.javasdk.eventsourcedentity
-
An event sourced command context.
- CommandContext - Interface in kalix.javasdk.replicatedentity
-
Command context for Replicated Entity.
- CommandContext - Interface in kalix.javasdk.valueentity
-
A value based entity command context.
- CommandContext - Interface in kalix.javasdk.workflow
-
A value based workflow command context.
- commandId() - Method in interface kalix.javasdk.eventsourcedentity.CommandContext
-
The id of the command being executed.
- commandId() - Method in interface kalix.javasdk.replicatedentity.CommandContext
-
The id of the command.
- commandId() - Method in interface kalix.javasdk.valueentity.CommandContext
-
The id of the command being executed.
- commandId() - Method in interface kalix.javasdk.workflow.CommandContext
-
The id of the command being executed.
- commandName() - Method in interface kalix.javasdk.eventsourcedentity.CommandContext
-
The name of the command being executed.
- commandName() - Method in interface kalix.javasdk.replicatedentity.CommandContext
-
The name of the command.
- commandName() - Method in interface kalix.javasdk.valueentity.CommandContext
-
The name of the command being executed.
- commandName() - Method in interface kalix.javasdk.workflow.CommandContext
-
The name of the command being executed.
- CONFLICT - Enum constant in enum kalix.javasdk.StatusCode.ErrorCode
- contains(E) - Method in interface kalix.javasdk.replicatedentity.ReplicatedSet
-
Check whether this set contains the given element.
- containsAll(Collection<E>) - Method in interface kalix.javasdk.replicatedentity.ReplicatedSet
-
Check whether this set contains all the given elements.
- containsKey(K) - Method in interface kalix.javasdk.replicatedentity.ReplicatedCounterMap
-
Check whether this counter map contains a mapping for the given key.
- containsKey(K) - Method in interface kalix.javasdk.replicatedentity.ReplicatedMap
-
Check whether this map contains a mapping for the given key.
- containsKey(K) - Method in interface kalix.javasdk.replicatedentity.ReplicatedMultiMap
-
Check whether this multi-map contains at least one value for the given key.
- containsKey(K) - Method in interface kalix.javasdk.replicatedentity.ReplicatedRegisterMap
-
Check whether this register map contains a mapping for the given key.
- containsValue(K, V) - Method in interface kalix.javasdk.replicatedentity.ReplicatedMultiMap
-
Check whether this multi-map contains the given value associated with the given key.
- Context - Interface in kalix.javasdk
-
Root class of all contexts.
- contextForComponents() - Method in class kalix.javasdk.action.Action
-
INTERNAL API
- create(ActionCreationContext) - Method in interface kalix.javasdk.impl.ActionFactory
- create(EventSourcedEntityContext) - Method in interface kalix.javasdk.impl.EventSourcedEntityFactory
-
Create an entity handler for the given context.
- create(ReplicatedEntityContext) - Method in interface kalix.javasdk.impl.ReplicatedEntityFactory
-
Create an entity handler for the given context.
- create(ValueEntityContext) - Method in interface kalix.javasdk.impl.ValueEntityFactory
-
Create an entity handler for the given context.
- create(ViewCreationContext) - Method in interface kalix.javasdk.impl.ViewFactory
-
Create a view handler for the given context.
- create(WorkflowContext) - Method in interface kalix.javasdk.impl.WorkflowFactory
- created() - Static method in class kalix.javasdk.HttpResponse
-
Creates a 201 CREATED response.
- CREATED - Enum constant in enum kalix.javasdk.StatusCode.Success
- createRunner() - Method in class kalix.javasdk.Kalix
-
Creates a KalixRunner using the currently configured services.
- createRunner(Config) - Method in class kalix.javasdk.Kalix
-
Creates a KalixRunner using the currently configured services, using the supplied configuration.
- currentState() - Method in class kalix.javasdk.eventsourcedentity.EventSourcedEntity
-
Returns the state as currently stored by Kalix.
- currentState() - Method in class kalix.javasdk.valueentity.ValueEntity
-
Returns the state as currently stored by Kalix.
- currentState() - Method in class kalix.javasdk.workflow.AbstractWorkflow
-
Returns the state as currently stored by Kalix.
- currentVersion() - Method in class kalix.javasdk.JsonMigration
-
Define current version, that is, the value used when serializing new data.
- CUSTOM - Enum constant in enum kalix.javasdk.replicatedentity.ReplicatedRegister.Clock
-
A custom clock.
- CUSTOM_AUTO_INCREMENT - Enum constant in enum kalix.javasdk.replicatedentity.ReplicatedRegister.Clock
-
A custom clock, that automatically increments the custom value if the local clock value is greater than it.
D
- datacontenttype() - Method in interface kalix.javasdk.CloudEvent
-
The data content type of this CloudEvent.
- dataschema() - Method in interface kalix.javasdk.CloudEvent
-
The data schema of this CloudEvent.
- decodeJson(Class<T>, Any) - Static method in class kalix.javasdk.JsonSupport
-
Decode the given protobuf Any object to an instance of T using Jackson.
- decodeJson(Class<T>, String, Any) - Static method in class kalix.javasdk.JsonSupport
-
Decode the given protobuf Any to an instance of T using Jackson but only if the suffix of the type URL matches the given jsonType.
- decodeJsonCollection(Class<T>, Class<C>, Any) - Static method in class kalix.javasdk.JsonSupport
- decrement(long) - Method in interface kalix.javasdk.replicatedentity.ReplicatedCounter
-
Decrement the counter.
- decrement(K, long) - Method in interface kalix.javasdk.replicatedentity.ReplicatedCounterMap
-
Decrement the counter at the given key by the given amount.
- DEFAULT - Enum constant in enum kalix.javasdk.replicatedentity.ReplicatedRegister.Clock
-
The default clock, uses the current system time as the clock value.
- defaults() - Static method in interface kalix.javasdk.action.ActionOptions
-
Create default options for an action.
- defaults() - Static method in interface kalix.javasdk.eventsourcedentity.EventSourcedEntityOptions
-
Create a default entity option for an event sourced entity.
- defaults() - Static method in interface kalix.javasdk.replicatedentity.ReplicatedEntityOptions
-
Create default Replicated Entity options.
- defaults() - Static method in interface kalix.javasdk.valueentity.ValueEntityOptions
-
Create a default entity option for a value based entity.
- defaults() - Static method in interface kalix.javasdk.view.ViewOptions
-
Create default options for a view.
- defaults() - Static method in interface kalix.javasdk.workflow.WorkflowOptions
- defaultStepRecoverStrategy(AbstractWorkflow.RecoverStrategy) - Method in class kalix.javasdk.workflow.AbstractWorkflow.WorkflowDef
-
Define a default step recovery strategy.
- defaultStepTimeout(Duration) - Method in class kalix.javasdk.workflow.AbstractWorkflow.WorkflowDef
-
Define a default step timeout.
- defaultTimeout() - Static method in interface kalix.javasdk.PassivationStrategy
-
Create a passivation strategy that passivates the entity after the default duration (30 seconds) of inactivity.
- DeferredCall<I,
O> - Interface in kalix.javasdk -
Represents a call to another component, performed as a forward, a side effect, or a request-reply.
- definition() - Method in class kalix.javasdk.workflow.AbstractWorkflow
- delete() - Method in interface kalix.javasdk.replicatedentity.ReplicatedEntity.Effect.Builder
-
Delete the replicated entity.
- deleteEntity() - Method in interface kalix.javasdk.eventsourcedentity.EventSourcedEntity.Effect.OnSuccessBuilder
-
Delete the entity.
- deleteEntity() - Method in interface kalix.javasdk.valueentity.ValueEntity.Effect.Builder
-
Delete the entity.
- deleteState() - Method in interface kalix.javasdk.valueentity.ValueEntity.Effect.Builder
-
Deprecated, for removal: This API element is subject to removal in a future version.Renamed to deleteEntity
- deleteState() - Method in interface kalix.javasdk.view.View.UpdateEffect.Builder
E
- effects() - Method in class kalix.javasdk.action.Action
- effects() - Method in class kalix.javasdk.eventsourcedentity.EventSourcedEntity
- effects() - Method in class kalix.javasdk.replicatedentity.ReplicatedEntity
- effects() - Method in class kalix.javasdk.valueentity.ValueEntity
- effects() - Method in class kalix.javasdk.view.View
- effects() - Method in class kalix.javasdk.workflow.AbstractWorkflow
- elements() - Method in interface kalix.javasdk.replicatedentity.ReplicatedSet
-
Elements of this set as a regular
Set
. - emitEvent(E) - Method in interface kalix.javasdk.eventsourcedentity.EventSourcedEntity.Effect.Builder
- emitEvents(List<? extends E>) - Method in interface kalix.javasdk.eventsourcedentity.EventSourcedEntity.Effect.Builder
- EMPTY - Static variable in interface kalix.javasdk.Metadata
-
An empty Metadata object.
- emptyData(ReplicatedDataFactory) - Method in class kalix.javasdk.replicatedentity.ReplicatedCounterEntity
- emptyData(ReplicatedDataFactory) - Method in class kalix.javasdk.replicatedentity.ReplicatedCounterMapEntity
- emptyData(ReplicatedDataFactory) - Method in class kalix.javasdk.replicatedentity.ReplicatedEntity
-
Implement by returning the initial empty replicated data object.
- emptyData(ReplicatedDataFactory) - Method in class kalix.javasdk.replicatedentity.ReplicatedMapEntity
- emptyData(ReplicatedDataFactory) - Method in class kalix.javasdk.replicatedentity.ReplicatedMultiMapEntity
- emptyData(ReplicatedDataFactory) - Method in class kalix.javasdk.replicatedentity.ReplicatedRegisterEntity
- emptyData(ReplicatedDataFactory) - Method in class kalix.javasdk.replicatedentity.ReplicatedRegisterMapEntity
- emptyData(ReplicatedDataFactory) - Method in class kalix.javasdk.replicatedentity.ReplicatedSetEntity
- emptyData(ReplicatedDataFactory) - Method in class kalix.javasdk.replicatedentity.ReplicatedVoteEntity
- emptyState() - Method in class kalix.javasdk.eventsourcedentity.EventSourcedEntity
-
Implement by returning the initial empty state object.
- emptyState() - Method in class kalix.javasdk.valueentity.ValueEntity
-
Implement by returning the initial empty state object.
- emptyState() - Method in class kalix.javasdk.view.View
-
The default implementation of this method returns
null
. - emptyState() - Method in class kalix.javasdk.workflow.AbstractWorkflow
-
Returns the initial empty state object.
- emptyValue() - Method in class kalix.javasdk.replicatedentity.ReplicatedRegisterEntity
-
Implement to set the default empty value for the register.
- encodeJson(T) - Static method in class kalix.javasdk.JsonSupport
-
Encode the given value as JSON using Jackson and put the encoded string as bytes in a protobuf Any with the type URL
"json.kalix.io/[valueClassName]"
. - encodeJson(T, String) - Static method in class kalix.javasdk.JsonSupport
-
Encode the given value as JSON using Jackson and put the encoded string as bytes in a protobuf Any with the type URL
"json.kalix.io/[jsonType]"
. - encodeToBytes(T) - Static method in class kalix.javasdk.JsonSupport
- end() - Method in interface kalix.javasdk.workflow.AbstractWorkflow.Effect.Builder
-
Finish the workflow execution.
- end() - Method in interface kalix.javasdk.workflow.AbstractWorkflow.Effect.PersistenceEffectBuilder
-
Finish the workflow execution.
- EntityContext - Interface in kalix.javasdk
-
Root context for all contexts that pertain to entities, that is, things that are addressable via an entity id.
- entityId() - Method in interface kalix.javasdk.EntityContext
-
The id of the entity that this context is for.
- EntityOptions - Interface in kalix.javasdk
-
Options used for configuring an entity.
- equals(Object) - Method in class kalix.javasdk.Principal.LocalService
- error(String) - Method in interface kalix.javasdk.action.Action.Effect.Builder
-
Create an error reply.
- error(String) - Method in interface kalix.javasdk.eventsourcedentity.EventSourcedEntity.Effect.Builder
-
Create an error reply.
- error(String) - Method in interface kalix.javasdk.replicatedentity.ReplicatedEntity.Effect.Builder
-
Create an error reply.
- error(String) - Method in interface kalix.javasdk.valueentity.ValueEntity.Effect.Builder
-
Create an error reply.
- error(String) - Method in interface kalix.javasdk.view.View.UpdateEffect.Builder
-
Trigger an error for the event.
- error(String) - Method in interface kalix.javasdk.workflow.AbstractWorkflow.Effect.Builder
-
Create an error reply.
- error(String, Status.Code) - Method in interface kalix.javasdk.action.Action.Effect.Builder
-
Create an error reply with a custom gRPC status code.
- error(String, Status.Code) - Method in interface kalix.javasdk.eventsourcedentity.EventSourcedEntity.Effect.Builder
-
Create an error reply.
- error(String, Status.Code) - Method in interface kalix.javasdk.replicatedentity.ReplicatedEntity.Effect.Builder
-
Create an error reply.
- error(String, Status.Code) - Method in interface kalix.javasdk.valueentity.ValueEntity.Effect.Builder
-
Create an error reply.
- error(String, Status.Code) - Method in interface kalix.javasdk.workflow.AbstractWorkflow.Effect.Builder
-
Create an error reply with a gRPC status code.
- error(String, StatusCode.ErrorCode) - Method in interface kalix.javasdk.action.Action.Effect.Builder
-
Create an error reply with a custom status code.
- error(String, StatusCode.ErrorCode) - Method in interface kalix.javasdk.eventsourcedentity.EventSourcedEntity.Effect.Builder
-
Create an error reply with a custom status code.
- error(String, StatusCode.ErrorCode) - Method in interface kalix.javasdk.replicatedentity.ReplicatedEntity.Effect.Builder
-
Create an error reply with a custom status code.
- error(String, StatusCode.ErrorCode) - Method in interface kalix.javasdk.valueentity.ValueEntity.Effect.Builder
-
Create an error reply with a custom status code.
- error(String, StatusCode.ErrorCode) - Method in interface kalix.javasdk.workflow.AbstractWorkflow.Effect.Builder
-
Create an error reply with an HTTP status code.
- eventContext() - Method in class kalix.javasdk.eventsourcedentity.EventSourcedEntity
-
Additional context and metadata for an event handler.
- EventContext - Interface in kalix.javasdk.eventsourcedentity
-
Context for an event.
- eventName() - Method in interface kalix.javasdk.view.UpdateContext
-
The name of the event being handled.
- EventSourcedEntity<S,
E> - Class in kalix.javasdk.eventsourcedentity -
The Event Sourced state model captures changes to data by storing events in a journal.
- EventSourcedEntity() - Constructor for class kalix.javasdk.eventsourcedentity.EventSourcedEntity
- EventSourcedEntity.Effect<T> - Interface in kalix.javasdk.eventsourcedentity
-
An Effect is a description of what Kalix needs to do after the command is handled.
- EventSourcedEntity.Effect.Builder<S,
E> - Interface in kalix.javasdk.eventsourcedentity -
Construct the effect that is returned by the command handler.
- EventSourcedEntity.Effect.OnSuccessBuilder<S> - Interface in kalix.javasdk.eventsourcedentity
- EventSourcedEntityContext - Interface in kalix.javasdk.eventsourcedentity
-
Root context for all event sourcing contexts.
- EventSourcedEntityFactory - Interface in kalix.javasdk.impl
-
Low level interface for handling events and commands on an entity.
- EventSourcedEntityOptions - Interface in kalix.javasdk.eventsourcedentity
-
Root entity options for all event sourcing entities.
- EventSourcedEntityProvider<S,
E, ES extends EventSourcedEntity<S, E>> - Interface in kalix.javasdk.eventsourcedentity -
Register an event sourced entity in
Kalix
using aEventSourcedEntityProvider
. - eventSubject() - Method in interface kalix.javasdk.action.ActionContext
-
The origin subject of the
CloudEvent
. - eventSubject() - Method in interface kalix.javasdk.view.UpdateContext
-
The origin subject of the
CloudEvent
. - execute() - Method in interface kalix.javasdk.DeferredCall
-
Execute this call right away and get the async result back for composition.
- expirationTime() - Method in interface kalix.javasdk.JwtClaims
-
Get the expiration time, that is, the exp claim, as described in RFC 7519 section 4.1.4.
F
- failoverStepInput - Variable in class kalix.javasdk.workflow.AbstractWorkflow.RecoverStrategy
- failoverStepName - Variable in class kalix.javasdk.workflow.AbstractWorkflow.RecoverStrategy
- failoverTo(String) - Static method in class kalix.javasdk.workflow.AbstractWorkflow.RecoverStrategy
-
In case of a step failure don't retry but transition to a given step name.
- failoverTo(String) - Method in class kalix.javasdk.workflow.AbstractWorkflow.RecoverStrategy.MaxRetries
-
Once max retries is exceeded, transition to a given step name.
- failoverTo(String, I, AbstractWorkflow.RecoverStrategy.MaxRetries) - Method in class kalix.javasdk.workflow.AbstractWorkflow.WorkflowDef
-
Define a failover step name after workflow timeout.
- failoverTo(String, AbstractWorkflow.RecoverStrategy.MaxRetries) - Method in class kalix.javasdk.workflow.AbstractWorkflow.WorkflowDef
-
Define a failover step name after workflow timeout.
- failoverTo(String, T) - Static method in class kalix.javasdk.workflow.AbstractWorkflow.RecoverStrategy
-
In case of a step failure don't retry but transition to a given step name with the input parameter.
- failoverTo(String, T) - Method in class kalix.javasdk.workflow.AbstractWorkflow.RecoverStrategy.MaxRetries
-
Once max retries is exceeded, transition to a given step name with the input parameter.
- findByName(String) - Method in class kalix.javasdk.workflow.AbstractWorkflow.WorkflowDef
- FORBIDDEN - Enum constant in enum kalix.javasdk.StatusCode.ErrorCode
- forward(DeferredCall<? extends Object, S>) - Method in interface kalix.javasdk.action.Action.Effect.Builder
-
Create a forward reply.
- forward(DeferredCall<? extends Object, T>) - Method in interface kalix.javasdk.eventsourcedentity.EventSourcedEntity.Effect.Builder
-
Create a forward reply.
- forward(DeferredCall<? extends Object, T>) - Method in interface kalix.javasdk.replicatedentity.ReplicatedEntity.Effect.Builder
-
Create a forward reply.
- forward(DeferredCall<? extends Object, T>) - Method in interface kalix.javasdk.valueentity.ValueEntity.Effect.Builder
-
Create a forward reply.
- forwardHeaders() - Method in interface kalix.javasdk.action.ActionOptions
- forwardHeaders() - Method in interface kalix.javasdk.EntityOptions
- forwardHeaders() - Method in interface kalix.javasdk.view.ViewOptions
- FOUND - Enum constant in enum kalix.javasdk.StatusCode.Redirect
- from(int) - Static method in enum kalix.javasdk.StatusCode.Success
G
- GATEWAY_TIMEOUT - Enum constant in enum kalix.javasdk.StatusCode.ErrorCode
- get() - Method in interface kalix.javasdk.Principals
-
Get the principals associated with this request.
- get() - Method in interface kalix.javasdk.replicatedentity.ReplicatedRegister
-
Get the current value of the register.
- get(String) - Method in interface kalix.javasdk.Metadata
-
Get the string value for the given key, if found.
- get(K) - Method in interface kalix.javasdk.replicatedentity.ReplicatedCounterMap
-
Get the counter value for the given key.
- get(K) - Method in interface kalix.javasdk.replicatedentity.ReplicatedMap
-
Get the
ReplicatedData
value for the given key. - get(K) - Method in interface kalix.javasdk.replicatedentity.ReplicatedMultiMap
-
Get the values for the given key.
- getAll(String) - Method in interface kalix.javasdk.Metadata
-
Get all the string values for a given key.
- getAllKeys() - Method in interface kalix.javasdk.Metadata
-
Get all the keys for all the entries.
- getBinary(String) - Method in interface kalix.javasdk.Metadata
-
Get the binary value for the given key, if found.
- getBinaryAll(String) - Method in interface kalix.javasdk.Metadata
-
Get all the binary values for a given key.
- getBinaryValue() - Method in interface kalix.javasdk.Metadata.MetadataEntry
-
The binary value for the metadata entry.
- getBody() - Method in class kalix.javasdk.HttpResponse
- getBoolean(String) - Method in interface kalix.javasdk.JwtClaims
-
Get the boolean claim with the given name.
- getBooleanList(String) - Method in interface kalix.javasdk.JwtClaims
-
Get the boolean list claim with the given name.
- getContentType() - Method in class kalix.javasdk.HttpResponse
- getDouble(String) - Method in interface kalix.javasdk.JwtClaims
-
Get the double claim with the given name.
- getDoubleList(String) - Method in interface kalix.javasdk.JwtClaims
-
Get the double list claim with the given name.
- getFailoverMaxRetries() - Method in class kalix.javasdk.workflow.AbstractWorkflow.WorkflowDef
- getFailoverStepInput() - Method in class kalix.javasdk.workflow.AbstractWorkflow.WorkflowDef
- getFailoverStepName() - Method in class kalix.javasdk.workflow.AbstractWorkflow.WorkflowDef
- getGrpcClient(Class<T>, String) - Method in interface kalix.javasdk.action.ActionCreationContext
-
Get an Akka gRPC client for the given service name.
- getInteger(String) - Method in interface kalix.javasdk.JwtClaims
-
Get the integer claim with the given name.
- getIntegerList(String) - Method in interface kalix.javasdk.JwtClaims
-
Get the integer list claim with the given name.
- getKey() - Method in interface kalix.javasdk.Metadata.MetadataEntry
-
The key for the metadata entry.
- getLocalService() - Method in interface kalix.javasdk.Principals
-
Get the service that invoked this call, if any.
- getLong(String) - Method in interface kalix.javasdk.JwtClaims
-
Get the long claim with the given name.
- getLongList(String) - Method in interface kalix.javasdk.JwtClaims
-
Get the long list claim with the given name.
- getMaxRetries() - Method in class kalix.javasdk.workflow.AbstractWorkflow.RecoverStrategy.MaxRetries
- getMessageCodec() - Method in class kalix.javasdk.Kalix
-
INTERNAL API The returned codec includes all registered descriptors and is meant to be used internally for eventing testkit.
- getName() - Method in class kalix.javasdk.Principal.LocalService
- getNumericDate(String) - Method in interface kalix.javasdk.JwtClaims
-
Get the numeric data claim with the given name.
- getNumericDateList(String) - Method in interface kalix.javasdk.JwtClaims
-
Get the numeric date list claim with the given name.
- getObject(String) - Method in interface kalix.javasdk.JwtClaims
-
Get the object claim with the given name.
- getObjectList(String) - Method in interface kalix.javasdk.JwtClaims
-
Get the object list claim with the given name.
- getObjectMapper() - Static method in class kalix.javasdk.JsonSupport
-
The Jackson ObjectMapper that is used for encoding and decoding JSON.
- getOpenTelemetryTracer() - Method in interface kalix.javasdk.action.ActionCreationContext
-
Deprecated.use getTracer() instead.
- getOrElse(K, Function<ReplicatedDataFactory, V>) - Method in interface kalix.javasdk.replicatedentity.ReplicatedMap
-
Get the
ReplicatedData
value for the given key. - getReplicatedCounter(K) - Method in interface kalix.javasdk.replicatedentity.ReplicatedMap
-
Get a
ReplicatedCounter
from a heterogeneous Replicated Map (a map with different types of Replicated Data values). - getReplicatedCounterMap(K) - Method in interface kalix.javasdk.replicatedentity.ReplicatedMap
-
Get a
ReplicatedCounterMap
from a heterogeneous Replicated Map (a map with different types of Replicated Data values). - getReplicatedMap(K) - Method in interface kalix.javasdk.replicatedentity.ReplicatedMap
-
Get a
ReplicatedMap
from a heterogeneous Replicated Map (a map with different types of Replicated Data values). - getReplicatedMultiMap(K) - Method in interface kalix.javasdk.replicatedentity.ReplicatedMap
-
Get a
ReplicatedMultiMap
from a heterogeneous Replicated Map (a map with different types of Replicated Data values). - getReplicatedRegister(K) - Method in interface kalix.javasdk.replicatedentity.ReplicatedMap
-
Get a
ReplicatedRegister
from a heterogeneous Replicated Map (a map with different types of Replicated Data values). - getReplicatedRegister(K, Supplier<ValueT>) - Method in interface kalix.javasdk.replicatedentity.ReplicatedMap
-
Get a
ReplicatedRegister
from a heterogeneous Replicated Map (a map with different types of Replicated Data values). - getReplicatedRegisterMap(K) - Method in interface kalix.javasdk.replicatedentity.ReplicatedMap
-
Get a
ReplicatedRegisterMap
from a heterogeneous Replicated Map (a map with different types of Replicated Data values). - getReplicatedSet(K) - Method in interface kalix.javasdk.replicatedentity.ReplicatedMap
-
Get a
ReplicatedSet
from a heterogeneous Replicated Map (a map with different types of Replicated Data values). - getSelfVote() - Method in interface kalix.javasdk.replicatedentity.ReplicatedVote
-
Get the current value for this node's vote.
- getStatusCode() - Method in class kalix.javasdk.HttpResponse
- getStepConfigs() - Method in class kalix.javasdk.workflow.AbstractWorkflow.WorkflowDef
- getStepRecoverStrategy() - Method in class kalix.javasdk.workflow.AbstractWorkflow.WorkflowDef
- getSteps() - Method in class kalix.javasdk.workflow.AbstractWorkflow.WorkflowDef
- getStepTimeout() - Method in class kalix.javasdk.workflow.AbstractWorkflow.WorkflowDef
- getString(String) - Method in interface kalix.javasdk.JwtClaims
-
Get the string claim with the given name.
- getStringList(String) - Method in interface kalix.javasdk.JwtClaims
-
Get the string list claim with the given name.
- getTracer() - Method in interface kalix.javasdk.action.ActionCreationContext
-
Get an OpenTelemetry tracer for the current action.
- getValue() - Method in interface kalix.javasdk.Metadata.MetadataEntry
-
The string value for the metadata entry.
- getValue() - Method in interface kalix.javasdk.replicatedentity.ReplicatedCounter
-
Get the current value of the counter.
- getValue(K) - Method in interface kalix.javasdk.replicatedentity.ReplicatedRegisterMap
-
Get the current value of the register at the given key.
- getVoters() - Method in interface kalix.javasdk.replicatedentity.ReplicatedVote
-
Get the number of voters participating in the vote (ie, the number of nodes in the cluster).
- getVotesFor() - Method in interface kalix.javasdk.replicatedentity.ReplicatedVote
-
Get the number of votes for.
- getWorkflowTimeout() - Method in class kalix.javasdk.workflow.AbstractWorkflow.WorkflowDef
H
- has(String) - Method in interface kalix.javasdk.Metadata
-
Check whether this metadata has a entry for the given key.
- hasClaims() - Method in interface kalix.javasdk.JwtClaims
-
Does this request have any claims that have been validated?
- hashCode() - Method in class kalix.javasdk.Principal.LocalService
- HttpResponse - Class in kalix.javasdk
-
Represents an HTTP response with more level control over the status code, content type and body.
I
- id() - Method in interface kalix.javasdk.CloudEvent
-
The id of this CloudEvent.
- ignore() - Method in interface kalix.javasdk.action.Action.Effect.Builder
-
Ignore the current element and proceed with processing the next element if returned for an element from a subscription.
- ignore() - Method in interface kalix.javasdk.view.View.UpdateEffect.Builder
-
Ignore this event (and continue to process the next).
- IM_USED - Enum constant in enum kalix.javasdk.StatusCode.Success
- increment(long) - Method in interface kalix.javasdk.replicatedentity.ReplicatedCounter
-
Increment the counter.
- increment(K, long) - Method in interface kalix.javasdk.replicatedentity.ReplicatedCounterMap
-
Increment the counter at the given key by the given amount.
- INTERNAL_SERVER_ERROR - Enum constant in enum kalix.javasdk.StatusCode.ErrorCode
- INTERNET - Enum constant in enum kalix.javasdk.Principal.Basic
- INTERNET - Static variable in interface kalix.javasdk.Principal
-
Abstract principal representing all requests from the internet
- isAnyLocalService() - Method in interface kalix.javasdk.Principals
-
Whether this request was from any service in the local project.
- isAtLeastOne() - Method in interface kalix.javasdk.replicatedentity.ReplicatedVote
-
Has at least one node voted true?
- isBackoffice() - Method in interface kalix.javasdk.Principals
-
Whether this request is a backoffice request.
- isBinary() - Method in interface kalix.javasdk.Metadata.MetadataEntry
-
Whether this entry is a binary entry.
- isCloudEvent() - Method in interface kalix.javasdk.Metadata
-
Whether this metadata is also a CloudEvent.
- isEmpty() - Method in interface kalix.javasdk.replicatedentity.ReplicatedCounterMap
-
Check whether this counter map is empty.
- isEmpty() - Method in interface kalix.javasdk.replicatedentity.ReplicatedMap
-
Check whether this map is empty.
- isEmpty() - Method in interface kalix.javasdk.replicatedentity.ReplicatedMultiMap
-
Check whether this multi-map is empty.
- isEmpty() - Method in interface kalix.javasdk.replicatedentity.ReplicatedRegisterMap
-
Check whether this register map is empty.
- isEmpty() - Method in interface kalix.javasdk.replicatedentity.ReplicatedSet
-
Check whether this set is empty.
- isInternet() - Method in interface kalix.javasdk.Principals
-
Whether this request was from the internet.
- isLocalService(String) - Method in interface kalix.javasdk.Principals
-
Whether this request was from a service in the local project.
- isMajority() - Method in interface kalix.javasdk.replicatedentity.ReplicatedVote
-
Have a majority of nodes voted true?
- isSelf() - Method in interface kalix.javasdk.Principals
-
Whether this is a self request.
- issuedAt() - Method in interface kalix.javasdk.JwtClaims
-
Get the issued at, that is, the iat claim, as described in RFC 7519 section 4.1.6.
- issuer() - Method in interface kalix.javasdk.JwtClaims
-
Get the issuer, that is, the iss claim, as described in RFC 7519 section 4.1.1.
- isText() - Method in interface kalix.javasdk.Metadata.MetadataEntry
-
Whether this entry is a text entry.
- isUnanimous() - Method in interface kalix.javasdk.replicatedentity.ReplicatedVote
-
Is the vote unanimous?
J
- JsonMigration - Class in kalix.javasdk
-
Allows to specify dedicated strategy for JSON schema evolution.
- JsonMigration() - Constructor for class kalix.javasdk.JsonMigration
- JsonSupport - Class in kalix.javasdk
- jwtClaims() - Method in interface kalix.javasdk.Metadata
-
Get the JWT claims present in this metadata.
- JwtClaims - Interface in kalix.javasdk
-
Representation of JWT claims that have been validated and extracted from the bearer token of a request.
- jwtId() - Method in interface kalix.javasdk.JwtClaims
-
Get the JWT ID, that is, the jti claim, as described in RFC 7519 section 4.1.7.
K
- Kalix - Class in kalix.javasdk
-
The Kalix class is the main interface to configuring entities to deploy, and subsequently starting a local server which will expose these entities to the Kalix Runtime Sidecar.
- Kalix() - Constructor for class kalix.javasdk.Kalix
- KALIX_JSON - Static variable in class kalix.javasdk.JsonSupport
- kalix.javasdk - package kalix.javasdk
-
Root package for the Kalix Java SDK library.
- kalix.javasdk.action - package kalix.javasdk.action
- kalix.javasdk.annotations - package kalix.javasdk.annotations
- kalix.javasdk.eventsourcedentity - package kalix.javasdk.eventsourcedentity
-
Event Sourced Entity support.
- kalix.javasdk.impl - package kalix.javasdk.impl
-
Internal implementation classes for Kalix Java Support.
- kalix.javasdk.logging - package kalix.javasdk.logging
- kalix.javasdk.replicatedentity - package kalix.javasdk.replicatedentity
-
Replicated Entity support.
- kalix.javasdk.timer - package kalix.javasdk.timer
- kalix.javasdk.valueentity - package kalix.javasdk.valueentity
-
Value Entity support.
- kalix.javasdk.view - package kalix.javasdk.view
- kalix.javasdk.workflow - package kalix.javasdk.workflow
- keySet() - Method in interface kalix.javasdk.replicatedentity.ReplicatedCounterMap
-
Get a
Set
view of the keys contained in this counter map. - keySet() - Method in interface kalix.javasdk.replicatedentity.ReplicatedMap
-
Get a
Set
view of the keys contained in this map. - keySet() - Method in interface kalix.javasdk.replicatedentity.ReplicatedMultiMap
-
Return the keys contained in this multi-map.
- keySet() - Method in interface kalix.javasdk.replicatedentity.ReplicatedRegisterMap
-
Get a
Set
view of the keys contained in this register map.
L
- LOCAL - Enum constant in enum kalix.javasdk.replicatedentity.WriteConsistency
-
Updates will only be written to the local replica immediately, and then asynchronously distributed to other replicas in the background.
- localService(String) - Static method in interface kalix.javasdk.Principal
-
Create a local service principal with the given name
- LogbackJsonLayout - Class in kalix.javasdk.logging
-
This Logback JSON layout uses the name `severity` (instead of `level`).
- LogbackJsonLayout() - Constructor for class kalix.javasdk.logging.LogbackJsonLayout
M
- MAJORITY - Enum constant in enum kalix.javasdk.replicatedentity.WriteConsistency
-
Updates will be written immediately to a majority of replicas, and then asynchronously distributed to remaining replicas in the background.
- materializer() - Method in interface kalix.javasdk.Context
-
An Akka Stream materializer to use for running streams.
- maxRetries - Variable in class kalix.javasdk.workflow.AbstractWorkflow.RecoverStrategy
- maxRetries - Variable in class kalix.javasdk.workflow.AbstractWorkflow.RecoverStrategy.MaxRetries
- maxRetries(int) - Method in class kalix.javasdk.workflow.AbstractWorkflow
-
Starts defining a recover strategy for the workflow or a specific step.
- maxRetries(int) - Static method in class kalix.javasdk.workflow.AbstractWorkflow.RecoverStrategy
-
Set the number of retires for a failed step,
maxRetries
equals 0 means that the step won't retry in case of failure. - MaxRetries(int) - Constructor for class kalix.javasdk.workflow.AbstractWorkflow.RecoverStrategy.MaxRetries
- message() - Method in interface kalix.javasdk.DeferredCall
-
The message to pass to the call when the call is invoked.
- MessageEnvelope<T> - Interface in kalix.javasdk.action
-
A message envelope.
- metadata() - Method in interface kalix.javasdk.action.ActionContext
-
Get the metadata associated with this call.
- metadata() - Method in interface kalix.javasdk.action.MessageEnvelope
-
The metadata associated with the message.
- metadata() - Method in interface kalix.javasdk.DeferredCall
- metadata() - Method in interface kalix.javasdk.MetadataContext
-
Get the metadata associated with this context.
- Metadata - Interface in kalix.javasdk
-
Transport specific metadata.
- Metadata.MetadataEntry - Interface in kalix.javasdk
-
A metadata entry.
- MetadataContext - Interface in kalix.javasdk
-
Context that provides access to metadata.
- Migration - Annotation Type in kalix.javasdk.annotations
-
Annotation to assign a @
JsonMigration
implementation for a given class. - MOVED_PERMANENTLY - Enum constant in enum kalix.javasdk.StatusCode.Redirect
- MULTI_STATUS - Enum constant in enum kalix.javasdk.StatusCode.Success
- MULTIPLE_CHOICES - Enum constant in enum kalix.javasdk.StatusCode.Redirect
N
- name() - Method in class kalix.javasdk.workflow.AbstractWorkflow.AsyncCallStep
- name() - Method in class kalix.javasdk.workflow.AbstractWorkflow.CallStep
- name() - Method in interface kalix.javasdk.workflow.AbstractWorkflow.Step
- newCounter() - Method in interface kalix.javasdk.replicatedentity.ReplicatedDataFactory
-
Create a new counter.
- newRegister(T) - Method in interface kalix.javasdk.replicatedentity.ReplicatedDataFactory
-
Create a new ReplicatedRegister.
- newReplicatedCounterMap() - Method in interface kalix.javasdk.replicatedentity.ReplicatedDataFactory
-
Create a new map of counters.
- newReplicatedMap() - Method in interface kalix.javasdk.replicatedentity.ReplicatedDataFactory
-
Create a new ReplicatedMap.
- newReplicatedMultiMap() - Method in interface kalix.javasdk.replicatedentity.ReplicatedDataFactory
-
Create a new multimap (map of sets).
- newReplicatedRegisterMap() - Method in interface kalix.javasdk.replicatedentity.ReplicatedDataFactory
-
Create a new map of registers.
- newReplicatedSet() - Method in interface kalix.javasdk.replicatedentity.ReplicatedDataFactory
-
Create a new ReplicatedSet.
- newRouter(ActionCreationContext) - Method in interface kalix.javasdk.action.ActionProvider
- newRouter(EventSourcedEntityContext) - Method in interface kalix.javasdk.eventsourcedentity.EventSourcedEntityProvider
- newRouter(ReplicatedEntityContext) - Method in interface kalix.javasdk.replicatedentity.ReplicatedEntityProvider
- newRouter(ValueEntityContext) - Method in interface kalix.javasdk.valueentity.ValueEntityProvider
- newRouter(ViewCreationContext) - Method in interface kalix.javasdk.view.ViewProvider
- newRouter(WorkflowContext) - Method in interface kalix.javasdk.workflow.WorkflowProvider
- newVote() - Method in interface kalix.javasdk.replicatedentity.ReplicatedDataFactory
-
Create a new Vote.
- NO_CONTENT - Enum constant in enum kalix.javasdk.StatusCode.Success
- noContent() - Static method in class kalix.javasdk.HttpResponse
-
Creates a 204 NO CONTENT response.
- NON_AUTHORITATIVE_INFORMATION - Enum constant in enum kalix.javasdk.StatusCode.Success
- NOT_FOUND - Enum constant in enum kalix.javasdk.StatusCode.ErrorCode
- NOT_MODIFIED - Enum constant in enum kalix.javasdk.StatusCode.Redirect
- notBefore() - Method in interface kalix.javasdk.JwtClaims
-
Get the not before, that is, the nbf claim, as described in RFC 7519 section 4.1.5.
O
- of(String, URI, String) - Static method in interface kalix.javasdk.CloudEvent
-
Create a CloudEvent.
- of(DeferredCall) - Static method in interface kalix.javasdk.SideEffect
-
Create a side effect of the given service call.
- of(DeferredCall, boolean) - Static method in interface kalix.javasdk.SideEffect
-
Create a side effect of the given service call.
- of(StatusCode.Success, String, byte[]) - Static method in class kalix.javasdk.HttpResponse
-
Creates an HTTP response with specified status code, content type and body.
- of(T) - Static method in interface kalix.javasdk.action.MessageEnvelope
-
Create a message.
- of(T, Metadata) - Static method in interface kalix.javasdk.action.MessageEnvelope
-
Create a message.
- ok() - Static method in class kalix.javasdk.HttpResponse
-
Creates a 200 OK response.
- ok(byte[]) - Static method in class kalix.javasdk.HttpResponse
-
Creates a 200 OK response with a application/octet-stream body.
- ok(Object) - Static method in class kalix.javasdk.HttpResponse
-
Creates a 200 OK response with a application/json body.
- ok(String) - Static method in class kalix.javasdk.HttpResponse
-
Creates a 200 OK response with a text/plain body.
- OK - Enum constant in enum kalix.javasdk.StatusCode.Success
- options() - Method in interface kalix.javasdk.action.ActionProvider
- options() - Method in interface kalix.javasdk.eventsourcedentity.EventSourcedEntityProvider
- options() - Method in interface kalix.javasdk.replicatedentity.ReplicatedEntityProvider
- options() - Method in interface kalix.javasdk.valueentity.ValueEntityProvider
- options() - Method in interface kalix.javasdk.view.ViewProvider
- options() - Method in interface kalix.javasdk.workflow.WorkflowProvider
P
- parseBytes(byte[], Class<T>) - Static method in class kalix.javasdk.JsonSupport
- PARTIAL_CONTENT - Enum constant in enum kalix.javasdk.StatusCode.Success
- passivationStrategy() - Method in interface kalix.javasdk.replicatedentity.ReplicatedEntityOptions
- PassivationStrategy - Interface in kalix.javasdk
-
A passivation strategy.
- pause() - Method in interface kalix.javasdk.workflow.AbstractWorkflow.Effect.Builder
-
Pause the workflow execution and wait for an external input, e.g.
- pause() - Method in interface kalix.javasdk.workflow.AbstractWorkflow.Effect.PersistenceEffectBuilder
-
Pause the workflow execution and wait for an external input, e.g.
- payload() - Method in interface kalix.javasdk.action.MessageEnvelope
-
The payload of the message.
- PERMANENT_REDIRECT - Enum constant in enum kalix.javasdk.StatusCode.Redirect
- preferJavaProtobufs() - Method in class kalix.javasdk.Kalix
-
When locating protobufs, if both a Java and a ScalaPB generated class is found on the classpath, this specifies that Java should be preferred.
- preferScalaProtobufs() - Method in class kalix.javasdk.Kalix
-
When locating protobufs, if both a Java and a ScalaPB generated class is found on the classpath, this specifies that Scala should be preferred.
- Principal - Interface in kalix.javasdk
-
A principal associated with a request.
- Principal.Basic - Enum in kalix.javasdk
-
Basic principals that have no additional configuration.
- Principal.LocalService - Class in kalix.javasdk
-
A local service principal.
- principals() - Method in interface kalix.javasdk.Metadata
-
Get the principals associated with this request metadata.
- Principals - Interface in kalix.javasdk
-
The principals associated with a request.
- ProtoStepBuilder - Class in kalix.javasdk.workflow
-
Step builder for defining a workflow step for Java protobuf SDK
- ProtoStepBuilder(String) - Constructor for class kalix.javasdk.workflow.ProtoStepBuilder
- ProtoStepBuilder.AsyncCallStepBuilder<CallInput,
CallOutput> - Class in kalix.javasdk.workflow - ProtoStepBuilder.CallStepBuilder<Input,
DefCallInput, DefCallOutput> - Class in kalix.javasdk.workflow - ProtoWorkflow<S extends com.google.protobuf.GeneratedMessageV3> - Class in kalix.javasdk.workflow
-
Workflows are stateful components and are defined by a set of steps and transitions between them.
- ProtoWorkflow() - Constructor for class kalix.javasdk.workflow.ProtoWorkflow
- put(K, V) - Method in interface kalix.javasdk.replicatedentity.ReplicatedMultiMap
-
Store a key-value pair, if not already present.
- putAll(K, Collection<V>) - Method in interface kalix.javasdk.replicatedentity.ReplicatedMultiMap
-
Store multiple values for a key.
R
- recoverStrategy - Variable in class kalix.javasdk.workflow.AbstractWorkflow.StepConfig
- RecoverStrategy(int, String, Optional<T>) - Constructor for class kalix.javasdk.workflow.AbstractWorkflow.RecoverStrategy
- register(ActionProvider<A>) - Method in class kalix.javasdk.Kalix
-
Register an action using an {
ActionProvider
}. - register(EventSourcedEntityProvider<S, E, ES>) - Method in class kalix.javasdk.Kalix
-
Register an event sourced entity using a {
EventSourcedEntityProvider
}. - register(ReplicatedEntityProvider<D, E>) - Method in class kalix.javasdk.Kalix
-
Register a replicated entity using a
ReplicatedEntityProvider
. - register(ValueEntityProvider<S, E>) - Method in class kalix.javasdk.Kalix
-
Register a value based entity using a {
ValueEntityProvider
}. - register(ViewProvider) - Method in class kalix.javasdk.Kalix
-
Register a view using a
ViewProvider
. - register(WorkflowProvider<S, W>) - Method in class kalix.javasdk.Kalix
- remove(E) - Method in interface kalix.javasdk.replicatedentity.ReplicatedSet
-
Remove an element from this set if it is present.
- remove(String) - Method in interface kalix.javasdk.Metadata
-
Remove all metadata entries with the given key.
- remove(K) - Method in interface kalix.javasdk.replicatedentity.ReplicatedCounterMap
-
Remove the mapping for a key if it is present.
- remove(K) - Method in interface kalix.javasdk.replicatedentity.ReplicatedMap
-
Remove the mapping for a key if it is present.
- remove(K) - Method in interface kalix.javasdk.replicatedentity.ReplicatedRegisterMap
-
Remove the mapping for a key if it is present.
- remove(K, V) - Method in interface kalix.javasdk.replicatedentity.ReplicatedMultiMap
-
Remove a single key-value pair for the given key and value, if present.
- removeAll(Collection<E>) - Method in interface kalix.javasdk.replicatedentity.ReplicatedSet
-
Remove elements from this set if they're present.
- removeAll(K) - Method in interface kalix.javasdk.replicatedentity.ReplicatedMultiMap
-
Remove all values associated with the given key.
- ReplicatedCounter - Interface in kalix.javasdk.replicatedentity
-
A counter that can be incremented and decremented.
- ReplicatedCounterEntity - Class in kalix.javasdk.replicatedentity
- ReplicatedCounterEntity() - Constructor for class kalix.javasdk.replicatedentity.ReplicatedCounterEntity
- ReplicatedCounterMap<K> - Interface in kalix.javasdk.replicatedentity
-
A Map of counters.
- ReplicatedCounterMapEntity<K> - Class in kalix.javasdk.replicatedentity
- ReplicatedCounterMapEntity() - Constructor for class kalix.javasdk.replicatedentity.ReplicatedCounterMapEntity
- ReplicatedDataFactory - Interface in kalix.javasdk.replicatedentity
-
Factory for creating Replicated Data objects.
- ReplicatedEntity<D extends kalix.replicatedentity.ReplicatedData> - Class in kalix.javasdk.replicatedentity
- ReplicatedEntity() - Constructor for class kalix.javasdk.replicatedentity.ReplicatedEntity
- ReplicatedEntity.Effect<R> - Interface in kalix.javasdk.replicatedentity
-
An Effect is a description of what Kalix needs to do after the command is handled.
- ReplicatedEntity.Effect.Builder<D> - Interface in kalix.javasdk.replicatedentity
-
Construct the effect that is returned by the command handler.
- ReplicatedEntity.Effect.OnSuccessBuilder - Interface in kalix.javasdk.replicatedentity
- ReplicatedEntityContext - Interface in kalix.javasdk.replicatedentity
-
Root context for all Replicated Entity contexts.
- ReplicatedEntityFactory - Interface in kalix.javasdk.impl
-
Low level interface for handling commands on a replicated entity.
- ReplicatedEntityOptions - Interface in kalix.javasdk.replicatedentity
-
Root entity options for all Replicated Entities.
- ReplicatedEntityProvider<D extends kalix.replicatedentity.ReplicatedData,
E extends ReplicatedEntity<D>> - Interface in kalix.javasdk.replicatedentity -
Register a value based entity in
Kalix
using aReplicatedEntityProvider
. - ReplicatedMap<K,
V extends kalix.replicatedentity.ReplicatedData> - Interface in kalix.javasdk.replicatedentity -
A Replicated Map that allows both the addition and removal of
ReplicatedData
objects. - ReplicatedMapEntity<K,
V extends kalix.replicatedentity.ReplicatedData> - Class in kalix.javasdk.replicatedentity - ReplicatedMapEntity() - Constructor for class kalix.javasdk.replicatedentity.ReplicatedMapEntity
- ReplicatedMultiMap<K,
V> - Interface in kalix.javasdk.replicatedentity -
A replicated map that maps keys to values, where each key may be associated with multiple values.
- ReplicatedMultiMapEntity<K,
V> - Class in kalix.javasdk.replicatedentity - ReplicatedMultiMapEntity() - Constructor for class kalix.javasdk.replicatedentity.ReplicatedMultiMapEntity
- ReplicatedRegister<T> - Interface in kalix.javasdk.replicatedentity
-
A Last-Write-Wins Register.
- ReplicatedRegister.Clock - Enum in kalix.javasdk.replicatedentity
-
Clock for register replication
- ReplicatedRegisterEntity<T> - Class in kalix.javasdk.replicatedentity
- ReplicatedRegisterEntity() - Constructor for class kalix.javasdk.replicatedentity.ReplicatedRegisterEntity
- ReplicatedRegisterMap<K,
V> - Interface in kalix.javasdk.replicatedentity -
A Map of registers.
- ReplicatedRegisterMapEntity<K,
V> - Class in kalix.javasdk.replicatedentity - ReplicatedRegisterMapEntity() - Constructor for class kalix.javasdk.replicatedentity.ReplicatedRegisterMapEntity
- ReplicatedSet<E> - Interface in kalix.javasdk.replicatedentity
-
A Replicated Set that allows both the addition and removal of elements in a set.
- ReplicatedSetEntity<T> - Class in kalix.javasdk.replicatedentity
- ReplicatedSetEntity() - Constructor for class kalix.javasdk.replicatedentity.ReplicatedSetEntity
- ReplicatedVote - Interface in kalix.javasdk.replicatedentity
-
A Vote replicated data type.
- ReplicatedVoteEntity - Class in kalix.javasdk.replicatedentity
- ReplicatedVoteEntity() - Constructor for class kalix.javasdk.replicatedentity.ReplicatedVoteEntity
- reply(R) - Method in interface kalix.javasdk.workflow.AbstractWorkflow.Effect.Builder
-
Create a message reply.
- reply(R, Metadata) - Method in interface kalix.javasdk.workflow.AbstractWorkflow.Effect.Builder
-
Reply after for example
updateState
. - reply(S) - Method in interface kalix.javasdk.action.Action.Effect.Builder
-
Create a message reply.
- reply(S, Metadata) - Method in interface kalix.javasdk.action.Action.Effect.Builder
-
Create a message reply with custom Metadata.
- reply(T) - Method in interface kalix.javasdk.eventsourcedentity.EventSourcedEntity.Effect.Builder
-
Create a message reply.
- reply(T) - Method in interface kalix.javasdk.replicatedentity.ReplicatedEntity.Effect.Builder
-
Create a message reply.
- reply(T) - Method in interface kalix.javasdk.valueentity.ValueEntity.Effect.Builder
-
Create a message reply.
- reply(T, Metadata) - Method in interface kalix.javasdk.eventsourcedentity.EventSourcedEntity.Effect.Builder
-
Create a message reply.
- reply(T, Metadata) - Method in interface kalix.javasdk.replicatedentity.ReplicatedEntity.Effect.Builder
-
Create a message reply.
- reply(T, Metadata) - Method in interface kalix.javasdk.valueentity.ValueEntity.Effect.Builder
-
Create a message reply.
- RESET_CONTENT - Enum constant in enum kalix.javasdk.StatusCode.Success
- retainAll(Collection<E>) - Method in interface kalix.javasdk.replicatedentity.ReplicatedSet
-
Retain only the elements that are contained in the given collection.
- REVERSE - Enum constant in enum kalix.javasdk.replicatedentity.ReplicatedRegister.Clock
-
A reverse clock, based on the system clock.
S
- SEE_OTHER - Enum constant in enum kalix.javasdk.StatusCode.Redirect
- SELF - Enum constant in enum kalix.javasdk.Principal.Basic
- SELF - Static variable in interface kalix.javasdk.Principal
-
Abstract principal representing all requests from self
- sequenceNumber() - Method in interface kalix.javasdk.eventsourcedentity.CommandContext
-
The current sequence number of events in this entity.
- sequenceNumber() - Method in interface kalix.javasdk.eventsourcedentity.EventContext
-
The sequence number of the current event being processed.
- SERVICE_UNAVAILABLE - Enum constant in enum kalix.javasdk.StatusCode.ErrorCode
- serviceDescriptor() - Method in interface kalix.javasdk.action.ActionProvider
- serviceDescriptor() - Method in interface kalix.javasdk.eventsourcedentity.EventSourcedEntityProvider
- serviceDescriptor() - Method in interface kalix.javasdk.replicatedentity.ReplicatedEntityProvider
- serviceDescriptor() - Method in interface kalix.javasdk.valueentity.ValueEntityProvider
- serviceDescriptor() - Method in interface kalix.javasdk.view.ViewProvider
- serviceDescriptor() - Method in interface kalix.javasdk.workflow.WorkflowProvider
- set(String, String) - Method in interface kalix.javasdk.Metadata
-
Set the string value for the given key.
- set(T) - Method in interface kalix.javasdk.replicatedentity.ReplicatedRegister
-
Set the value of the register, using the default clock.
- set(T, ReplicatedRegister.Clock, long) - Method in interface kalix.javasdk.replicatedentity.ReplicatedRegister
-
Set the current value of the register, using the given custom clock and clock value if required.
- setBinary(String, ByteBuffer) - Method in interface kalix.javasdk.Metadata
-
Set the binary value for the given key.
- setValue(K, V) - Method in interface kalix.javasdk.replicatedentity.ReplicatedRegisterMap
-
Set the current value of the register at the given key, using the default clock.
- setValue(K, V, ReplicatedRegister.Clock, long) - Method in interface kalix.javasdk.replicatedentity.ReplicatedRegisterMap
-
Set the current value of the register at the given key, using the given clock and custom clock value if required.
- SideEffect - Interface in kalix.javasdk
-
A side effect.
- size() - Method in interface kalix.javasdk.replicatedentity.ReplicatedCounterMap
-
Get the number of key-counter mappings in this counter map.
- size() - Method in interface kalix.javasdk.replicatedentity.ReplicatedMap
-
Get the number of key-value mappings in this map.
- size() - Method in interface kalix.javasdk.replicatedentity.ReplicatedMultiMap
-
Return the number of key-value pairs in this multi-map.
- size() - Method in interface kalix.javasdk.replicatedentity.ReplicatedRegisterMap
-
Get the number of key-register mappings in this register map.
- size() - Method in interface kalix.javasdk.replicatedentity.ReplicatedSet
-
Get the number of elements in this set (its cardinality).
- snapshotEvery() - Method in interface kalix.javasdk.eventsourcedentity.EventSourcedEntityOptions
- source() - Method in interface kalix.javasdk.CloudEvent
-
The source of this CloudEvent.
- specversion() - Method in interface kalix.javasdk.CloudEvent
-
The CloudEvent spec version.
- start() - Method in class kalix.javasdk.Kalix
-
Starts a server with the configured entities.
- start(Config) - Method in class kalix.javasdk.Kalix
-
Starts a server with the configured entities, using the supplied configuration.
- startSingleTimer(String, Duration, int, DeferredCall<I, O>) - Method in interface kalix.javasdk.timer.TimerScheduler
-
Schedule a single timer in Kalix.
- startSingleTimer(String, Duration, DeferredCall<I, O>) - Method in interface kalix.javasdk.timer.TimerScheduler
-
Schedule a single timer in Kalix.
- STATUS_CODE_EXTENSION_TYPE_URL - Static variable in class kalix.javasdk.HttpResponse
- StatusCode - Interface in kalix.javasdk
-
Interface used to represent HTTP status code.
- StatusCode.ErrorCode - Enum in kalix.javasdk
-
The supported HTTP error codes that can be used when replying from the Kalix user function.
- StatusCode.Redirect - Enum in kalix.javasdk
- StatusCode.Success - Enum in kalix.javasdk
- step(String) - Method in class kalix.javasdk.workflow.ProtoWorkflow
-
Start a step definition with a given step name.
- step(String) - Method in class kalix.javasdk.workflow.StepBuilder
- step(String) - Method in class kalix.javasdk.workflow.Workflow
-
Start a step definition with a given step name.
- StepBuilder - Class in kalix.javasdk.workflow
- StepBuilder(String) - Constructor for class kalix.javasdk.workflow.StepBuilder
- StepBuilder.AsyncCallStepBuilder<CallInput,
CallOutput> - Class in kalix.javasdk.workflow - StepBuilder.CallStepBuilder<Input,
DefCallInput, DefCallOutput> - Class in kalix.javasdk.workflow - StepConfig(String, Optional<Duration>, Optional<AbstractWorkflow.RecoverStrategy<?>>) - Constructor for class kalix.javasdk.workflow.AbstractWorkflow.StepConfig
- stepName - Variable in class kalix.javasdk.workflow.AbstractWorkflow.StepConfig
- subject() - Method in interface kalix.javasdk.CloudEvent
-
The subject of this CloudEvent.
- subject() - Method in interface kalix.javasdk.JwtClaims
-
Get the subject, that is, the sub claim, as described in RFC 7519 section 4.1.2.
- supportedClassNames() - Method in class kalix.javasdk.JsonMigration
-
Override this method if you have changed the class name.
- supportedForwardVersion() - Method in class kalix.javasdk.JsonMigration
-
Define the supported forward version this migration can read (must be greater or equal than `currentVersion`).
- synchronous() - Method in interface kalix.javasdk.SideEffect
-
Whether this effect should be executed synchronously or not.
T
- TEMPORARY_REDIRECT - Enum constant in enum kalix.javasdk.StatusCode.Redirect
- thenAddSideEffect(Function<S, SideEffect>) - Method in interface kalix.javasdk.eventsourcedentity.EventSourcedEntity.Effect.OnSuccessBuilder
-
Attach the given side effect to this reply from the new state.
- thenForward(Function<S, DeferredCall<? extends Object, T>>) - Method in interface kalix.javasdk.eventsourcedentity.EventSourcedEntity.Effect.OnSuccessBuilder
-
Create a forward reply after for example
emitEvent
. - thenForward(DeferredCall<? extends Object, T>) - Method in interface kalix.javasdk.replicatedentity.ReplicatedEntity.Effect.OnSuccessBuilder
-
Create a forward reply after for example
delete
. - thenForward(DeferredCall<? extends Object, T>) - Method in interface kalix.javasdk.valueentity.ValueEntity.Effect.OnSuccessBuilder
-
Create a forward reply after for example
updateState
. - thenReply(Function<S, T>) - Method in interface kalix.javasdk.eventsourcedentity.EventSourcedEntity.Effect.OnSuccessBuilder
-
Reply after for example
emitEvent
. - thenReply(Function<S, T>, Metadata) - Method in interface kalix.javasdk.eventsourcedentity.EventSourcedEntity.Effect.OnSuccessBuilder
-
Reply after for example
emitEvent
. - thenReply(R) - Method in interface kalix.javasdk.workflow.AbstractWorkflow.Effect.TransitionalEffect
-
Reply after for example
updateState
. - thenReply(R, Metadata) - Method in interface kalix.javasdk.workflow.AbstractWorkflow.Effect.TransitionalEffect
-
Reply after for example
updateState
. - thenReply(T) - Method in interface kalix.javasdk.replicatedentity.ReplicatedEntity.Effect.OnSuccessBuilder
-
Reply after for example
delete
. - thenReply(T) - Method in interface kalix.javasdk.valueentity.ValueEntity.Effect.OnSuccessBuilder
-
Reply after for example
updateState
. - thenReply(T, Metadata) - Method in interface kalix.javasdk.replicatedentity.ReplicatedEntity.Effect.OnSuccessBuilder
-
Reply after for example
delete
. - thenReply(T, Metadata) - Method in interface kalix.javasdk.valueentity.ValueEntity.Effect.OnSuccessBuilder
-
Reply after for example
updateState
. - time() - Method in interface kalix.javasdk.CloudEvent
-
The time of this CloudEvent.
- timeout - Variable in class kalix.javasdk.workflow.AbstractWorkflow.StepConfig
- timeout() - Method in class kalix.javasdk.workflow.AbstractWorkflow.AsyncCallStep
- timeout() - Method in class kalix.javasdk.workflow.AbstractWorkflow.CallStep
- timeout() - Method in interface kalix.javasdk.workflow.AbstractWorkflow.Step
- timeout(Duration) - Static method in interface kalix.javasdk.PassivationStrategy
-
Create a passivation strategy that passivates the entity after a given duration of inactivity.
- timeout(Duration) - Method in class kalix.javasdk.workflow.AbstractWorkflow.AsyncCallStep
-
Define a step timeout.
- timeout(Duration) - Method in class kalix.javasdk.workflow.AbstractWorkflow.CallStep
-
Define a step timeout.
- timeout(Duration) - Method in class kalix.javasdk.workflow.AbstractWorkflow.WorkflowDef
-
Define a timeout for the duration of the entire workflow.
- timers() - Method in class kalix.javasdk.action.Action
-
Returns a
TimerScheduler
that can be used to schedule further in time. - timers() - Method in class kalix.javasdk.workflow.AbstractWorkflow
-
Returns a
TimerScheduler
that can be used to schedule further in time. - TimerScheduler - Interface in kalix.javasdk.timer
- TOO_MANY_REQUESTS - Enum constant in enum kalix.javasdk.StatusCode.ErrorCode
- toString() - Method in class kalix.javasdk.Principal.LocalService
- traceContext() - Method in interface kalix.javasdk.Metadata
-
Get the trace context associated with this request metadata.
- TraceContext - Interface in kalix.javasdk
-
Utility interface for trace context helper methods.
- traceId() - Method in interface kalix.javasdk.TraceContext
-
Allows retrieving the trace id of the trace parent if any.
- traceParent() - Method in interface kalix.javasdk.TraceContext
-
Allows retrieving the trace parent for easier injection in external calls (e.g.
- traceState() - Method in interface kalix.javasdk.TraceContext
-
Allows retrieving the trace state for easier injection in external calls (e.g.
- transform(int, JsonNode) - Method in class kalix.javasdk.JsonMigration
-
Implement the transformation of the incoming JSON structure to the current JSON structure.
- transitionFunc - Variable in class kalix.javasdk.workflow.AbstractWorkflow.AsyncCallStep
- transitionFunc - Variable in class kalix.javasdk.workflow.AbstractWorkflow.CallStep
- transitionInputClass - Variable in class kalix.javasdk.workflow.AbstractWorkflow.AsyncCallStep
- transitionInputClass - Variable in class kalix.javasdk.workflow.AbstractWorkflow.CallStep
- transitionTo(String) - Method in interface kalix.javasdk.workflow.AbstractWorkflow.Effect.Builder
-
Defines the next step to which the workflow should transition to.
- transitionTo(String) - Method in interface kalix.javasdk.workflow.AbstractWorkflow.Effect.PersistenceEffectBuilder
-
Defines the next step to which the workflow should transition to.
- transitionTo(String, I) - Method in interface kalix.javasdk.workflow.AbstractWorkflow.Effect.Builder
-
Defines the next step to which the workflow should transition to.
- transitionTo(String, I) - Method in interface kalix.javasdk.workflow.AbstractWorkflow.Effect.PersistenceEffectBuilder
-
Defines the next step to which the workflow should transition to.
- type() - Method in interface kalix.javasdk.CloudEvent
-
The type of this CloudEvent.
- typeId() - Method in interface kalix.javasdk.eventsourcedentity.EventSourcedEntityProvider
- typeId() - Method in interface kalix.javasdk.replicatedentity.ReplicatedEntityProvider
- typeId() - Method in interface kalix.javasdk.valueentity.ValueEntityProvider
- typeId() - Method in interface kalix.javasdk.workflow.WorkflowProvider
U
- UNAUTHORIZED - Enum constant in enum kalix.javasdk.StatusCode.ErrorCode
- update(D) - Method in interface kalix.javasdk.replicatedentity.ReplicatedEntity.Effect.Builder
-
Update the underlying replicated data for the replicated entity.
- update(K, V) - Method in interface kalix.javasdk.replicatedentity.ReplicatedMap
-
Update the
ReplicatedData
value associated with the given key. - updateContext() - Method in class kalix.javasdk.view.View
-
Additional context and metadata for an update handler.
- UpdateContext - Interface in kalix.javasdk.view
-
Context for view update calls.
- updateState(S) - Method in interface kalix.javasdk.valueentity.ValueEntity.Effect.Builder
- updateState(S) - Method in interface kalix.javasdk.view.View.UpdateEffect.Builder
- updateState(S) - Method in interface kalix.javasdk.workflow.AbstractWorkflow.Effect.Builder
- USE_PROXY - Enum constant in enum kalix.javasdk.StatusCode.Redirect
V
- value() - Element in annotation type kalix.javasdk.annotations.Migration
- value() - Method in enum kalix.javasdk.StatusCode.ErrorCode
- value() - Method in enum kalix.javasdk.StatusCode.Redirect
- value() - Method in enum kalix.javasdk.StatusCode.Success
- value() - Method in interface kalix.javasdk.StatusCode
- ValueEntity<S> - Class in kalix.javasdk.valueentity
-
Value Entities persist their state on every change.
- ValueEntity() - Constructor for class kalix.javasdk.valueentity.ValueEntity
- ValueEntity.Effect<T> - Interface in kalix.javasdk.valueentity
-
An Effect is a description of what Kalix needs to do after the command is handled.
- ValueEntity.Effect.Builder<S> - Interface in kalix.javasdk.valueentity
-
Construct the effect that is returned by the command handler.
- ValueEntity.Effect.OnSuccessBuilder<S> - Interface in kalix.javasdk.valueentity
- ValueEntityContext - Interface in kalix.javasdk.valueentity
-
Root context for all value based entity contexts.
- ValueEntityFactory - Interface in kalix.javasdk.impl
-
Low level interface for handling commands on a value based entity.
- ValueEntityOptions - Interface in kalix.javasdk.valueentity
-
Root entity options for all value based entities.
- ValueEntityProvider<S,
E extends ValueEntity<S>> - Interface in kalix.javasdk.valueentity -
Register a value based entity in
Kalix
using aValueEntityProvider
. - valueOf(String) - Static method in enum kalix.javasdk.Principal.Basic
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kalix.javasdk.replicatedentity.ReplicatedRegister.Clock
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kalix.javasdk.replicatedentity.WriteConsistency
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kalix.javasdk.StatusCode.ErrorCode
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kalix.javasdk.StatusCode.Redirect
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kalix.javasdk.StatusCode.Success
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum kalix.javasdk.Principal.Basic
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum kalix.javasdk.replicatedentity.ReplicatedRegister.Clock
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum kalix.javasdk.replicatedentity.WriteConsistency
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum kalix.javasdk.StatusCode.ErrorCode
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum kalix.javasdk.StatusCode.Redirect
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum kalix.javasdk.StatusCode.Success
-
Returns an array containing the constants of this enum type, in the order they are declared.
- View<S> - Class in kalix.javasdk.view
-
Kalix applications follow the Command Query Responsibility Segregation (CQRS) pattern (see https://developer.lightbend.com/docs/akka-guide/concepts/cqrs.html).
- View() - Constructor for class kalix.javasdk.view.View
- View.UpdateEffect<S> - Interface in kalix.javasdk.view
-
An UpdateEffect is a description of what Kalix needs to do after the command is handled.
- View.UpdateEffect.Builder<S> - Interface in kalix.javasdk.view
- ViewContext - Interface in kalix.javasdk.view
-
Context for views.
- ViewCreationContext - Interface in kalix.javasdk.view
-
Creation context for
View
entities. - ViewFactory - Interface in kalix.javasdk.impl
-
Low level interface for handling messages in views.
- viewId() - Method in interface kalix.javasdk.view.ViewContext
-
The id of the view that this context is for.
- viewId() - Method in interface kalix.javasdk.view.ViewProvider
- ViewOptions - Interface in kalix.javasdk.view
- ViewProvider - Interface in kalix.javasdk.view
- viewState() - Method in class kalix.javasdk.view.View
-
Returns the view state (row) for this invocation as currently stored in Kalix.
- vote(boolean) - Method in interface kalix.javasdk.replicatedentity.ReplicatedVote
-
Update this node's vote to the given value.
W
- withClassLoader(ClassLoader) - Method in class kalix.javasdk.Kalix
-
Sets the ClassLoader to be used for reflective access, the default value is the ClassLoader of the Kalix class.
- withDatacontenttype(String) - Method in interface kalix.javasdk.CloudEvent
-
Return a new CloudEvent with the given data content type.
- withDataschema(URI) - Method in interface kalix.javasdk.CloudEvent
-
Return a new CloudEvent with the given data schema.
- withDefaultAclFileDescriptor(Optional<DescriptorProtos.FileDescriptorProto>) - Method in class kalix.javasdk.Kalix
-
INTERNAL API - subject to change without notice
- withForwardHeaders(Set<String>) - Method in interface kalix.javasdk.action.ActionOptions
-
Ask Kalix to forward these headers from the incoming request as metadata headers for the incoming commands.
- withForwardHeaders(Set<String>) - Method in interface kalix.javasdk.EntityOptions
-
Ask Kalix to forward these headers from the incoming request as metadata headers for the incoming commands.
- withForwardHeaders(Set<String>) - Method in interface kalix.javasdk.eventsourcedentity.EventSourcedEntityOptions
- withForwardHeaders(Set<String>) - Method in interface kalix.javasdk.valueentity.ValueEntityOptions
- withForwardHeaders(Set<String>) - Method in interface kalix.javasdk.view.ViewOptions
-
Ask Kalix to forward these headers from the incoming request as metadata headers for the incoming commands.
- withId(String) - Method in interface kalix.javasdk.CloudEvent
-
Return a new CloudEvent with the given id.
- withMetadata(Metadata) - Method in interface kalix.javasdk.DeferredCall
- withPassivationStrategy(PassivationStrategy) - Method in interface kalix.javasdk.replicatedentity.ReplicatedEntityOptions
- withSdkName(String) - Method in class kalix.javasdk.Kalix
-
INTERNAL API - subject to change without notice
- withSnapshotEvery(int) - Method in interface kalix.javasdk.eventsourcedentity.EventSourcedEntityOptions
-
Specifies how snapshots of the entity state should be made: Zero means use default from configuration file.
- withSource(URI) - Method in interface kalix.javasdk.CloudEvent
-
Return a new CloudEvent with the given source.
- withStatusCode(StatusCode.Redirect) - Method in interface kalix.javasdk.Metadata
-
Add an HTTP response code to this metadata.
- withStatusCode(StatusCode.Success) - Method in interface kalix.javasdk.Metadata
-
Add an HTTP response code to this metadata.
- withSubject(String) - Method in interface kalix.javasdk.CloudEvent
-
Return a new CloudEvent with the given subject.
- withTime(ZonedDateTime) - Method in interface kalix.javasdk.CloudEvent
-
Return a new CloudEvent with the given time.
- withType(String) - Method in interface kalix.javasdk.CloudEvent
-
Return a new CloudEvent with the given type.
- withTypeUrlPrefix(String) - Method in class kalix.javasdk.Kalix
-
Sets the type URL prefix to be used when serializing and deserializing types from and to Protobuf Any values.
- withWriteConsistency(WriteConsistency) - Method in interface kalix.javasdk.replicatedentity.ReplicatedEntityOptions
-
Set the write consistency setting for replication of the replicated entity state.
- workflow() - Method in class kalix.javasdk.workflow.AbstractWorkflow
- Workflow<S> - Class in kalix.javasdk.workflow
-
Workflows are stateful components and are defined by a set of steps and transitions between them.
- Workflow() - Constructor for class kalix.javasdk.workflow.Workflow
- WorkflowContext - Interface in kalix.javasdk.workflow
- WorkflowFactory - Interface in kalix.javasdk.impl
- workflowId() - Method in interface kalix.javasdk.workflow.WorkflowContext
-
The id of the workflow that this context is for.
- WorkflowOptions - Interface in kalix.javasdk.workflow
- WorkflowProvider<S,
W extends AbstractWorkflow<S>> - Interface in kalix.javasdk.workflow - writeConsistency() - Method in interface kalix.javasdk.replicatedentity.ReplicatedEntityOptions
-
Get the current write consistency setting for replication of the replicated entity state.
- WriteConsistency - Enum in kalix.javasdk.replicatedentity
-
Write consistency setting for replication of state updates for Replicated Entities.
_
- _internalSetActionContext(Optional<ActionContext>) - Method in class kalix.javasdk.action.Action
-
INTERNAL API
- _internalSetCommandContext(Optional<CommandContext>) - Method in class kalix.javasdk.eventsourcedentity.EventSourcedEntity
-
INTERNAL API
- _internalSetCommandContext(Optional<CommandContext>) - Method in class kalix.javasdk.replicatedentity.ReplicatedEntity
-
INTERNAL API
- _internalSetCommandContext(Optional<CommandContext>) - Method in class kalix.javasdk.valueentity.ValueEntity
-
INTERNAL API
- _internalSetCommandContext(Optional<CommandContext>) - Method in class kalix.javasdk.workflow.AbstractWorkflow
-
INTERNAL API
- _internalSetCurrentState(S) - Method in class kalix.javasdk.eventsourcedentity.EventSourcedEntity
-
INTERNAL API
- _internalSetCurrentState(S) - Method in class kalix.javasdk.valueentity.ValueEntity
-
INTERNAL API
- _internalSetCurrentState(S) - Method in class kalix.javasdk.workflow.AbstractWorkflow
-
INTERNAL API
- _internalSetEventContext(Optional<EventContext>) - Method in class kalix.javasdk.eventsourcedentity.EventSourcedEntity
-
INTERNAL API
- _internalSetTimerScheduler(Optional<TimerScheduler>) - Method in class kalix.javasdk.workflow.AbstractWorkflow
-
INTERNAL API
- _internalSetUpdateContext(Optional<UpdateContext>) - Method in class kalix.javasdk.view.View
-
INTERNAL API
- _internalSetViewState(S) - Method in class kalix.javasdk.view.View
-
INTERNAL API
All Classes and Interfaces|All Packages|Constant Field Values