Index

A B C D E G H I K M O P S T V W 
All Classes and Interfaces|All Packages|Constant Field Values

A

aclEnabled - Variable in class kalix.javasdk.testkit.KalixTestKit.Settings
Whether ACL checking is enabled.
ActionResult<T> - Interface in kalix.javasdk.testkit
Represents the result of an Action handling a command when run in through the testkit.
advancedViews - Variable in class kalix.javasdk.testkit.KalixTestKit.Settings
Whether advanced View features are enabled.
after() - Method in class kalix.javasdk.testkit.junit.KalixTestKitResource
JUnit4 support - rule based
afterAll(ExtensionContext) - Method in class kalix.javasdk.testkit.junit.jupiter.KalixTestKitExtension
JUnit5 support - extension based
availableLocalPort() - Static method in class kalix.javasdk.testkit.KalixTestKit
Get an available local port for testing.

B

before() - Method in class kalix.javasdk.testkit.junit.KalixTestKitResource
JUnit4 support - rule based
beforeAll(ExtensionContext) - Method in class kalix.javasdk.testkit.junit.jupiter.KalixTestKitExtension
JUnit5 support - extension based

C

clear() - Method in interface kalix.javasdk.testkit.EventingTestKit.OutgoingMessages
Clear the destination so any existing messages are not considered on subsequent expect call.
create() - Static method in interface kalix.javasdk.testkit.MockRegistry
Returns an empty instance of MockRegistry that can be chained with `withMock`

D

DEFAULT - Static variable in class kalix.javasdk.testkit.KalixTestKit.Settings
Default settings for KalixTestkit.
DEFAULT_GOOGLE_PUBSUB_PORT - Static variable in class kalix.javasdk.testkit.impl.KalixRuntimeContainer
Default local port where the Google Pub/Sub emulator is available (8085).
DEFAULT_KAFKA_PORT - Static variable in class kalix.javasdk.testkit.impl.KalixRuntimeContainer
 
DEFAULT_RUNTIME_IMAGE_NAME - Static variable in class kalix.javasdk.testkit.impl.KalixRuntimeContainer
Default Testcontainers DockerImageName for the Kalix Runtime.
DEFAULT_RUNTIME_PORT - Static variable in class kalix.javasdk.testkit.impl.KalixRuntimeContainer
Default runtime port (9000).
DEFAULT_STOP_TIMEOUT - Static variable in class kalix.javasdk.testkit.KalixTestKit.Settings
Default stop timeout (10 seconds).
DEFAULT_USER_SERVICE_PORT - Static variable in class kalix.javasdk.testkit.impl.KalixRuntimeContainer
Default user service port (8080).
DeferredCallDetails<I,O> - Interface in kalix.javasdk.testkit
 
didEmitEvents() - Method in interface kalix.javasdk.testkit.EventSourcedResult
 

E

EMPTY - Static variable in class kalix.javasdk.testkit.KalixTestKit.MockedEventing
 
EMPTY - Static variable in interface kalix.javasdk.testkit.MockRegistry
 
EVENT_SOURCED_ENTITY - Static variable in class kalix.javasdk.testkit.KalixTestKit.MockedEventing
 
eventingSupport - Variable in class kalix.javasdk.testkit.KalixTestKit.Settings
 
EventingTestKit - Interface in kalix.javasdk.testkit
 
EventingTestKit.IncomingMessages - Interface in kalix.javasdk.testkit
Allows to simulate publishing messages for the purposes of testing incoming message flow.
EventingTestKit.Message<P> - Interface in kalix.javasdk.testkit
 
EventingTestKit.MessageBuilder - Class in kalix.javasdk.testkit
 
EventingTestKit.OutgoingMessages - Interface in kalix.javasdk.testkit
Allows to assert published messages for the purposes of testing outgoing message flow.
EventSourcedEntityEffectsRunner<S,E> - Class in kalix.javasdk.testkit.impl
Extended by generated code, not meant for user extension
EventSourcedEntityEffectsRunner(EventSourcedEntity<S, E>) - Constructor for class kalix.javasdk.testkit.impl.EventSourcedEntityEffectsRunner
 
