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