Index

A B C D E F G H I J K L M N O P R S T U V W _ 
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 an ActionProvider.
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 a EventSourcedEntityProvider.
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
Get an OpenTelemetry tracer for the current action.
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.
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.EntityOptions
 
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 a ReplicatedEntityProvider.
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.
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 a ValueEntityProvider.
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.EntityOptions
Create an entity option with the given passivation strategy.
withPassivationStrategy(PassivationStrategy) - Method in interface kalix.javasdk.eventsourcedentity.EventSourcedEntityOptions
Deprecated, for removal: This API element is subject to removal in a future version.
passivation strategy is ignored
withPassivationStrategy(PassivationStrategy) - Method in interface kalix.javasdk.replicatedentity.ReplicatedEntityOptions
 
withPassivationStrategy(PassivationStrategy) - Method in interface kalix.javasdk.valueentity.ValueEntityOptions
Deprecated, for removal: This API element is subject to removal in a future version.
passivation strategy is ignored
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
A B C D E F G H I J K L M N O P R S T U V W _ 
All Classes and Interfaces|All Packages|Constant Field Values