EventSourcedResult<R> - Interface in kalix.javasdk.testkit
Represents the result of an EventSourcedEntity handling a command when run in through the testkit.
expectN() - Method in interface kalix.javasdk.testkit.EventingTestKit.OutgoingMessages
Waits for a default amount of time before returning all unread messages.
expectN(int) - Method in interface kalix.javasdk.testkit.EventingTestKit.OutgoingMessages
Waits for a given amount of unread messages to be received before returning.
expectN(int, Duration) - Method in interface kalix.javasdk.testkit.EventingTestKit.OutgoingMessages
Waits for a given amount of unread messages to be received before returning up to a given timeout.
expectNone() - Method in interface kalix.javasdk.testkit.EventingTestKit.OutgoingMessages
Waits for predefined amount of time (see OutgoingMessagesImpl.DefaultTimeout() for default value).
expectNone(Duration) - Method in interface kalix.javasdk.testkit.EventingTestKit.OutgoingMessages
Waits for given amount of time.
expectOne() - Method in interface kalix.javasdk.testkit.EventingTestKit.OutgoingMessages
Waits for predefined amount of time (see OutgoingMessagesImpl.DefaultTimeout() for default value) and returns the next unread message.
expectOne(Duration) - Method in interface kalix.javasdk.testkit.EventingTestKit.OutgoingMessages
Waits for a specific amount and returns the next unread message.
expectOneRaw() - Method in interface kalix.javasdk.testkit.EventingTestKit.OutgoingMessages
Waits and returns the next unread message.
expectOneRaw(Duration) - Method in interface kalix.javasdk.testkit.EventingTestKit.OutgoingMessages
Waits and returns the next unread message.
expectOneTyped(Class<T>) - Method in interface kalix.javasdk.testkit.EventingTestKit.OutgoingMessages
Waits and returns the next unread message and automatically parses and casts it to the specified given type.
expectOneTyped(Class<T>, Duration) - Method in interface kalix.javasdk.testkit.EventingTestKit.OutgoingMessages
Waits and returns the next unread message and automatically parses and casts it to the specified given type.
expectType(Class<T>) - Method in interface kalix.javasdk.testkit.EventingTestKit.Message
Expects message payload to conform to type passed in and returns the typed object if so.

G

getActorSystem() - Method in class kalix.javasdk.testkit.junit.jupiter.KalixTestKitExtension
Get an ActorSystem for creating Akka HTTP clients.
getActorSystem() - Method in class kalix.javasdk.testkit.junit.KalixTestKitResource
Get an ActorSystem for creating Akka HTTP clients.
getActorSystem() - Method in class kalix.javasdk.testkit.KalixTestKit
Get an ActorSystem for creating Akka HTTP clients.
getAllEvents() - Method in interface kalix.javasdk.testkit.EventSourcedResult
 
getAllEvents() - Method in class kalix.javasdk.testkit.impl.EventSourcedEntityEffectsRunner
 
getAsyncResult() - Method in interface kalix.javasdk.testkit.ActionResult
 
getError() - Method in interface kalix.javasdk.testkit.ActionResult
 
getError() - Method in interface kalix.javasdk.testkit.EventSourcedResult
The error description.
getError() - Method in interface kalix.javasdk.testkit.ValueEntityResult
The error description.
getErrorStatusCode() - Method in interface kalix.javasdk.testkit.ActionResult
 
getErrorStatusCode() - Method in interface kalix.javasdk.testkit.EventSourcedResult
 
getErrorStatusCode() - Method in interface kalix.javasdk.testkit.ValueEntityResult
 
getEventSourcedEntityIncomingMessages(String) - Method in interface kalix.javasdk.testkit.EventingTestKit
 
