Call method and return a request id and a result channel.

Call method with parent and return a request id and a result channel (used in debugging).

BindingPartition.

Call method and wait for result.

Call method, marking the request as edited (used in debugging).

CollectInactiveSessions deactives SessionInstances that have not been used since the given time.

Connect to Kafka.

CreateTopic attempts to create the specified topic using the given parameters.

DeleteTopic attempts to delete the specified topic.

DelSession forgets the node id responsible for the specified session.

Connect to Kafka and return a channel closed after disconnecting from Kafka.

GetAllSessions returns a map from Session names to all known IDs for each name.

GetLocalActivatedSessions returns a map from Session names IDs with local Activated SessionInstances If name is not "", only SessionInstances with the given Name are returned.

GetNodeID returns the node id for the current node.

GetNodeIDs returns the sorted list of live node ids and a channel to be notified of changes.

GetPartition returns the partition for the current node.

GetPartitions returns the sorted list of partitions in use and a channel to be notified of changes TODO: fix hack, for now returns the set {0} as this method is only used to reload bindings.

GetServiceNodeIDs returns the sorted list of live node ids for a given service.

GetServices returns the sorted list of services currently available.

GetSessionNodeId returns the node responsible for the specified session if defined or "" if not.

GetTopology returns a map from node ids to services.

NewPublisher returns a new event publisher.

Reclaim resources associated with async request id.

Register method handler.

Register method handler.

Register method handler.

Send message (errors: cancelled, Redis, Kafka, ErrUnavailable).

Subscribe to a topic.

Call method and return immediately (result will be discarded).

Tell method, marking the request as edited (used in debugging).

errors.

Temp staging for experiments.

Config specifies the Kafka configuration.

Node implements Target.

Result of async call.

Service implements Target.

Session implements Target.

An instance of a Session.

A Publisher makes it possible to publish events to Kafka.

Target of an invocation.

Handler for method.

Data transformer applied to convert external events to Tell payloads.