A C D E F G H I J K L M N O P R S T U V W _
All Classes All Packages
All Classes All Packages
All Classes All Packages
A
- Action - Class in com.akkaserverless.javasdk.action
- Action() - Constructor for class com.akkaserverless.javasdk.action.Action
- Action.Effect<T> - Interface in com.akkaserverless.javasdk.action
-
A return type to allow returning forwards or failures, and attaching effects to messages.
- Action.Effect.Builder - Interface in com.akkaserverless.javasdk.action
-
Construct the effect that is returned by the command handler.
- actionContext() - Method in class com.akkaserverless.javasdk.action.Action
-
Additional context and metadata for a message handler.
- ActionContext - Interface in com.akkaserverless.javasdk.action
-
Context for action calls.
- ActionCreationContext - Interface in com.akkaserverless.javasdk.action
-
Creation context for
Action
components. - ActionFactory - Interface in com.akkaserverless.javasdk.impl
-
Low level interface to implement
Action
components. - ActionOptions - Interface in com.akkaserverless.javasdk.action
-
Options for actions
- ActionProvider<A extends Action> - Interface in com.akkaserverless.javasdk.action
-
Register an Action in {
AkkaServerless
} using anActionProvider
. - add(E) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedSet
-
Add an element to this set if it is not already present.
- add(String, String) - Method in interface com.akkaserverless.javasdk.Metadata
-
Add the string value for the given key.
- addAll(Collection<E>) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedSet
-
Add elements to this set if they're not already present.
- addBinary(String, ByteBuffer) - Method in interface com.akkaserverless.javasdk.Metadata
-
Add the binary value for the given key.
- addCustomDataToJsonMap(Map<String, Object>, ILoggingEvent) - Method in class com.akkaserverless.javasdk.logging.LogbackJsonLayout
- additionalDescriptors() - Method in interface com.akkaserverless.javasdk.action.ActionProvider
- additionalDescriptors() - Method in interface com.akkaserverless.javasdk.eventsourcedentity.EventSourcedEntityProvider
- additionalDescriptors() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedEntityProvider
- additionalDescriptors() - Method in interface com.akkaserverless.javasdk.valueentity.ValueEntityProvider
- additionalDescriptors() - Method in interface com.akkaserverless.javasdk.view.ViewProvider
- addSideEffect(SideEffect...) - Method in interface com.akkaserverless.javasdk.action.Action.Effect
-
Attach the given side effects to this reply.
- addSideEffects(SideEffect...) - Method in interface com.akkaserverless.javasdk.eventsourcedentity.EventSourcedEntity.Effect
-
Attach the given effects to this reply.
- addSideEffects(SideEffect...) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedEntity.Effect
-
Attach the given effects to this reply.
- addSideEffects(SideEffect...) - Method in interface com.akkaserverless.javasdk.valueentity.ValueEntity.Effect
-
Attach the given effects to this reply.
- addSideEffects(Collection<SideEffect>) - Method in interface com.akkaserverless.javasdk.action.Action.Effect
-
Attach the given side effects to this reply.
- addSideEffects(Collection<SideEffect>) - Method in interface com.akkaserverless.javasdk.eventsourcedentity.EventSourcedEntity.Effect
-
Attach the given side effects to this reply.
- addSideEffects(Collection<SideEffect>) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedEntity.Effect
-
Attach the given side effects to this reply.
- addSideEffects(Collection<SideEffect>) - Method in interface com.akkaserverless.javasdk.valueentity.ValueEntity.Effect
-
Attach the given side effects to this reply.
- AKKA_SERVERLESS_JSON - Static variable in class com.akkaserverless.javasdk.JsonSupport
- AkkaServerless - Class in com.akkaserverless.javasdk
-
The AkkaServerless class is the main interface to configuring entities to deploy, and subsequently starting a local server which will expose these entities to the AkkaServerless Proxy Sidecar.
- AkkaServerless() - Constructor for class com.akkaserverless.javasdk.AkkaServerless
- ALL - com.akkaserverless.javasdk.replicatedentity.WriteConsistency
-
Updates will be written immediately to all replicas.
- allClaimNames() - Method in interface com.akkaserverless.javasdk.JwtClaims
-
Returns the names of all the claims in this request.
- asCloudEvent() - Method in interface com.akkaserverless.javasdk.Metadata
-
Return a CloudEvent representation of this Metadata.
- asCloudEvent(String, URI, String) - Method in interface com.akkaserverless.javasdk.Metadata
-
Convert this metadata to a CloudEvent, adding the given required CloudEvent fields.
- asMap() - Method in interface com.akkaserverless.javasdk.JwtClaims
-
Returns all the claims as a map of strings to strings.
- asMetadata() - Method in interface com.akkaserverless.javasdk.CloudEvent
-
Return this CloudEvent represented as Metadata.
- asyncEffect(CompletionStage<Action.Effect<S>>) - Method in interface com.akkaserverless.javasdk.action.Action.Effect.Builder
-
Create a reply from an async operation result returning an effect.
- asyncReply(CompletionStage<S>) - Method in interface com.akkaserverless.javasdk.action.Action.Effect.Builder
-
Create a message reply from an async operation result.
- audience() - Method in interface com.akkaserverless.javasdk.JwtClaims
-
Get the audience, that is, the aud claim, as described in RFC 7519 section 4.1.3.
C
- call() - Method in interface com.akkaserverless.javasdk.SideEffect
-
The service call that is executed as this effect.
- clear() - Method in interface com.akkaserverless.javasdk.Metadata
-
Clear all metadata entries.
- clear() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedCounterMap
-
Remove all mappings from this counter map.
- clear() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedMap
-
Remove all entries from this map.
- clear() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedMultiMap
-
Remove all key-value pairs from the multi-map, leaving it empty.
- clear() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedRegisterMap
-
Remove all mappings from this register map.
- clear() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedSet
-
Remove all elements from this set.
- clearDatacontenttype() - Method in interface com.akkaserverless.javasdk.CloudEvent
-
Clear the data content type of this CloudEvent, if set.
- clearDataschema() - Method in interface com.akkaserverless.javasdk.CloudEvent
-
Clear the data schema of this CloudEvent, if set.
- clearSubject() - Method in interface com.akkaserverless.javasdk.CloudEvent
-
Clear the subject of this CloudEvent, if set.
- clearTime() - Method in interface com.akkaserverless.javasdk.CloudEvent
-
Clear the time of this CloudEvent, if set.
- CloudEvent - Interface in com.akkaserverless.javasdk
-
CloudEvent representation of Metadata.
- com.akkaserverless.javasdk - package com.akkaserverless.javasdk
-
Root package for the Akka Serverless Java SDK library.
- com.akkaserverless.javasdk.action - package com.akkaserverless.javasdk.action
- com.akkaserverless.javasdk.eventsourcedentity - package com.akkaserverless.javasdk.eventsourcedentity
-
Event Sourced Entity support.
- com.akkaserverless.javasdk.impl - package com.akkaserverless.javasdk.impl
-
Internal implementation classes for AkkaServerless Java Support.
- com.akkaserverless.javasdk.logging - package com.akkaserverless.javasdk.logging
- com.akkaserverless.javasdk.replicatedentity - package com.akkaserverless.javasdk.replicatedentity
-
Replicated Entity support.
- com.akkaserverless.javasdk.valueentity - package com.akkaserverless.javasdk.valueentity
-
Value Entity support.
- com.akkaserverless.javasdk.view - package com.akkaserverless.javasdk.view
- commandContext() - Method in class com.akkaserverless.javasdk.eventsourcedentity.EventSourcedEntity
-
Additional context and metadata for a command handler.
- commandContext() - Method in class com.akkaserverless.javasdk.replicatedentity.ReplicatedEntity
-
Additional context and metadata for a command handler.
- commandContext() - Method in class com.akkaserverless.javasdk.valueentity.ValueEntity
-
Additional context and metadata for a command handler.
- CommandContext - Interface in com.akkaserverless.javasdk.eventsourcedentity
-
An event sourced command context.
- CommandContext - Interface in com.akkaserverless.javasdk.replicatedentity
-
Command context for Replicated Entity.
- CommandContext - Interface in com.akkaserverless.javasdk.valueentity
-
A value based entity command context.
- commandId() - Method in interface com.akkaserverless.javasdk.eventsourcedentity.CommandContext
-
The id of the command being executed.
- commandId() - Method in interface com.akkaserverless.javasdk.replicatedentity.CommandContext
-
The id of the command.
- commandId() - Method in interface com.akkaserverless.javasdk.valueentity.CommandContext
-
The id of the command being executed.
- commandName() - Method in interface com.akkaserverless.javasdk.eventsourcedentity.CommandContext
-
The name of the command being executed.
- commandName() - Method in interface com.akkaserverless.javasdk.replicatedentity.CommandContext
-
The name of the command.
- commandName() - Method in interface com.akkaserverless.javasdk.valueentity.CommandContext
-
The name of the command being executed.
- contains(E) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedSet
-
Check whether this set contains the given element.
- containsAll(Collection<E>) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedSet
-
Check whether this set contains all the given elements.
- containsKey(K) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedCounterMap
-
Check whether this counter map contains a mapping for the given key.
- containsKey(K) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedMap
-
Check whether this map contains a mapping for the given key.
- containsKey(K) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedMultiMap
-
Check whether this multi-map contains at least one value for the given key.
- containsKey(K) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedRegisterMap
-
Check whether this register map contains a mapping for the given key.
- containsValue(K, V) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedMultiMap
-
Check whether this multi-map contains the given value associated with the given key.
- Context - Interface in com.akkaserverless.javasdk
-
Root class of all contexts.
- create(ActionCreationContext) - Method in interface com.akkaserverless.javasdk.impl.ActionFactory
- create(EventSourcedEntityContext) - Method in interface com.akkaserverless.javasdk.impl.EventSourcedEntityFactory
-
Create an entity handler for the given context.
- create(ReplicatedEntityContext) - Method in interface com.akkaserverless.javasdk.impl.ReplicatedEntityFactory
-
Create an entity handler for the given context.
- create(ValueEntityContext) - Method in interface com.akkaserverless.javasdk.impl.ValueEntityFactory
-
Create an entity handler for the given context.
- create(ViewCreationContext) - Method in interface com.akkaserverless.javasdk.impl.ViewFactory
-
Create a view handler for the given context.
- createRunner() - Method in class com.akkaserverless.javasdk.AkkaServerless
-
Creates an AkkaServerlessRunner using the currently configured services.
- createRunner(Config) - Method in class com.akkaserverless.javasdk.AkkaServerless
-
Creates an AkkaServerlessRunner using the currently configured services, using the supplied configuration.
- CUSTOM - com.akkaserverless.javasdk.replicatedentity.ReplicatedRegister.Clock
-
A custom clock.
- CUSTOM_AUTO_INCREMENT - com.akkaserverless.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 com.akkaserverless.javasdk.CloudEvent
-
The data content type of this CloudEvent.
- dataschema() - Method in interface com.akkaserverless.javasdk.CloudEvent
-
The data schema of this CloudEvent.
- decodeJson(Class<T>, Any) - Static method in class com.akkaserverless.javasdk.JsonSupport
-
Decode the given protobuf Any object to an instance of T using Jackson.
- decodeJson(Class<T>, String, Any) - Static method in class com.akkaserverless.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.
- decrement(long) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedCounter
-
Decrement the counter.
- decrement(K, long) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedCounterMap
-
Decrement the counter at the given key by the given amount.
- DEFAULT - com.akkaserverless.javasdk.replicatedentity.ReplicatedRegister.Clock
-
The default clock, uses the current system time as the clock value.
- defaults() - Static method in interface com.akkaserverless.javasdk.action.ActionOptions
-
Create default options for an action.
- defaults() - Static method in interface com.akkaserverless.javasdk.eventsourcedentity.EventSourcedEntityOptions
-
Create a default entity option for an event sourced entity.
- defaults() - Static method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedEntityOptions
-
Create default Replicated Entity options.
- defaults() - Static method in interface com.akkaserverless.javasdk.valueentity.ValueEntityOptions
-
Create a default entity option for a value based entity.
- defaults() - Static method in interface com.akkaserverless.javasdk.view.ViewOptions
-
Create default options for a view.
- defaultTimeout() - Static method in interface com.akkaserverless.javasdk.PassivationStrategy
-
Create a passivation strategy that passivates the entity after the default duration (30 seconds) of inactivity.
- DeferredCall<I,O> - Interface in com.akkaserverless.javasdk
-
Represents a call to another component, performed as a forward, a side effect, or a request-reply.
- delete() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedEntity.Effect.Builder
-
Delete the replicated entity.
- deleteState() - Method in interface com.akkaserverless.javasdk.valueentity.ValueEntity.Effect.Builder
E
- effects() - Method in class com.akkaserverless.javasdk.action.Action
- effects() - Method in class com.akkaserverless.javasdk.eventsourcedentity.EventSourcedEntity
- effects() - Method in class com.akkaserverless.javasdk.replicatedentity.ReplicatedEntity
- effects() - Method in class com.akkaserverless.javasdk.valueentity.ValueEntity
- effects() - Method in class com.akkaserverless.javasdk.view.View
- elements() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedSet
-
Elements of this set as a regular
Set
. - emitEvent(Object) - Method in interface com.akkaserverless.javasdk.eventsourcedentity.EventSourcedEntity.Effect.Builder
- emitEvents(List<?>) - Method in interface com.akkaserverless.javasdk.eventsourcedentity.EventSourcedEntity.Effect.Builder
- EMPTY - Static variable in interface com.akkaserverless.javasdk.Metadata
-
An empty Metadata object.
- emptyData(ReplicatedDataFactory) - Method in class com.akkaserverless.javasdk.replicatedentity.ReplicatedCounterEntity
- emptyData(ReplicatedDataFactory) - Method in class com.akkaserverless.javasdk.replicatedentity.ReplicatedCounterMapEntity
- emptyData(ReplicatedDataFactory) - Method in class com.akkaserverless.javasdk.replicatedentity.ReplicatedEntity
-
Implement by returning the initial empty replicated data object.
- emptyData(ReplicatedDataFactory) - Method in class com.akkaserverless.javasdk.replicatedentity.ReplicatedMapEntity
- emptyData(ReplicatedDataFactory) - Method in class com.akkaserverless.javasdk.replicatedentity.ReplicatedMultiMapEntity
- emptyData(ReplicatedDataFactory) - Method in class com.akkaserverless.javasdk.replicatedentity.ReplicatedRegisterEntity
- emptyData(ReplicatedDataFactory) - Method in class com.akkaserverless.javasdk.replicatedentity.ReplicatedRegisterMapEntity
- emptyData(ReplicatedDataFactory) - Method in class com.akkaserverless.javasdk.replicatedentity.ReplicatedSetEntity
- emptyData(ReplicatedDataFactory) - Method in class com.akkaserverless.javasdk.replicatedentity.ReplicatedVoteEntity
- emptyState() - Method in class com.akkaserverless.javasdk.eventsourcedentity.EventSourcedEntity
-
Implement by returning the initial empty state object.
- emptyState() - Method in class com.akkaserverless.javasdk.valueentity.ValueEntity
-
Implement by returning the initial empty state object.
- emptyState() - Method in class com.akkaserverless.javasdk.view.View
- emptyValue() - Method in class com.akkaserverless.javasdk.replicatedentity.ReplicatedRegisterEntity
-
Implement to set the default empty value for the register.
- encodeJson(T) - Static method in class com.akkaserverless.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.akkaserverless.com/[valueClassName]"
. - encodeJson(T, String) - Static method in class com.akkaserverless.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.akkaserverless.com/[jsonType]"
. - EntityContext - Interface in com.akkaserverless.javasdk
-
Root context for all contexts that pertain to entities, that is, things that are addressable via an entity id.
- entityId() - Method in interface com.akkaserverless.javasdk.EntityContext
-
The id of the entity that this context is for.
- EntityOptions - Interface in com.akkaserverless.javasdk
-
Options used for configuring an entity.
- entityType() - Method in interface com.akkaserverless.javasdk.eventsourcedentity.EventSourcedEntityProvider
- entityType() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedEntityProvider
- entityType() - Method in interface com.akkaserverless.javasdk.valueentity.ValueEntityProvider
- error(String) - Method in interface com.akkaserverless.javasdk.action.Action.Effect.Builder
-
Create an error reply.
- error(String) - Method in interface com.akkaserverless.javasdk.eventsourcedentity.EventSourcedEntity.Effect.Builder
-
Create an error reply.
- error(String) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedEntity.Effect.Builder
-
Create an error reply.
- error(String) - Method in interface com.akkaserverless.javasdk.valueentity.ValueEntity.Effect.Builder
-
Create an error reply.
- error(String) - Method in interface com.akkaserverless.javasdk.view.View.UpdateEffect.Builder
-
Trigger an error for the event.
- eventContext() - Method in class com.akkaserverless.javasdk.eventsourcedentity.EventSourcedEntity
-
Additional context and metadata for an event handler.
- EventContext - Interface in com.akkaserverless.javasdk.eventsourcedentity
-
Context for an event.
- eventName() - Method in interface com.akkaserverless.javasdk.view.UpdateContext
-
The name of the event being handled.
- EventSourcedEntity<S> - Class in com.akkaserverless.javasdk.eventsourcedentity
- EventSourcedEntity() - Constructor for class com.akkaserverless.javasdk.eventsourcedentity.EventSourcedEntity
- EventSourcedEntity.Effect<T> - Interface in com.akkaserverless.javasdk.eventsourcedentity
-
A return type to allow returning forwards or failures, and attaching effects to messages.
- EventSourcedEntity.Effect.Builder<S> - Interface in com.akkaserverless.javasdk.eventsourcedentity
-
Construct the effect that is returned by the command handler.
- EventSourcedEntity.Effect.OnSuccessBuilder<S> - Interface in com.akkaserverless.javasdk.eventsourcedentity
- EventSourcedEntityContext - Interface in com.akkaserverless.javasdk.eventsourcedentity
-
Root context for all event sourcing contexts.
- EventSourcedEntityFactory - Interface in com.akkaserverless.javasdk.impl
-
Low level interface for handling events and commands on an entity.
- EventSourcedEntityOptions - Interface in com.akkaserverless.javasdk.eventsourcedentity
-
Root entity options for all event sourcing entities.
- EventSourcedEntityProvider<S,E extends EventSourcedEntity<S>> - Interface in com.akkaserverless.javasdk.eventsourcedentity
-
Register an event sourced entity in
AkkaServerless
using aEventSourcedEntityProvider
. - eventSubject() - Method in interface com.akkaserverless.javasdk.action.ActionContext
-
The origin subject of the
CloudEvent
. - eventSubject() - Method in interface com.akkaserverless.javasdk.view.UpdateContext
-
The origin subject of the
CloudEvent
. - execute() - Method in interface com.akkaserverless.javasdk.DeferredCall
-
Execute this call right away and get the async result back for composition.
- expirationTime() - Method in interface com.akkaserverless.javasdk.JwtClaims
-
Get the expiration time, that is, the exp claim, as described in RFC 7519 section 4.1.4.
F
- forward(DeferredCall<? extends Object, S>) - Method in interface com.akkaserverless.javasdk.action.Action.Effect.Builder
-
Create a forward reply.
- forward(DeferredCall<? extends Object, T>) - Method in interface com.akkaserverless.javasdk.eventsourcedentity.EventSourcedEntity.Effect.Builder
-
Create a forward reply.
- forward(DeferredCall<? extends Object, T>) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedEntity.Effect.Builder
-
Create a forward reply.
- forward(DeferredCall<? extends Object, T>) - Method in interface com.akkaserverless.javasdk.valueentity.ValueEntity.Effect.Builder
-
Create a forward reply.
- forwardHeaders() - Method in interface com.akkaserverless.javasdk.action.ActionOptions
- forwardHeaders() - Method in interface com.akkaserverless.javasdk.EntityOptions
- forwardHeaders() - Method in interface com.akkaserverless.javasdk.view.ViewOptions
G
- get() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedRegister
-
Get the current value of the register.
- get(String) - Method in interface com.akkaserverless.javasdk.Metadata
-
Get the string value for the given key, if found.
- get(K) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedCounterMap
-
Get the counter value for the given key.
- get(K) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedMap
-
Get the
ReplicatedData
value for the given key. - get(K) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedMultiMap
-
Get the values for the given key.
- getAll(String) - Method in interface com.akkaserverless.javasdk.Metadata
-
Get all the string values for a given key.
- getAllKeys() - Method in interface com.akkaserverless.javasdk.Metadata
-
Get all the keys for all the entries.
- getBinary(String) - Method in interface com.akkaserverless.javasdk.Metadata
-
Get the binary value for the given key, if found.
- getBinaryAll(String) - Method in interface com.akkaserverless.javasdk.Metadata
-
Get all the binary values for a given key.
- getBinaryValue() - Method in interface com.akkaserverless.javasdk.Metadata.MetadataEntry
-
The binary value for the metadata entry.
- getBoolean(String) - Method in interface com.akkaserverless.javasdk.JwtClaims
-
Get the boolean claim with the given name.
- getBooleanList(String) - Method in interface com.akkaserverless.javasdk.JwtClaims
-
Get the boolean list claim with the given name.
- getDouble(String) - Method in interface com.akkaserverless.javasdk.JwtClaims
-
Get the double claim with the given name.
- getDoubleList(String) - Method in interface com.akkaserverless.javasdk.JwtClaims
-
Get the double list claim with the given name.
- getGrpcClient(Class<T>, String) - Method in interface com.akkaserverless.javasdk.action.ActionContext
-
Get an Akka gRPC client for the given service name.
- getGrpcClient(Class<T>, String) - Method in interface com.akkaserverless.javasdk.action.ActionCreationContext
-
Get an Akka gRPC client for the given service name.
- getInteger(String) - Method in interface com.akkaserverless.javasdk.JwtClaims
-
Get the integer claim with the given name.
- getIntegerList(String) - Method in interface com.akkaserverless.javasdk.JwtClaims
-
Get the integer list claim with the given name.
- getKey() - Method in interface com.akkaserverless.javasdk.Metadata.MetadataEntry
-
The key for the metadata entry.
- getLong(String) - Method in interface com.akkaserverless.javasdk.JwtClaims
-
Get the long claim with the given name.
- getLongList(String) - Method in interface com.akkaserverless.javasdk.JwtClaims
-
Get the long list claim with the given name.
- getNumericDate(String) - Method in interface com.akkaserverless.javasdk.JwtClaims
-
Get the numeric data claim with the given name.
- getNumericDateList(String) - Method in interface com.akkaserverless.javasdk.JwtClaims
-
Get the numeric date list claim with the given name.
- getObject(String) - Method in interface com.akkaserverless.javasdk.JwtClaims
-
Get the object claim with the given name.
- getObjectList(String) - Method in interface com.akkaserverless.javasdk.JwtClaims
-
Get the object list claim with the given name.
- getObjectMapper() - Static method in class com.akkaserverless.javasdk.JsonSupport
-
The Jackson ObjectMapper that is used for encoding and decoding JSON.
- getOrElse(K, Function<ReplicatedDataFactory, V>) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedMap
-
Get the
ReplicatedData
value for the given key. - getReplicatedCounter(K) - Method in interface com.akkaserverless.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 com.akkaserverless.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 com.akkaserverless.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 com.akkaserverless.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 com.akkaserverless.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 com.akkaserverless.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 com.akkaserverless.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 com.akkaserverless.javasdk.replicatedentity.ReplicatedMap
-
Get a
ReplicatedSet
from a heterogeneous Replicated Map (a map with different types of Replicated Data values). - getSelfVote() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedVote
-
Get the current value for this node's vote.
- getString(String) - Method in interface com.akkaserverless.javasdk.JwtClaims
-
Get the string claim with the given name.
- getStringList(String) - Method in interface com.akkaserverless.javasdk.JwtClaims
-
Get the string list claim with the given name.
- getValue() - Method in interface com.akkaserverless.javasdk.Metadata.MetadataEntry
-
The string value for the metadata entry.
- getValue() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedCounter
-
Get the current value of the counter.
- getValue(K) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedRegisterMap
-
Get the current value of the register at the given key.
- getVoters() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedVote
-
Get the number of voters participating in the vote (ie, the number of nodes in the cluster).
- getVotesFor() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedVote
-
Get the number of votes for.
H
- has(String) - Method in interface com.akkaserverless.javasdk.Metadata
-
Check whether this metadata has a entry for the given key.
- hasClaims() - Method in interface com.akkaserverless.javasdk.JwtClaims
-
Does this request have any claims that have been validated?
I
- id() - Method in interface com.akkaserverless.javasdk.CloudEvent
-
The id of this CloudEvent.
- ignore() - Method in interface com.akkaserverless.javasdk.view.View.UpdateEffect.Builder
-
Ignore this event (and continue to process the next).
- increment(long) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedCounter
-
Increment the counter.
- increment(K, long) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedCounterMap
-
Increment the counter at the given key by the given amount.
- isAtLeastOne() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedVote
-
Has at least one node voted true?
- isBinary() - Method in interface com.akkaserverless.javasdk.Metadata.MetadataEntry
-
Whether this entry is a binary entry.
- isCloudEvent() - Method in interface com.akkaserverless.javasdk.Metadata
-
Whether this metadata is also a CloudEvent.
- isEmpty() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedCounterMap
-
Check whether this counter map is empty.
- isEmpty() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedMap
-
Check whether this map is empty.
- isEmpty() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedMultiMap
-
Check whether this multi-map is empty.
- isEmpty() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedRegisterMap
-
Check whether this register map is empty.
- isEmpty() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedSet
-
Check whether this set is empty.
- isMajority() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedVote
-
Have a majority of nodes voted true?
- issuedAt() - Method in interface com.akkaserverless.javasdk.JwtClaims
-
Get the issued at, that is, the iat claim, as described in RFC 7519 section 4.1.6.
- issuer() - Method in interface com.akkaserverless.javasdk.JwtClaims
-
Get the issuer, that is, the iss claim, as described in RFC 7519 section 4.1.1.
- isText() - Method in interface com.akkaserverless.javasdk.Metadata.MetadataEntry
-
Whether this entry is a text entry.
- isUnanimous() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedVote
-
Is the vote unanimous?
J
- JsonSupport - Class in com.akkaserverless.javasdk
- jwtClaims() - Method in interface com.akkaserverless.javasdk.Metadata
-
Get the JWT claims present in this metadata.
- JwtClaims - Interface in com.akkaserverless.javasdk
-
Representation of JWT claims that have been validated and extracted from the bearer token of a request.
- jwtId() - Method in interface com.akkaserverless.javasdk.JwtClaims
-
Get the JWT ID, that is, the jti claim, as described in RFC 7519 section 4.1.7.
K
- keySet() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedCounterMap
-
Get a
Set
view of the keys contained in this counter map. - keySet() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedMap
-
Get a
Set
view of the keys contained in this map. - keySet() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedMultiMap
-
Return the keys contained in this multi-map.
- keySet() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedRegisterMap
-
Get a
Set
view of the keys contained in this register map.
L
- LOCAL - com.akkaserverless.javasdk.replicatedentity.WriteConsistency
-
Updates will only be written to the local replica immediately, and then asynchronously distributed to other replicas in the background.
- LogbackJsonLayout - Class in com.akkaserverless.javasdk.logging
-
This Logback JSON layout uses the name `severity` (instead of `level`).
- LogbackJsonLayout() - Constructor for class com.akkaserverless.javasdk.logging.LogbackJsonLayout
M
- MAJORITY - com.akkaserverless.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 com.akkaserverless.javasdk.Context
-
An Akka Stream materializer to use for running streams.
- message() - Method in interface com.akkaserverless.javasdk.DeferredCall
-
The message to pass to the call when the call is invoked.
- MessageEnvelope<T> - Interface in com.akkaserverless.javasdk.action
-
A message envelope.
- metadata() - Method in interface com.akkaserverless.javasdk.action.ActionContext
-
Get the metadata associated with this call.
- metadata() - Method in interface com.akkaserverless.javasdk.action.MessageEnvelope
-
The metadata associated with the message.
- metadata() - Method in interface com.akkaserverless.javasdk.DeferredCall
- metadata() - Method in interface com.akkaserverless.javasdk.MetadataContext
-
Get the metadata associated with this context.
- Metadata - Interface in com.akkaserverless.javasdk
-
Transport specific metadata.
- Metadata.MetadataEntry - Interface in com.akkaserverless.javasdk
-
A metadata entry.
- MetadataContext - Interface in com.akkaserverless.javasdk
-
Context that provides access to metadata.
N
- newCounter() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedDataFactory
-
Create a new counter.
- newRegister(T) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedDataFactory
-
Create a new ReplicatedRegister.
- newReplicatedCounterMap() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedDataFactory
-
Create a new map of counters.
- newReplicatedMap() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedDataFactory
-
Create a new ReplicatedMap.
- newReplicatedMultiMap() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedDataFactory
-
Create a new multimap (map of sets).
- newReplicatedRegisterMap() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedDataFactory
-
Create a new map of registers.
- newReplicatedSet() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedDataFactory
-
Create a new ReplicatedSet.
- newRouter(ActionCreationContext) - Method in interface com.akkaserverless.javasdk.action.ActionProvider
- newRouter(EventSourcedEntityContext) - Method in interface com.akkaserverless.javasdk.eventsourcedentity.EventSourcedEntityProvider
- newRouter(ReplicatedEntityContext) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedEntityProvider
- newRouter(ValueEntityContext) - Method in interface com.akkaserverless.javasdk.valueentity.ValueEntityProvider
- newRouter(ViewCreationContext) - Method in interface com.akkaserverless.javasdk.view.ViewProvider
- newVote() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedDataFactory
-
Create a new Vote.
- noReply() - Method in interface com.akkaserverless.javasdk.action.Action.Effect.Builder
-
Create a reply that contains neither a message nor a forward nor an error.
- noReply() - Method in interface com.akkaserverless.javasdk.eventsourcedentity.EventSourcedEntity.Effect.Builder
-
Create a reply that contains neither a message nor a forward nor an error.
- noReply() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedEntity.Effect.Builder
-
Create a reply that contains neither a message nor a forward nor an error.
- noReply() - Method in interface com.akkaserverless.javasdk.valueentity.ValueEntity.Effect.Builder
-
Create a reply that contains neither a message nor a forward nor an error.
- notBefore() - Method in interface com.akkaserverless.javasdk.JwtClaims
-
Get the not before, that is, the nbf claim, as described in RFC 7519 section 4.1.5.
O
- of(DeferredCall) - Static method in interface com.akkaserverless.javasdk.SideEffect
-
Create a side effect of the given service call.
- of(DeferredCall, boolean) - Static method in interface com.akkaserverless.javasdk.SideEffect
-
Create a side effect of the given service call.
- of(String, URI, String) - Static method in interface com.akkaserverless.javasdk.CloudEvent
-
Create a CloudEvent.
- of(T) - Static method in interface com.akkaserverless.javasdk.action.MessageEnvelope
-
Create a message.
- of(T, Metadata) - Static method in interface com.akkaserverless.javasdk.action.MessageEnvelope
-
Create a message.
- options() - Method in interface com.akkaserverless.javasdk.action.ActionProvider
- options() - Method in interface com.akkaserverless.javasdk.eventsourcedentity.EventSourcedEntityProvider
- options() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedEntityProvider
- options() - Method in interface com.akkaserverless.javasdk.valueentity.ValueEntityProvider
- options() - Method in interface com.akkaserverless.javasdk.view.ViewProvider
P
- passivationStrategy() - Method in interface com.akkaserverless.javasdk.EntityOptions
- PassivationStrategy - Interface in com.akkaserverless.javasdk
-
A passivation strategy.
- payload() - Method in interface com.akkaserverless.javasdk.action.MessageEnvelope
-
The payload of the message.
- preferJavaProtobufs() - Method in class com.akkaserverless.javasdk.AkkaServerless
-
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 com.akkaserverless.javasdk.AkkaServerless
-
When locating protobufs, if both a Java and a ScalaPB generated class is found on the classpath, this specifies that Scala should be preferred.
- put(K, V) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedMultiMap
-
Store a key-value pair, if not already present.
- putAll(K, Collection<V>) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedMultiMap
-
Store multiple values for a key.
R
- register(ActionProvider) - Method in class com.akkaserverless.javasdk.AkkaServerless
-
Register an action using an {
ActionProvider
}. - register(EventSourcedEntityProvider<S, E>) - Method in class com.akkaserverless.javasdk.AkkaServerless
-
Register a event sourced entity using a {
EventSourcedEntityProvider
}. - register(ReplicatedEntityProvider<D, E>) - Method in class com.akkaserverless.javasdk.AkkaServerless
-
Register a replicated entity using a
ReplicatedEntityProvider
. - register(ValueEntityProvider<S, E>) - Method in class com.akkaserverless.javasdk.AkkaServerless
-
Register a value based entity using a {
ValueEntityProvider
}. - register(ViewProvider) - Method in class com.akkaserverless.javasdk.AkkaServerless
-
Register a view using a
ViewProvider
. - remove(E) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedSet
-
Remove an element from this set if it is present.
- remove(String) - Method in interface com.akkaserverless.javasdk.Metadata
-
Remove all metadata entries with the given key.
- remove(K) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedCounterMap
-
Remove the mapping for a key if it is present.
- remove(K) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedMap
-
Remove the mapping for a key if it is present.
- remove(K) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedRegisterMap
-
Remove the mapping for a key if it is present.
- remove(K, V) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedMultiMap
-
Remove a single key-value pair for the given key and value, if present.
- removeAll(Collection<E>) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedSet
-
Remove elements from this set if they're present.
- removeAll(K) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedMultiMap
-
Remove all values associated with the given key.
- ReplicatedCounter - Interface in com.akkaserverless.javasdk.replicatedentity
-
A counter that can be incremented and decremented.
- ReplicatedCounterEntity - Class in com.akkaserverless.javasdk.replicatedentity
- ReplicatedCounterEntity() - Constructor for class com.akkaserverless.javasdk.replicatedentity.ReplicatedCounterEntity
- ReplicatedCounterMap<K> - Interface in com.akkaserverless.javasdk.replicatedentity
-
A Map of counters.
- ReplicatedCounterMapEntity<K> - Class in com.akkaserverless.javasdk.replicatedentity
- ReplicatedCounterMapEntity() - Constructor for class com.akkaserverless.javasdk.replicatedentity.ReplicatedCounterMapEntity
- ReplicatedDataFactory - Interface in com.akkaserverless.javasdk.replicatedentity
-
Factory for creating Replicated Data objects.
- ReplicatedEntity<D extends com.akkaserverless.replicatedentity.ReplicatedData> - Class in com.akkaserverless.javasdk.replicatedentity
- ReplicatedEntity() - Constructor for class com.akkaserverless.javasdk.replicatedentity.ReplicatedEntity
- ReplicatedEntity.Effect<R> - Interface in com.akkaserverless.javasdk.replicatedentity
-
A return type to allow returning forwards or failures, and attaching effects to messages.
- ReplicatedEntity.Effect.Builder<D> - Interface in com.akkaserverless.javasdk.replicatedentity
-
Construct the effect that is returned by the command handler.
- ReplicatedEntity.Effect.OnSuccessBuilder - Interface in com.akkaserverless.javasdk.replicatedentity
- ReplicatedEntityContext - Interface in com.akkaserverless.javasdk.replicatedentity
-
Root context for all Replicated Entity contexts.
- ReplicatedEntityFactory - Interface in com.akkaserverless.javasdk.impl
-
Low level interface for handling commands on a replicated entity.
- ReplicatedEntityOptions - Interface in com.akkaserverless.javasdk.replicatedentity
-
Root entity options for all Replicated Entities.
- ReplicatedEntityProvider<D extends com.akkaserverless.replicatedentity.ReplicatedData,E extends ReplicatedEntity<D>> - Interface in com.akkaserverless.javasdk.replicatedentity
-
Register a value based entity in
AkkaServerless
using aReplicatedEntityProvider
. - ReplicatedMap<K,V extends com.akkaserverless.replicatedentity.ReplicatedData> - Interface in com.akkaserverless.javasdk.replicatedentity
-
A Replicated Map that allows both the addition and removal of
ReplicatedData
objects. - ReplicatedMapEntity<K,V extends com.akkaserverless.replicatedentity.ReplicatedData> - Class in com.akkaserverless.javasdk.replicatedentity
- ReplicatedMapEntity() - Constructor for class com.akkaserverless.javasdk.replicatedentity.ReplicatedMapEntity
- ReplicatedMultiMap<K,V> - Interface in com.akkaserverless.javasdk.replicatedentity
-
A replicated map that maps keys to values, where each key may be associated with multiple values.
- ReplicatedMultiMapEntity<K,V> - Class in com.akkaserverless.javasdk.replicatedentity
- ReplicatedMultiMapEntity() - Constructor for class com.akkaserverless.javasdk.replicatedentity.ReplicatedMultiMapEntity
- ReplicatedRegister<T> - Interface in com.akkaserverless.javasdk.replicatedentity
-
A Last-Write-Wins Register.
- ReplicatedRegister.Clock - Enum in com.akkaserverless.javasdk.replicatedentity
-
Clock for register replication
- ReplicatedRegisterEntity<T> - Class in com.akkaserverless.javasdk.replicatedentity
- ReplicatedRegisterEntity() - Constructor for class com.akkaserverless.javasdk.replicatedentity.ReplicatedRegisterEntity
- ReplicatedRegisterMap<K,V> - Interface in com.akkaserverless.javasdk.replicatedentity
-
A Map of registers.
- ReplicatedRegisterMapEntity<K,V> - Class in com.akkaserverless.javasdk.replicatedentity
- ReplicatedRegisterMapEntity() - Constructor for class com.akkaserverless.javasdk.replicatedentity.ReplicatedRegisterMapEntity
- ReplicatedSet<E> - Interface in com.akkaserverless.javasdk.replicatedentity
-
A Replicated Set that allows both the addition and removal of elements in a set.
- ReplicatedSetEntity<T> - Class in com.akkaserverless.javasdk.replicatedentity
- ReplicatedSetEntity() - Constructor for class com.akkaserverless.javasdk.replicatedentity.ReplicatedSetEntity
- ReplicatedVote - Interface in com.akkaserverless.javasdk.replicatedentity
-
A Vote replicated data type.
- ReplicatedVoteEntity - Class in com.akkaserverless.javasdk.replicatedentity
- ReplicatedVoteEntity() - Constructor for class com.akkaserverless.javasdk.replicatedentity.ReplicatedVoteEntity
- reply(S) - Method in interface com.akkaserverless.javasdk.action.Action.Effect.Builder
-
Create a message reply.
- reply(S, Metadata) - Method in interface com.akkaserverless.javasdk.action.Action.Effect.Builder
-
Create a message reply.
- reply(T) - Method in interface com.akkaserverless.javasdk.eventsourcedentity.EventSourcedEntity.Effect.Builder
-
Create a message reply.
- reply(T) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedEntity.Effect.Builder
-
Create a message reply.
- reply(T) - Method in interface com.akkaserverless.javasdk.valueentity.ValueEntity.Effect.Builder
-
Create a message reply.
- reply(T, Metadata) - Method in interface com.akkaserverless.javasdk.eventsourcedentity.EventSourcedEntity.Effect.Builder
-
Create a message reply.
- reply(T, Metadata) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedEntity.Effect.Builder
-
Create a message reply.
- reply(T, Metadata) - Method in interface com.akkaserverless.javasdk.valueentity.ValueEntity.Effect.Builder
-
Create a message reply.
- retainAll(Collection<E>) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedSet
-
Retain only the elements that are contained in the given collection.
- REVERSE - com.akkaserverless.javasdk.replicatedentity.ReplicatedRegister.Clock
-
A reverse clock, based on the system clock.
S
- sequenceNumber() - Method in interface com.akkaserverless.javasdk.eventsourcedentity.CommandContext
-
The current sequence number of events in this entity.
- sequenceNumber() - Method in interface com.akkaserverless.javasdk.eventsourcedentity.EventContext
-
The sequence number of the current event being processed.
- serviceDescriptor() - Method in interface com.akkaserverless.javasdk.action.ActionProvider
- serviceDescriptor() - Method in interface com.akkaserverless.javasdk.eventsourcedentity.EventSourcedEntityProvider
- serviceDescriptor() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedEntityProvider
- serviceDescriptor() - Method in interface com.akkaserverless.javasdk.valueentity.ValueEntityProvider
- serviceDescriptor() - Method in interface com.akkaserverless.javasdk.view.ViewProvider
- set(String, String) - Method in interface com.akkaserverless.javasdk.Metadata
-
Set the string value for the given key.
- set(T) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedRegister
-
Set the value of the register, using the default clock.
- set(T, ReplicatedRegister.Clock, long) - Method in interface com.akkaserverless.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 com.akkaserverless.javasdk.Metadata
-
Set the binary value for the given key.
- setValue(K, V) - Method in interface com.akkaserverless.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 com.akkaserverless.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 com.akkaserverless.javasdk
-
A side effect.
- size() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedCounterMap
-
Get the number of key-counter mappings in this counter map.
- size() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedMap
-
Get the number of key-value mappings in this map.
- size() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedMultiMap
-
Return the number of key-value pairs in this multi-map.
- size() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedRegisterMap
-
Get the number of key-register mappings in this register map.
- size() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedSet
-
Get the number of elements in this set (its cardinality).
- snapshotEvery() - Method in interface com.akkaserverless.javasdk.eventsourcedentity.EventSourcedEntityOptions
- source() - Method in interface com.akkaserverless.javasdk.CloudEvent
-
The source of this CloudEvent.
- specversion() - Method in interface com.akkaserverless.javasdk.CloudEvent
-
The CloudEvent spec version.
- start() - Method in class com.akkaserverless.javasdk.AkkaServerless
-
Starts a server with the configured entities.
- start(Config) - Method in class com.akkaserverless.javasdk.AkkaServerless
-
Starts a server with the configured entities, using the supplied configuration.
- subject() - Method in interface com.akkaserverless.javasdk.CloudEvent
-
The subject of this CloudEvent.
- subject() - Method in interface com.akkaserverless.javasdk.JwtClaims
-
Get the subject, that is, the sub claim, as described in RFC 7519 section 4.1.2.
- synchronous() - Method in interface com.akkaserverless.javasdk.SideEffect
-
Whether this effect should be executed synchronously or not.
T
- thenAddSideEffect(Function<S, SideEffect>) - Method in interface com.akkaserverless.javasdk.eventsourcedentity.EventSourcedEntity.Effect.OnSuccessBuilder
-
Attach the given side effect to this reply from the new state.
- thenForward(DeferredCall<? extends Object, T>) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedEntity.Effect.OnSuccessBuilder
-
Create a forward reply after for example
delete
. - thenForward(DeferredCall<? extends Object, T>) - Method in interface com.akkaserverless.javasdk.valueentity.ValueEntity.Effect.OnSuccessBuilder
-
Create a forward reply after for example
updateState
. - thenForward(Function<S, DeferredCall<? extends Object, T>>) - Method in interface com.akkaserverless.javasdk.eventsourcedentity.EventSourcedEntity.Effect.OnSuccessBuilder
-
Create a forward reply after for example
emitEvent
. - thenNoReply() - Method in interface com.akkaserverless.javasdk.eventsourcedentity.EventSourcedEntity.Effect.OnSuccessBuilder
-
Create a reply that contains neither a message nor a forward nor an error.
- thenNoReply() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedEntity.Effect.OnSuccessBuilder
-
Create a reply that contains neither a message nor a forward nor an error.
- thenNoReply() - Method in interface com.akkaserverless.javasdk.valueentity.ValueEntity.Effect.OnSuccessBuilder
-
Create a reply that contains neither a message nor a forward nor an error.
- thenReply(Function<S, T>) - Method in interface com.akkaserverless.javasdk.eventsourcedentity.EventSourcedEntity.Effect.OnSuccessBuilder
-
Reply after for example
emitEvent
. - thenReply(Function<S, T>, Metadata) - Method in interface com.akkaserverless.javasdk.eventsourcedentity.EventSourcedEntity.Effect.OnSuccessBuilder
-
Reply after for example
emitEvent
. - thenReply(T) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedEntity.Effect.OnSuccessBuilder
-
Reply after for example
delete
. - thenReply(T) - Method in interface com.akkaserverless.javasdk.valueentity.ValueEntity.Effect.OnSuccessBuilder
-
Reply after for example
updateState
. - thenReply(T, Metadata) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedEntity.Effect.OnSuccessBuilder
-
Reply after for example
delete
. - thenReply(T, Metadata) - Method in interface com.akkaserverless.javasdk.valueentity.ValueEntity.Effect.OnSuccessBuilder
-
Reply after for example
updateState
. - time() - Method in interface com.akkaserverless.javasdk.CloudEvent
-
The time of this CloudEvent.
- timeout(Duration) - Static method in interface com.akkaserverless.javasdk.PassivationStrategy
-
Create a passivation strategy that passivates the entity after a given duration of inactivity.
- type() - Method in interface com.akkaserverless.javasdk.CloudEvent
-
The type of this CloudEvent.
U
- update(D) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedEntity.Effect.Builder
-
Update the underlying replicated data for the replicated entity.
- update(K, V) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedMap
-
Update the
ReplicatedData
value associated with the given key. - updateContext() - Method in class com.akkaserverless.javasdk.view.View
-
Additional context and metadata for an update handler.
- UpdateContext - Interface in com.akkaserverless.javasdk.view
-
Context for view update calls.
- updateState(S) - Method in interface com.akkaserverless.javasdk.valueentity.ValueEntity.Effect.Builder
- updateState(S) - Method in interface com.akkaserverless.javasdk.view.View.UpdateEffect.Builder
V
- ValueEntity<S> - Class in com.akkaserverless.javasdk.valueentity
- ValueEntity() - Constructor for class com.akkaserverless.javasdk.valueentity.ValueEntity
- ValueEntity.Effect<T> - Interface in com.akkaserverless.javasdk.valueentity
-
A return type to allow returning forwards or failures, and attaching effects to messages.
- ValueEntity.Effect.Builder<S> - Interface in com.akkaserverless.javasdk.valueentity
-
Construct the effect that is returned by the command handler.
- ValueEntity.Effect.OnSuccessBuilder<S> - Interface in com.akkaserverless.javasdk.valueentity
- ValueEntityContext - Interface in com.akkaserverless.javasdk.valueentity
-
Root context for all value based entity contexts.
- ValueEntityFactory - Interface in com.akkaserverless.javasdk.impl
-
Low level interface for handling commands on a value based entity.
- ValueEntityOptions - Interface in com.akkaserverless.javasdk.valueentity
-
Root entity options for all value based entities.
- ValueEntityProvider<S,E extends ValueEntity<S>> - Interface in com.akkaserverless.javasdk.valueentity
-
Register a value based entity in
AkkaServerless
using aValueEntityProvider
. - valueOf(String) - Static method in enum com.akkaserverless.javasdk.replicatedentity.ReplicatedRegister.Clock
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.akkaserverless.javasdk.replicatedentity.WriteConsistency
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum com.akkaserverless.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 com.akkaserverless.javasdk.replicatedentity.WriteConsistency
-
Returns an array containing the constants of this enum type, in the order they are declared.
- View<S> - Class in com.akkaserverless.javasdk.view
- View() - Constructor for class com.akkaserverless.javasdk.view.View
- View.UpdateEffect<S> - Interface in com.akkaserverless.javasdk.view
-
Construct the effect that is returned by the command handler.
- View.UpdateEffect.Builder<S> - Interface in com.akkaserverless.javasdk.view
- ViewContext - Interface in com.akkaserverless.javasdk.view
-
Context for views.
- ViewCreationContext - Interface in com.akkaserverless.javasdk.view
-
Creation context for
View
entities. - ViewFactory - Interface in com.akkaserverless.javasdk.impl
-
Low level interface for handling messages in views.
- viewId() - Method in interface com.akkaserverless.javasdk.view.ViewContext
-
The id of the view that this context is for.
- viewId() - Method in interface com.akkaserverless.javasdk.view.ViewProvider
- ViewOptions - Interface in com.akkaserverless.javasdk.view
- ViewProvider<S,V extends View<S>> - Interface in com.akkaserverless.javasdk.view
- vote(boolean) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedVote
-
Update this node's vote to the given value.
W
- withClassLoader(ClassLoader) - Method in class com.akkaserverless.javasdk.AkkaServerless
-
Sets the ClassLoader to be used for reflective access, the default value is the ClassLoader of the AkkaServerless class.
- withDatacontenttype(String) - Method in interface com.akkaserverless.javasdk.CloudEvent
-
Return a new CloudEvent with the given data content type.
- withDataschema(URI) - Method in interface com.akkaserverless.javasdk.CloudEvent
-
Return a new CloudEvent with the given data schema.
- withForwardHeaders(Set<String>) - Method in interface com.akkaserverless.javasdk.action.ActionOptions
-
Ask Akka Serverless to forward these headers from the incoming request as metadata headers for the incoming commands.
- withForwardHeaders(Set<String>) - Method in interface com.akkaserverless.javasdk.EntityOptions
-
Ask Akka Serverless to forward these headers from the incoming request as metadata headers for the incoming commands.
- withForwardHeaders(Set<String>) - Method in interface com.akkaserverless.javasdk.view.ViewOptions
-
Ask Akka Serverless to forward these headers from the incoming request as metadata headers for the incoming commands.
- withId(String) - Method in interface com.akkaserverless.javasdk.CloudEvent
-
Return a new CloudEvent with the given id.
- withPassivationStrategy(PassivationStrategy) - Method in interface com.akkaserverless.javasdk.EntityOptions
-
Create an entity option with the given passivation strategy.
- withPassivationStrategy(PassivationStrategy) - Method in interface com.akkaserverless.javasdk.eventsourcedentity.EventSourcedEntityOptions
- withPassivationStrategy(PassivationStrategy) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedEntityOptions
- withPassivationStrategy(PassivationStrategy) - Method in interface com.akkaserverless.javasdk.valueentity.ValueEntityOptions
- withSnapshotEvery(int) - Method in interface com.akkaserverless.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 com.akkaserverless.javasdk.CloudEvent
-
Return a new CloudEvent with the given source.
- withSubject(String) - Method in interface com.akkaserverless.javasdk.CloudEvent
-
Return a new CloudEvent with the given subject.
- withTime(ZonedDateTime) - Method in interface com.akkaserverless.javasdk.CloudEvent
-
Return a new CloudEvent with the given time.
- withType(String) - Method in interface com.akkaserverless.javasdk.CloudEvent
-
Return a new CloudEvent with the given type.
- withTypeUrlPrefix(String) - Method in class com.akkaserverless.javasdk.AkkaServerless
-
Sets the type URL prefix to be used when serializing and deserializing types from and to Protobyf Any values.
- withWriteConsistency(WriteConsistency) - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedEntityOptions
-
Set the write consistency setting for replication of the replicated entity state.
- writeConsistency() - Method in interface com.akkaserverless.javasdk.replicatedentity.ReplicatedEntityOptions
-
Get the current write consistency setting for replication of the replicated entity state.
- WriteConsistency - Enum in com.akkaserverless.javasdk.replicatedentity
-
Write consistency setting for replication of state updates for Replicated Entities.
_
- _internalSetActionContext(Optional<ActionContext>) - Method in class com.akkaserverless.javasdk.action.Action
-
INTERNAL API
- _internalSetCommandContext(Optional<CommandContext>) - Method in class com.akkaserverless.javasdk.eventsourcedentity.EventSourcedEntity
-
INTERNAL API
- _internalSetCommandContext(Optional<CommandContext>) - Method in class com.akkaserverless.javasdk.replicatedentity.ReplicatedEntity
-
INTERNAL API
- _internalSetCommandContext(Optional<CommandContext>) - Method in class com.akkaserverless.javasdk.valueentity.ValueEntity
-
INTERNAL API
- _internalSetEventContext(Optional<EventContext>) - Method in class com.akkaserverless.javasdk.eventsourcedentity.EventSourcedEntity
-
INTERNAL API
- _internalSetUpdateContext(Optional<UpdateContext>) - Method in class com.akkaserverless.javasdk.view.View
-
INTERNAL API
All Classes All Packages