getEventSourcedEntityIncomingMessages(String) - Method in class kalix.javasdk.testkit.junit.jupiter.KalixTestKitExtension
Get incoming messages for EventSourcedEntity.
getEventSourcedEntityIncomingMessages(String) - Method in class kalix.javasdk.testkit.junit.KalixTestKitResource
Get incoming messages for EventSourcedEntity.
getEventSourcedEntityIncomingMessages(String) - Method in class kalix.javasdk.testkit.KalixTestKit
Get incoming messages for EventSourcedEntity.
getForward() - Method in interface kalix.javasdk.testkit.ActionResult
 
getForward() - Method in interface kalix.javasdk.testkit.EventSourcedResult
An object with details about the forward.
getForward() - Method in interface kalix.javasdk.testkit.ValueEntityResult
 
getGrpcClient(Class<T>) - Method in class kalix.javasdk.testkit.junit.jupiter.KalixTestKitExtension
Get an Akka gRPC client for the given service name.
getGrpcClient(Class<T>) - Method in class kalix.javasdk.testkit.junit.KalixTestKitResource
Get an Akka gRPC client for the given service name.
getGrpcClient(Class<T>) - Method in class kalix.javasdk.testkit.KalixTestKit
Get an Akka gRPC client for the given service name.
getGrpcClientForPrincipal(Class<T>, Principal) - Method in class kalix.javasdk.testkit.KalixTestKit
Get an Akka gRPC client for the given service name, authenticating using the given principal.
getHost() - Method in class kalix.javasdk.testkit.junit.jupiter.KalixTestKitExtension
Get the host name/IP address where the Kalix service is available.
getHost() - Method in class kalix.javasdk.testkit.junit.KalixTestKitResource
Get the host name/IP address where the Kalix service is available.
getHost() - Method in class kalix.javasdk.testkit.KalixTestKit
Get the host name/IP address where the Kalix service is available.
getMaterializer() - Method in class kalix.javasdk.testkit.junit.jupiter.KalixTestKitExtension
An Akka Stream materializer to use for running streams.
getMaterializer() - Method in class kalix.javasdk.testkit.junit.KalixTestKitResource
An Akka Stream materializer to use for running streams.
getMaterializer() - Method in class kalix.javasdk.testkit.KalixTestKit
An Akka Stream materializer to use for running streams.
getMessage() - Method in interface kalix.javasdk.testkit.DeferredCallDetails
 
getMessageBuilder() - Method in class kalix.javasdk.testkit.junit.jupiter.KalixTestKitExtension
Returns EventingTestKit.MessageBuilder utility to create EventingTestKit.Messages for the eventing testkit.
getMessageBuilder() - Method in class kalix.javasdk.testkit.junit.KalixTestKitResource
Returns EventingTestKit.MessageBuilder utility to create EventingTestKit.Messages for the eventing testkit.
getMessageBuilder() - Method in class kalix.javasdk.testkit.KalixTestKit
Returns EventingTestKit.MessageBuilder utility to create EventingTestKit.Messages for the eventing testkit.
getMessageCodec() - Method in class kalix.javasdk.testkit.KalixTestKit
INTERNAL API
getMetadata() - Method in interface kalix.javasdk.testkit.DeferredCallDetails
 
getMetadata() - Method in interface kalix.javasdk.testkit.EventingTestKit.Message
 
getMethodName() - Method in interface kalix.javasdk.testkit.DeferredCallDetails
 
getNextEventOfType(Class<E>) - Method in interface kalix.javasdk.testkit.EventSourcedResult
Look at the next event and verify that it is of type E or fail if not or if there is no next event.
getPayload() - Method in interface kalix.javasdk.testkit.EventingTestKit.Message
 
getPort() - Method in class kalix.javasdk.testkit.junit.jupiter.KalixTestKitExtension
Get the local port where the Kalix service is available.
getPort() - Method in class kalix.javasdk.testkit.junit.KalixTestKitResource
Get the local port where the Kalix service is available.
getPort() - Method in class kalix.javasdk.testkit.KalixTestKit
Get the local port where the Kalix service is available.
getProxyPort() - Method in class kalix.javasdk.testkit.impl.KalixRuntimeContainer
Get the mapped port for the Kalix Runtime container.
getReply() - Method in interface kalix.javasdk.testkit.ActionResult
 
getReply() - Method in interface kalix.javasdk.testkit.EventSourcedResult
The reply object from the handler if there was one.
getReply() - Method in interface kalix.javasdk.testkit.ValueEntityResult
 
getRunner() - Method in class kalix.javasdk.testkit.KalixTestKit
INTERNAL API
getServiceName() - Method in interface kalix.javasdk.testkit.DeferredCallDetails
 
getSideEffects() - Method in interface kalix.javasdk.testkit.ActionResult
 
getSideEffects() - Method in interface kalix.javasdk.testkit.EventSourcedResult
 
getSideEffects() - Method in interface kalix.javasdk.testkit.ValueEntityResult
 
getState() - Method in class kalix.javasdk.testkit.impl.EventSourcedEntityEffectsRunner
 
getStreamIncomingMessages(String, String) - Method in interface kalix.javasdk.testkit.EventingTestKit
 
getStreamIncomingMessages(String, String) - Method in class kalix.javasdk.testkit.junit.jupiter.KalixTestKitExtension
Get incoming messages for Stream (eventing.in.direct in case of protobuf SDKs).
getStreamIncomingMessages(String, String) - Method in class kalix.javasdk.testkit.junit.KalixTestKitResource
Get incoming messages for Stream (eventing.in.direct in case of protobuf SDKs).
getStreamIncomingMessages(String, String) - Method in class kalix.javasdk.testkit.KalixTestKit
Get incoming messages for Stream (eventing.in.direct in case of protobuf SDKs).
getTopicIncomingMessages(String) - Method in interface kalix.javasdk.testkit.EventingTestKit
 
getTopicIncomingMessages(String) - Method in class kalix.javasdk.testkit.junit.jupiter.KalixTestKitExtension
Get incoming messages for Topic.
getTopicIncomingMessages(String) - Method in class kalix.javasdk.testkit.junit.KalixTestKitResource
Get incoming messages for Topic.
getTopicIncomingMessages(String) - Method in class kalix.javasdk.testkit.KalixTestKit
Get incoming messages for Topic.
getTopicOutgoingMessages(String) - Method in interface kalix.javasdk.testkit.EventingTestKit
 
getTopicOutgoingMessages(String) - Method in class kalix.javasdk.testkit.junit.jupiter.KalixTestKitExtension
Get mocked topic destination.
getTopicOutgoingMessages(String) - Method in class kalix.javasdk.testkit.junit.KalixTestKitResource
Get mocked topic destination.
getTopicOutgoingMessages(String) - Method in class kalix.javasdk.testkit.KalixTestKit
Get mocked topic destination.
getUpdatedState() - Method in interface kalix.javasdk.testkit.EventSourcedResult
 
getUpdatedState() - Method in interface kalix.javasdk.testkit.ValueEntityResult
 
getValueEntityIncomingMessages(String) - Method in interface kalix.javasdk.testkit.EventingTestKit
 
getValueEntityIncomingMessages(String) - Method in class kalix.javasdk.testkit.junit.jupiter.KalixTestKitExtension
Get incoming messages for ValueEntity.
getValueEntityIncomingMessages(String) - Method in class kalix.javasdk.testkit.junit.KalixTestKitResource
Get incoming messages for ValueEntity.
getValueEntityIncomingMessages(String) - Method in class kalix.javasdk.testkit.KalixTestKit
Get incoming messages for ValueEntity.
GOOGLE_PUBSUB - Enum constant in enum kalix.javasdk.testkit.KalixTestKit.Settings.EventingSupport
Used if you want to use an external Google PubSub (or its Emulator) on your tests.

H

handleEvent(S, E) - Method in class kalix.javasdk.testkit.impl.EventSourcedEntityEffectsRunner
 
hasConfig() - Method in class kalix.javasdk.testkit.KalixTestKit.MockedEventing
 
hasIncomingConfig() - Method in class kalix.javasdk.testkit.KalixTestKit.MockedEventing
 
hasOutgoingConfig() - Method in class kalix.javasdk.testkit.KalixTestKit.MockedEventing
 

I

interpretEffects(Supplier<EventSourcedEntity.Effect<R>>, Metadata) - Method in class kalix.javasdk.testkit.impl.EventSourcedEntityEffectsRunner
creates a command context to run the commands, then creates an event context to run the events, and finally, creates a command context to run the side effects.
isAsync() - Method in interface kalix.javasdk.testkit.ActionResult
 
isError() - Method in interface kalix.javasdk.testkit.ActionResult
 
isError() - Method in interface kalix.javasdk.testkit.EventSourcedResult
 
isError() - Method in interface kalix.javasdk.testkit.ValueEntityResult
 
isForward() - Method in interface kalix.javasdk.testkit.ActionResult
 
isForward() - Method in interface kalix.javasdk.testkit.EventSourcedResult
 
isForward() - Method in interface kalix.javasdk.testkit.ValueEntityResult
 
isIgnore() - Method in interface kalix.javasdk.testkit.ActionResult
 
isReply() - Method in interface kalix.javasdk.testkit.ActionResult
 
isReply() - Method in interface kalix.javasdk.testkit.EventSourcedResult
 
isReply() - Method in interface kalix.javasdk.testkit.ValueEntityResult
 

K

KAFKA - Enum constant in enum kalix.javasdk.testkit.KalixTestKit.Settings.EventingSupport
Used if you want to use an external Kafka broker on your tests.
kalix.javasdk.testkit - package kalix.javasdk.testkit
 
kalix.javasdk.testkit.impl - package kalix.javasdk.testkit.impl
 
kalix.javasdk.testkit.junit - package kalix.javasdk.testkit.junit
 
kalix.javasdk.testkit.junit.jupiter - package kalix.javasdk.testkit.junit.jupiter
 
KalixRuntimeContainer - Class in kalix.javasdk.testkit.impl
Docker test container of Kalix Runtime for local development and testing.
KalixRuntimeContainer() - Constructor for class kalix.javasdk.testkit.impl.KalixRuntimeContainer
 
KalixRuntimeContainer(int) - Constructor for class kalix.javasdk.testkit.impl.KalixRuntimeContainer
 
KalixRuntimeContainer(KalixTestKit.Settings.EventingSupport, int, int) - Constructor for class kalix.javasdk.testkit.impl.KalixRuntimeContainer
 
KalixRuntimeContainer(DockerImageName, KalixTestKit.Settings.EventingSupport, int, int) - Constructor for class kalix.javasdk.testkit.impl.KalixRuntimeContainer
 
KalixTestKit - Class in kalix.javasdk.testkit
Testkit for running Kalix services locally.
KalixTestKit(Kalix) - Constructor for class kalix.javasdk.testkit.KalixTestKit
Create a new testkit for a Kalix service descriptor.
KalixTestKit(Kalix, MessageCodec, KalixTestKit.Settings) - Constructor for class kalix.javasdk.testkit.KalixTestKit
Create a new testkit for a Kalix service descriptor with custom settings.
KalixTestKit(Kalix, KalixTestKit.Settings) - Constructor for class kalix.javasdk.testkit.KalixTestKit
Create a new testkit for a Kalix service descriptor with custom settings.
KalixTestKit.MockedEventing - Class in kalix.javasdk.testkit
 
KalixTestKit.Settings - Class in kalix.javasdk.testkit
Settings for KalixTestkit.
KalixTestKit.Settings.EventingSupport - Enum in kalix.javasdk.testkit
 
KalixTestKitExtension - Class in kalix.javasdk.testkit.junit.jupiter
A JUnit 5 "Jupiter" Extension for KalixTestKit, which automatically manages the lifecycle of the testkit.
KalixTestKitExtension(Kalix) - Constructor for class kalix.javasdk.testkit.junit.jupiter.KalixTestKitExtension
 
KalixTestKitExtension(Kalix, MessageCodec, KalixTestKit.Settings) - Constructor for class kalix.javasdk.testkit.junit.jupiter.KalixTestKitExtension
 
KalixTestKitExtension(Kalix, KalixTestKit.Settings) - Constructor for class kalix.javasdk.testkit.junit.jupiter.KalixTestKitExtension
 
KalixTestKitResource - Class in kalix.javasdk.testkit.junit
A JUnit 4 external resource for KalixTestKit, which automatically manages the lifecycle of the testkit.
KalixTestKitResource(Kalix) - Constructor for class kalix.javasdk.testkit.junit.KalixTestKitResource
 
KalixTestKitResource(Kalix, MessageCodec, KalixTestKit.Settings) - Constructor for class kalix.javasdk.testkit.junit.KalixTestKitResource
 
KalixTestKitResource(Kalix, KalixTestKit.Settings) - Constructor for class kalix.javasdk.testkit.junit.KalixTestKitResource
 

M

MessageBuilder(MessageCodec) - Constructor for class kalix.javasdk.testkit.EventingTestKit.MessageBuilder
 
mockedEventing - Variable in class kalix.javasdk.testkit.KalixTestKit.Settings
 
MockRegistry - Interface in kalix.javasdk.testkit
This trait is meant to allow for unit testing when a service has cross-component or cross-service calls.

O

of(T, String) - Method in class kalix.javasdk.testkit.EventingTestKit.MessageBuilder
Create a message from a payload plus a subject (that is, the entity id).
of(T, Metadata) - Method in class kalix.javasdk.testkit.EventingTestKit.MessageBuilder
Create a message object from a payload plus metadata.

P

publish(ByteString) - Method in interface kalix.javasdk.testkit.EventingTestKit.IncomingMessages
Simulate the publishing of a raw message.
publish(ByteString, Metadata) - Method in interface kalix.javasdk.testkit.EventingTestKit.IncomingMessages
Simulate the publishing of a raw message.
publish(List<EventingTestKit.Message<?>>) - Method in interface kalix.javasdk.testkit.EventingTestKit.IncomingMessages
Publish multiple messages.
publish(EventingTestKit.Message<?>) - Method in interface kalix.javasdk.testkit.EventingTestKit.IncomingMessages
Simulate the publishing of a message.
publish(T, String) - Method in interface kalix.javasdk.testkit.EventingTestKit.IncomingMessages
Simulate the publishing of a message.
publishDelete(String) - Method in interface kalix.javasdk.testkit.EventingTestKit.IncomingMessages
Publish a predefined delete message.

S

serviceName - Variable in class kalix.javasdk.testkit.KalixTestKit.Settings
The name of this service when deployed.
servicePortMappings - Variable in class kalix.javasdk.testkit.KalixTestKit.Settings
Service port mappings from serviceName to host:port
Settings(Duration) - Constructor for class kalix.javasdk.testkit.KalixTestKit.Settings
Deprecated.
Use Settings.DEFAULT.withStopTimeout() instead.
start() - Method in class kalix.javasdk.testkit.impl.KalixRuntimeContainer
 
start() - Method in class kalix.javasdk.testkit.KalixTestKit
Start this testkit with default configuration (loaded from application.conf).
start(ActorSystem, String, int, MessageCodec) - Static method in interface kalix.javasdk.testkit.EventingTestKit
INTERNAL API
start(Config) - Method in class kalix.javasdk.testkit.KalixTestKit
Start this testkit with custom configuration (overrides application.conf).
stateWasDeleted() - Method in interface kalix.javasdk.testkit.ValueEntityResult
 
stateWasUpdated() - Method in interface kalix.javasdk.testkit.ValueEntityResult
 
stop() - Method in class kalix.javasdk.testkit.KalixTestKit
Stop the testkit and local Kalix.
stopTimeout - Variable in class kalix.javasdk.testkit.KalixTestKit.Settings
Timeout setting for stopping the local Kalix test instance.
STREAM - Static variable in class kalix.javasdk.testkit.KalixTestKit.MockedEventing
 

T

TEST_BROKER - Enum constant in enum kalix.javasdk.testkit.KalixTestKit.Settings.EventingSupport
This is the default type used and allows the testing eventing integrations without an external broker dependency running.
toIncomingFlowConfig() - Method in class kalix.javasdk.testkit.KalixTestKit.MockedEventing
 
toOutgoingFlowConfig() - Method in class kalix.javasdk.testkit.KalixTestKit.MockedEventing
 
TOPIC - Static variable in class kalix.javasdk.testkit.KalixTestKit.MockedEventing
 
toString() - Method in class kalix.javasdk.testkit.KalixTestKit.MockedEventing
 
toString() - Method in class kalix.javasdk.testkit.KalixTestKit.Settings
 

V

VALUE_ENTITY - Static variable in class kalix.javasdk.testkit.KalixTestKit.MockedEventing
 
ValueEntityResult<R> - Interface in kalix.javasdk.testkit
Represents the result of an ValueEntity handling a command when run in through the testkit.
valueOf(String) - Static method in enum kalix.javasdk.testkit.KalixTestKit.Settings.EventingSupport
Returns the enum constant of this type with the specified name.
values() - Static method in enum kalix.javasdk.testkit.KalixTestKit.Settings.EventingSupport
Returns an array containing the constants of this enum type, in the order they are declared.

W

withAclDisabled() - Method in class kalix.javasdk.testkit.KalixTestKit.Settings
Disable ACL checking in this service.
withAclEnabled() - Method in class kalix.javasdk.testkit.KalixTestKit.Settings
Enable ACL checking in this service.
withAdvancedViews() - Method in class kalix.javasdk.testkit.KalixTestKit.Settings
Enable advanced View features for this service.
withEventingSupport(KalixTestKit.Settings.EventingSupport) - Method in class kalix.javasdk.testkit.KalixTestKit.Settings
 
withEventSourcedEntityIncomingMessages(String) - Method in class kalix.javasdk.testkit.KalixTestKit.Settings
Mock the incoming events flow from an EventSourcedEntity.
withEventSourcedIncomingMessages(String) - Method in class kalix.javasdk.testkit.KalixTestKit.MockedEventing
 
withMock(Class<T>, T) - Method in interface kalix.javasdk.testkit.MockRegistry
Returns a new MockRegistry with the new mock added to previous ones.
withServiceName(String) - Method in class kalix.javasdk.testkit.KalixTestKit.Settings
Set the name of this service.
withServicePortMapping(String, String, int) - Method in class kalix.javasdk.testkit.KalixTestKit.Settings
Add a service port mapping from serviceName to host:port.
withStopTimeout(Duration) - Method in class kalix.javasdk.testkit.KalixTestKit.Settings
Set a custom stop timeout, for stopping the local Kalix test instance.
withStreamIncomingMessages(String, String) - Method in class kalix.javasdk.testkit.KalixTestKit.MockedEventing
 
withStreamIncomingMessages(String, String) - Method in class kalix.javasdk.testkit.KalixTestKit.Settings
Mock the incoming messages flow from a Stream (eventing.in.direct in case of protobuf SDKs).
withTopicIncomingMessages(String) - Method in class kalix.javasdk.testkit.KalixTestKit.MockedEventing
 
withTopicIncomingMessages(String) - Method in class kalix.javasdk.testkit.KalixTestKit.Settings
Mock the incoming events flow from a Topic.
withTopicOutgoingMessages(String) - Method in class kalix.javasdk.testkit.KalixTestKit.MockedEventing
 
withTopicOutgoingMessages(String) - Method in class kalix.javasdk.testkit.KalixTestKit.Settings
Mock the outgoing events flow for a Topic.
withValueEntityIncomingMessages(String) - Method in class kalix.javasdk.testkit.KalixTestKit.MockedEventing
 
withValueEntityIncomingMessages(String) - Method in class kalix.javasdk.testkit.KalixTestKit.Settings
Mock the incoming messages flow from a ValueEntity.
withWorkflowTickInterval(Duration) - Method in class kalix.javasdk.testkit.KalixTestKit.Settings
Overrides workflow tick interval
workflowTickInterval - Variable in class kalix.javasdk.testkit.KalixTestKit.Settings
To override workflow tick interval for integration tests
A B C D E G H I K M O P S T V W 
All Classes and Interfaces|All Packages|Constant Field Values