cluster

package

Go to main page

Versions in this module

v0

v0.3.0

Nov 29, 2023

Changes in this version

+ const GracefullyLeftKey

+ const PubSubDeliveryName

+ const TopicActorKind

+ var DeliveryStatus_name = map[int32]string

+ var DeliveryStatus_value = map[string]int32

+ var FailBatchAndContinue = NewPublishingErrorDecision(0)

+ var FailBatchAndStop = NewPublishingErrorDecision(0)

+ var File_pubsub_proto protoreflect.FileDescriptor

+ var File_pubsub_test_proto protoreflect.FileDescriptor

+ var PublishStatus_name = map[int32]string

+ var PublishStatus_value = map[string]int32

+ var RetryBatchImmediately = NewPublishingErrorDecision(0)

+ type Acknowledge struct

+ func (*Acknowledge) Descriptor() ([]byte, []int)

+ func (*Acknowledge) ProtoMessage()

+ func (x *Acknowledge) ProtoReflect() protoreflect.Message

+ func (x *Acknowledge) Reset()

+ func (x *Acknowledge) String() string

+ type BatchingProducer struct

+ func NewBatchingProducer(publisher Publisher, topic string, opts ...BatchingProducerConfigOption) *BatchingProducer

+ func (p *BatchingProducer) Dispose()

+ func (p *BatchingProducer) Produce(ctx context.Context, message interface{}) (*ProduceProcessInfo, error)

+ type BatchingProducerConfig struct

+ BatchSize int

+ LogThrottle actor.ShouldThrottle

+ MaxQueueSize int

+ OnPublishingError PublishingErrorHandler

+ PublishTimeout time.Duration

+ PublisherIdleTimeout time.Duration

+ type BatchingProducerConfigOption func(config *BatchingProducerConfig)

+ func WithBatchingProducerBatchSize(batchSize int) BatchingProducerConfigOption

+ func WithBatchingProducerLogThrottle(logThrottle actor.ShouldThrottle) BatchingProducerConfigOption

+ func WithBatchingProducerMaxQueueSize(maxQueueSize int) BatchingProducerConfigOption

+ func WithBatchingProducerOnPublishingError(onPublishingError PublishingErrorHandler) BatchingProducerConfigOption

+ func WithBatchingProducerPublishTimeout(publishTimeout time.Duration) BatchingProducerConfigOption

+ func WithBatchingProducerPublisherIdleTimeout(publisherIdleTimeout time.Duration) BatchingProducerConfigOption

type Cluster

+ PubSub *PubSub

+ func (c *Cluster) BatchingProducer(topic string, opts ...BatchingProducerConfigOption) *BatchingProducer

+ func (c *Cluster) Logger() *slog.Logger

+ func (c *Cluster) Publisher() Publisher

+ func (c *Cluster) SubscribeByClusterIdentity(topic string, identity *ClusterIdentity, opts ...GrainCallOption) (*SubscribeResponse, error)

+ func (c *Cluster) SubscribeByPid(topic string, pid *actor.PID, opts ...GrainCallOption) (*SubscribeResponse, error)

+ func (c *Cluster) SubscribeWithReceive(topic string, receive actor.ReceiveFunc, opts ...GrainCallOption) (*SubscribeResponse, error)

+ func (c *Cluster) UnsubscribeByClusterIdentity(topic string, identity *ClusterIdentity, opts ...GrainCallOption) (*UnsubscribeResponse, error)

+ func (c *Cluster) UnsubscribeByIdentityAndKind(topic string, identity string, kind string, opts ...GrainCallOption) (*UnsubscribeResponse, error)

+ func (c *Cluster) UnsubscribeByPid(topic string, pid *actor.PID, opts ...GrainCallOption) (*UnsubscribeResponse, error)

type Config

+ HeartbeatExpiration time.Duration

+ PubSubConfig *PubSubConfig

type ConfigOption

+ func WithHeartbeatExpiration(t time.Duration) ConfigOption

+ func WithPubSubSubscriberTimeout(timeout time.Duration) ConfigOption

+ type DeliverBatchRequest struct

+ PubSubBatch *PubSubBatch

+ Subscribers *Subscribers

+ Topic string

+ func (d *DeliverBatchRequest) Serialize() remote.RootSerialized

+ type DeliverBatchRequestTransport struct

+ Batch *PubSubBatchTransport

+ Subscribers *Subscribers

+ Topic string

+ func (*DeliverBatchRequestTransport) Descriptor() ([]byte, []int)

+ func (*DeliverBatchRequestTransport) ProtoMessage()

+ func (t *DeliverBatchRequestTransport) Deserialize() remote.RootSerializable

+ func (x *DeliverBatchRequestTransport) GetBatch() *PubSubBatchTransport

+ func (x *DeliverBatchRequestTransport) GetSubscribers() *Subscribers

+ func (x *DeliverBatchRequestTransport) GetTopic() string

+ func (x *DeliverBatchRequestTransport) ProtoReflect() protoreflect.Message

+ func (x *DeliverBatchRequestTransport) Reset()

+ func (x *DeliverBatchRequestTransport) String() string

+ type DeliveryStatus int32

+ const DeliveryStatus_Delivered

+ const DeliveryStatus_OtherError

+ const DeliveryStatus_SubscriberNoLongerReachable

+ const DeliveryStatus_Timeout

+ func (DeliveryStatus) Descriptor() protoreflect.EnumDescriptor

+ func (DeliveryStatus) EnumDescriptor() ([]byte, []int)

+ func (DeliveryStatus) Type() protoreflect.EnumType

+ func (x DeliveryStatus) Enum() *DeliveryStatus

+ func (x DeliveryStatus) Number() protoreflect.EnumNumber

+ func (x DeliveryStatus) String() string

+ type EmptyKeyValueStore struct

+ func (e *EmptyKeyValueStore[T]) Clear(_ context.Context, _ string) error

+ func (e *EmptyKeyValueStore[T]) Get(_ context.Context, _ string) (T, error)

+ func (e *EmptyKeyValueStore[T]) Set(_ context.Context, _ string, _ T) error

type GrainCallOption

+ func WithRetryCount(count int) GrainCallOption

+ type Initialize struct

+ IdleTimeout *durationpb.Duration

+ func (*Initialize) Descriptor() ([]byte, []int)

+ func (*Initialize) ProtoMessage()

+ func (x *Initialize) GetIdleTimeout() *durationpb.Duration

+ func (x *Initialize) ProtoReflect() protoreflect.Message

+ func (x *Initialize) Reset()

+ func (x *Initialize) String() string

+ type InvalidOperationException struct

+ Topic string

+ func (i *InvalidOperationException) Error() string

+ func (i *InvalidOperationException) Is(err error) bool

+ type KeyValueStore interface

+ Clear func(ctx context.Context, key string) error

+ Get func(ctx context.Context, key string) (T, error)

+ Set func(ctx context.Context, key string, value T) error

+ type NotifyAboutFailingSubscribersRequest struct

+ InvalidDeliveries []*SubscriberDeliveryReport

+ func (*NotifyAboutFailingSubscribersRequest) Descriptor() ([]byte, []int)

+ func (*NotifyAboutFailingSubscribersRequest) ProtoMessage()

+ func (x *NotifyAboutFailingSubscribersRequest) GetInvalidDeliveries() []*SubscriberDeliveryReport

+ func (x *NotifyAboutFailingSubscribersRequest) ProtoReflect() protoreflect.Message

+ func (x *NotifyAboutFailingSubscribersRequest) Reset()

+ func (x *NotifyAboutFailingSubscribersRequest) String() string

+ type NotifyAboutFailingSubscribersResponse struct

+ func (*NotifyAboutFailingSubscribersResponse) Descriptor() ([]byte, []int)

+ func (*NotifyAboutFailingSubscribersResponse) ProtoMessage()

+ func (x *NotifyAboutFailingSubscribersResponse) ProtoReflect() protoreflect.Message

+ func (x *NotifyAboutFailingSubscribersResponse) Reset()

+ func (x *NotifyAboutFailingSubscribersResponse) String() string

+ type ProduceProcessInfo struct

+ Err error

+ Finished chan struct{}

+ func (p *ProduceProcessInfo) IsCancelled() bool

+ func (p *ProduceProcessInfo) IsFinished() bool

+ type ProducerQueueFullException struct

+ func (p *ProducerQueueFullException) Error() string

+ func (p *ProducerQueueFullException) Is(target error) bool

+ type PubSub struct

+ func GetPubSub(system *actor.ActorSystem) *PubSub

+ func NewPubSub(cluster *Cluster) *PubSub

+ func (p *PubSub) ExtensionID() extensions.ExtensionID

+ func (p *PubSub) Start()

+ type PubSubAutoRespondBatch struct

+ Envelopes []interface{}

+ func (b *PubSubAutoRespondBatch) GetAutoResponse(_ actor.Context) interface{}

+ func (b *PubSubAutoRespondBatch) GetMessages() []interface{}

+ func (b *PubSubAutoRespondBatch) Serialize() remote.RootSerialized

+ type PubSubAutoRespondBatchTransport struct

+ Envelopes []*PubSubEnvelope

+ TypeNames []string

+ func (*PubSubAutoRespondBatchTransport) Descriptor() ([]byte, []int)

+ func (*PubSubAutoRespondBatchTransport) ProtoMessage()

+ func (t *PubSubAutoRespondBatchTransport) Deserialize() remote.RootSerializable

+ func (x *PubSubAutoRespondBatchTransport) GetEnvelopes() []*PubSubEnvelope

+ func (x *PubSubAutoRespondBatchTransport) GetTypeNames() []string

+ func (x *PubSubAutoRespondBatchTransport) ProtoReflect() protoreflect.Message

+ func (x *PubSubAutoRespondBatchTransport) Reset()

+ func (x *PubSubAutoRespondBatchTransport) String() string

+ type PubSubBatch struct

+ Envelopes []interface{}

+ func (b *PubSubBatch) Serialize() remote.RootSerialized

+ type PubSubBatchTransport struct

+ Envelopes []*PubSubEnvelope

+ TypeNames []string

+ func (*PubSubBatchTransport) Descriptor() ([]byte, []int)

+ func (*PubSubBatchTransport) ProtoMessage()

+ func (t *PubSubBatchTransport) Deserialize() remote.RootSerializable

+ func (x *PubSubBatchTransport) GetEnvelopes() []*PubSubEnvelope

+ func (x *PubSubBatchTransport) GetTypeNames() []string

+ func (x *PubSubBatchTransport) ProtoReflect() protoreflect.Message

+ func (x *PubSubBatchTransport) Reset()

+ func (x *PubSubBatchTransport) String() string

+ type PubSubConfig struct

+ SubscriberTimeout time.Duration

+ type PubSubEnvelope struct

+ MessageData []byte

+ SerializerId int32

+ TypeId int32

+ func (*PubSubEnvelope) Descriptor() ([]byte, []int)

+ func (*PubSubEnvelope) ProtoMessage()

+ func (x *PubSubEnvelope) GetMessageData() []byte

+ func (x *PubSubEnvelope) GetSerializerId() int32

+ func (x *PubSubEnvelope) GetTypeId() int32

+ func (x *PubSubEnvelope) ProtoReflect() protoreflect.Message

+ func (x *PubSubEnvelope) Reset()

+ func (x *PubSubEnvelope) String() string

+ type PubSubMemberDeliveryActor struct

+ func NewPubSubMemberDeliveryActor(subscriberTimeout time.Duration, logger *slog.Logger) *PubSubMemberDeliveryActor

+ func (p *PubSubMemberDeliveryActor) DeliverBatch(c actor.Context, batch *PubSubAutoRespondBatch, s *SubscriberIdentity) *actor.Future

+ func (p *PubSubMemberDeliveryActor) DeliverToClusterIdentity(c actor.Context, batch *PubSubAutoRespondBatch, ci *ClusterIdentity) *actor.Future

+ func (p *PubSubMemberDeliveryActor) DeliverToPid(c actor.Context, batch *PubSubAutoRespondBatch, pid *actor.PID) *actor.Future

+ func (p *PubSubMemberDeliveryActor) Receive(c actor.Context)

+ type PublishResponse struct

+ Status PublishStatus

+ func (*PublishResponse) Descriptor() ([]byte, []int)

+ func (*PublishResponse) ProtoMessage()

+ func (x *PublishResponse) GetStatus() PublishStatus

+ func (x *PublishResponse) ProtoReflect() protoreflect.Message

+ func (x *PublishResponse) Reset()

+ func (x *PublishResponse) String() string

+ type PublishStatus int32

+ const PublishStatus_Failed

+ const PublishStatus_Ok

+ func (PublishStatus) Descriptor() protoreflect.EnumDescriptor

+ func (PublishStatus) EnumDescriptor() ([]byte, []int)

+ func (PublishStatus) Type() protoreflect.EnumType

+ func (x PublishStatus) Enum() *PublishStatus

+ func (x PublishStatus) Number() protoreflect.EnumNumber

+ func (x PublishStatus) String() string

+ type Publisher interface

+ Initialize func(ctx context.Context, topic string, config PublisherConfig) (*Acknowledge, error)

+ Logger func() *slog.Logger

+ Publish func(ctx context.Context, topic string, message interface{}, ...) (*PublishResponse, error)

+ PublishBatch func(ctx context.Context, topic string, batch *PubSubBatch, opts ...GrainCallOption) (*PublishResponse, error)

+ func NewPublisher(cluster *Cluster) Publisher

+ type PublisherConfig struct

+ IdleTimeout time.Duration

+ type PublishingErrorDecision struct

+ Delay time.Duration

+ func NewPublishingErrorDecision(delay time.Duration) *PublishingErrorDecision

+ func RetryBatchAfter(delay time.Duration) *PublishingErrorDecision

+ type PublishingErrorHandler func(retries int, e error, batch *PubSubBatch) *PublishingErrorDecision

+ type SubscribeRequest struct

+ Subscriber *SubscriberIdentity

+ func (*SubscribeRequest) Descriptor() ([]byte, []int)

+ func (*SubscribeRequest) ProtoMessage()

+ func (x *SubscribeRequest) GetSubscriber() *SubscriberIdentity

+ func (x *SubscribeRequest) ProtoReflect() protoreflect.Message

+ func (x *SubscribeRequest) Reset()

+ func (x *SubscribeRequest) String() string

+ type SubscribeResponse struct

+ func (*SubscribeResponse) Descriptor() ([]byte, []int)

+ func (*SubscribeResponse) ProtoMessage()

+ func (x *SubscribeResponse) ProtoReflect() protoreflect.Message

+ func (x *SubscribeResponse) Reset()

+ func (x *SubscribeResponse) String() string

+ type SubscriberDeliveryReport struct

+ Status DeliveryStatus

+ Subscriber *SubscriberIdentity

+ func (*SubscriberDeliveryReport) Descriptor() ([]byte, []int)

+ func (*SubscriberDeliveryReport) ProtoMessage()

+ func (x *SubscriberDeliveryReport) GetStatus() DeliveryStatus

+ func (x *SubscriberDeliveryReport) GetSubscriber() *SubscriberIdentity

+ func (x *SubscriberDeliveryReport) ProtoReflect() protoreflect.Message

+ func (x *SubscriberDeliveryReport) Reset()

+ func (x *SubscriberDeliveryReport) String() string

+ type SubscriberIdentity struct

+ Identity isSubscriberIdentity_Identity

+ func (*SubscriberIdentity) Descriptor() ([]byte, []int)

+ func (*SubscriberIdentity) ProtoMessage()

+ func (m *SubscriberIdentity) GetIdentity() isSubscriberIdentity_Identity

+ func (x *SubscriberIdentity) GetClusterIdentity() *ClusterIdentity

+ func (x *SubscriberIdentity) GetPid() *actor.PID

+ func (x *SubscriberIdentity) ProtoReflect() protoreflect.Message

+ func (x *SubscriberIdentity) Reset()

+ func (x *SubscriberIdentity) String() string

+ type SubscriberIdentity_ClusterIdentity struct

+ ClusterIdentity *ClusterIdentity

+ type SubscriberIdentity_Pid struct

+ Pid *actor.PID

+ type Subscribers struct

+ Subscribers []*SubscriberIdentity

+ func (*Subscribers) Descriptor() ([]byte, []int)

+ func (*Subscribers) ProtoMessage()

+ func (x *Subscribers) GetSubscribers() []*SubscriberIdentity

+ func (x *Subscribers) ProtoReflect() protoreflect.Message

+ func (x *Subscribers) Reset()

+ func (x *Subscribers) String() string

+ type TestMessage struct

+ Number int32

+ func (*TestMessage) Descriptor() ([]byte, []int)

+ func (*TestMessage) ProtoMessage()

+ func (x *TestMessage) GetNumber() int32

+ func (x *TestMessage) ProtoReflect() protoreflect.Message

+ func (x *TestMessage) Reset()

+ func (x *TestMessage) String() string

+ type TopicActor struct

+ func NewTopicActor(store KeyValueStore[*Subscribers], logger *slog.Logger) *TopicActor

+ func (t *TopicActor) Receive(c actor.Context)

+ type UnsubscribeRequest struct

+ Subscriber *SubscriberIdentity

+ func (*UnsubscribeRequest) Descriptor() ([]byte, []int)

+ func (*UnsubscribeRequest) ProtoMessage()

+ func (x *UnsubscribeRequest) GetSubscriber() *SubscriberIdentity

+ func (x *UnsubscribeRequest) ProtoReflect() protoreflect.Message

+ func (x *UnsubscribeRequest) Reset()

+ func (x *UnsubscribeRequest) String() string

+ type UnsubscribeResponse struct

+ func (*UnsubscribeResponse) Descriptor() ([]byte, []int)

+ func (*UnsubscribeResponse) ProtoMessage()

+ func (x *UnsubscribeResponse) ProtoReflect() protoreflect.Message

+ func (x *UnsubscribeResponse) Reset()

+ func (x *UnsubscribeResponse) String() string

v0.2.5

Nov 15, 2022

v0.2.4

Nov 11, 2022

v0.2.3

Oct 4, 2022

v0.2.2

Oct 4, 2022

v0.2.1

Sep 30, 2022

Changes in this version

+ const DefaultGossipActorName

+ const HearthbeatKey

+ const TopologyKey

+ var File_cluster_proto protoreflect.FileDescriptor

+ var File_gossip_proto protoreflect.FileDescriptor

+ var File_grain_proto protoreflect.FileDescriptor

+ var IdentityHandoverAck_State_name = map[int32]string

+ var IdentityHandoverAck_State_value = map[string]int32

+ func MembersToMap(members Members) map[string]*Member

+ func NewGossipConsensusHandler() *gossipConsensusHandler

+ func RemotePlacementActor(address string) *actor.PID

+ func SetClusterIdentity(ctx actor.ExtensionContext, ci *ClusterIdentity)

+ func SetLogLevel(level log.Level)

+ func SortMembers(members Members)

+ func TopologyHash(members Members) uint64

+ func WithClusterIdentity(props *actor.Props, ci *ClusterIdentity) *actor.Props

+ type ActivatedKind struct

+ Kind string

+ Props *actor.Props

+ Strategy MemberStrategy

+ func (ak *ActivatedKind) Dev()

+ func (ak *ActivatedKind) Inc()

+ type Activation struct

+ ClusterIdentity *ClusterIdentity

+ Pid *actor.PID

+ func (*Activation) Descriptor() ([]byte, []int)

+ func (*Activation) ProtoMessage()

+ func (x *Activation) GetClusterIdentity() *ClusterIdentity

+ func (x *Activation) GetPid() *actor.PID

+ func (x *Activation) ProtoReflect() protoreflect.Message

+ func (x *Activation) Reset()

+ func (x *Activation) String() string

+ type ActivationRequest struct

+ ClusterIdentity *ClusterIdentity

+ RequestId string

+ TopologyHash uint64

+ func (*ActivationRequest) Descriptor() ([]byte, []int)

+ func (*ActivationRequest) ProtoMessage()

+ func (x *ActivationRequest) GetClusterIdentity() *ClusterIdentity

+ func (x *ActivationRequest) GetRequestId() string

+ func (x *ActivationRequest) GetTopologyHash() uint64

+ func (x *ActivationRequest) ProtoReflect() protoreflect.Message

+ func (x *ActivationRequest) Reset()

+ func (x *ActivationRequest) String() string

+ type ActivationResponse struct

+ Failed bool

+ Pid *actor.PID

+ TopologyHash uint64

+ func (*ActivationResponse) Descriptor() ([]byte, []int)

+ func (*ActivationResponse) ProtoMessage()

+ func (x *ActivationResponse) GetFailed() bool

+ func (x *ActivationResponse) GetPid() *actor.PID

+ func (x *ActivationResponse) GetTopologyHash() uint64

+ func (x *ActivationResponse) ProtoReflect() protoreflect.Message

+ func (x *ActivationResponse) Reset()

+ func (x *ActivationResponse) String() string

+ type ActivationTerminated struct

+ ClusterIdentity *ClusterIdentity

+ Pid *actor.PID

+ func (*ActivationTerminated) Descriptor() ([]byte, []int)

+ func (*ActivationTerminated) ProtoMessage()

+ func (x *ActivationTerminated) GetClusterIdentity() *ClusterIdentity

+ func (x *ActivationTerminated) GetPid() *actor.PID

+ func (x *ActivationTerminated) ProtoReflect() protoreflect.Message

+ func (x *ActivationTerminated) Reset()

+ func (x *ActivationTerminated) String() string

+ type ActivationTerminating struct

+ ClusterIdentity *ClusterIdentity

+ Pid *actor.PID

+ func (*ActivationTerminating) Descriptor() ([]byte, []int)

+ func (*ActivationTerminating) ProtoMessage()

+ func (x *ActivationTerminating) GetClusterIdentity() *ClusterIdentity

+ func (x *ActivationTerminating) GetPid() *actor.PID

+ func (x *ActivationTerminating) ProtoReflect() protoreflect.Message

+ func (x *ActivationTerminating) Reset()

+ func (x *ActivationTerminating) String() string

+ type ActorStatistics struct

+ ActorCount map[string]int64

+ func (*ActorStatistics) Descriptor() ([]byte, []int)

+ func (*ActorStatistics) ProtoMessage()

+ func (x *ActorStatistics) GetActorCount() map[string]int64

+ func (x *ActorStatistics) ProtoReflect() protoreflect.Message

+ func (x *ActorStatistics) Reset()

+ func (x *ActorStatistics) String() string

+ type AddConsensusCheck struct

+ Check *ConsensusCheck

+ ID string

+ func NewAddConsensusCheck(id string, check *ConsensusCheck) AddConsensusCheck

+ type Cluster struct

+ ActorSystem *actor.ActorSystem

+ Config *Config

+ Gossip Gossiper

+ IdentityLookup IdentityLookup

+ MemberList *MemberList

+ PidCache *PidCacheValue

+ Remote *remote.Remote

+ func GetCluster(actorSystem *actor.ActorSystem) *Cluster

+ func New(actorSystem *actor.ActorSystem, config *Config) *Cluster

+ func (c *Cluster) Call(name string, kind string, msg interface{}, opts ...GrainCallOption) (interface{}, error)

+ func (c *Cluster) ExtensionID() extensions.ExtensionID

+ func (c *Cluster) Get(identity string, kind string) *actor.PID

+ func (c *Cluster) GetBlockedMembers() set.Set[string]

+ func (c *Cluster) GetClusterKind(kind string) *ActivatedKind

+ func (c *Cluster) GetClusterKinds() []string

+ func (c *Cluster) Request(identity string, kind string, message interface{}) (interface{}, error)

+ func (c *Cluster) Shutdown(graceful bool)

+ func (c *Cluster) StartClient()

+ func (c *Cluster) StartMember()

+ func (c *Cluster) TryGetClusterKind(kind string) (*ActivatedKind, bool)

+ type ClusterContextConfig struct

+ ActorRequestTimeout time.Duration

+ MaxNumberOfEventsInRequestLogThrottledPeriod int

+ RequestsLogThrottlePeriod time.Duration

+ RetryAction func(int) int

+ func NewDefaultClusterContextConfig() *ClusterContextConfig

+ type ClusterIdentity struct

+ Identity string

+ Kind string

+ func GetClusterIdentity(ctx actor.ExtensionContext) *ClusterIdentity

+ func NewClusterIdentity(identity string, kind string) *ClusterIdentity

+ func (*ClusterIdentity) Descriptor() ([]byte, []int)

+ func (*ClusterIdentity) ProtoMessage()

+ func (ci *ClusterIdentity) AsKey() string

+ func (ci *ClusterIdentity) ExtensionID() ctxext.ContextExtensionID

+ func (ci *ClusterIdentity) ToShortString() string

+ func (x *ClusterIdentity) GetIdentity() string

+ func (x *ClusterIdentity) GetKind() string

+ func (x *ClusterIdentity) ProtoReflect() protoreflect.Message

+ func (x *ClusterIdentity) Reset()

+ func (x *ClusterIdentity) String() string

+ type ClusterInit struct

+ Cluster *Cluster

+ Identity *ClusterIdentity

+ type ClusterProvider interface

+ Shutdown func(graceful bool) error

+ StartClient func(cluster *Cluster) error

+ StartMember func(cluster *Cluster) error

+ type ClusterTopology struct

+ Blocked []string

+ Joined []*Member

+ Left []*Member

+ Members []*Member

+ TopologyHash uint64

+ func (*ClusterTopology) Descriptor() ([]byte, []int)

+ func (*ClusterTopology) ProtoMessage()

+ func (x *ClusterTopology) GetBlocked() []string

+ func (x *ClusterTopology) GetJoined() []*Member

+ func (x *ClusterTopology) GetLeft() []*Member

+ func (x *ClusterTopology) GetMembers() []*Member

+ func (x *ClusterTopology) GetTopologyHash() uint64

+ func (x *ClusterTopology) ProtoReflect() protoreflect.Message

+ func (x *ClusterTopology) Reset()

+ func (x *ClusterTopology) String() string

+ type ClusterTopologyNotification struct

+ LeaderId string

+ MemberId string

+ TopologyHash uint32

+ func (*ClusterTopologyNotification) Descriptor() ([]byte, []int)

+ func (*ClusterTopologyNotification) ProtoMessage()

+ func (x *ClusterTopologyNotification) GetLeaderId() string

+ func (x *ClusterTopologyNotification) GetMemberId() string

+ func (x *ClusterTopologyNotification) GetTopologyHash() uint32

+ func (x *ClusterTopologyNotification) ProtoReflect() protoreflect.Message

+ func (x *ClusterTopologyNotification) Reset()

+ func (x *ClusterTopologyNotification) String() string

+ type Config struct

+ Address string

+ ClusterContextProducer ContextProducer

+ ClusterProvider ClusterProvider

+ GossipFanOut int

+ GossipInterval time.Duration

+ GossipMaxSend int

+ GossipRequestTimeout time.Duration

+ IdentityLookup IdentityLookup

+ Kinds map[string]*Kind

+ MaxNumberOfEventsInRequestLogThrottledPeriod int

+ MemberStrategyBuilder func(cluster *Cluster, kind string) MemberStrategy

+ Name string

+ RemoteConfig *remote.Config

+ RequestTimeoutTime time.Duration

+ RequestsLogThrottlePeriod time.Duration

+ TimeoutTime time.Duration

+ func Configure(clusterName string, clusterProvider ClusterProvider, ...) *Config

+ func (c *Config) ToClusterContextConfig() *ClusterContextConfig

+ type ConfigOption func(config *Config)

+ func WithClusterContextProducer(producer ContextProducer) ConfigOption

+ func WithKinds(kinds ...*Kind) ConfigOption

+ func WithMaxNumberOfEventsInRequestLogThrottlePeriod(maxNumber int) ConfigOption

+ func WithRequestTimeout(t time.Duration) ConfigOption

+ func WithRequestsLogThrottlePeriod(period time.Duration) ConfigOption

+ type ConsensusCheck struct

+ func NewConsensusCheck(affectedKeys []string, check GossipUpdater) ConsensusCheck

+ type ConsensusCheckBuilder struct

+ func NewConsensusCheckBuilder(key string, getValue func(*anypb.Any) interface{}) *ConsensusCheckBuilder

+ func (ccb *ConsensusCheckBuilder) AffectedKeys() []string

+ func (ccb *ConsensusCheckBuilder) Build() (ConsensusHandler, *ConsensusCheck)

+ func (ccb *ConsensusCheckBuilder) Check() ConsensusChecker

+ func (ccb *ConsensusCheckBuilder) HasConsensus(memberValues []*consensusMemberValue) (bool, uint64)

+ func (ccb *ConsensusCheckBuilder) MapToValue(valueTuple *consensusValue) func(string, *GossipMemberState) (string, string, uint64)

+ type ConsensusCheckDefinition interface

+ AffectedKeys func() map[string]struct{}

+ Check func() *ConsensusCheck

+ type ConsensusChecker func(*GossipState, map[string]empty) (bool, interface{})

+ type ConsensusChecks struct

+ func NewConsensusChecks() *ConsensusChecks

+ func (cc *ConsensusChecks) Add(id string, check *ConsensusCheck)

+ func (cc *ConsensusChecks) GetByUpdatedKey(key string) []*ConsensusCheck

+ func (cc *ConsensusChecks) GetByUpdatedKeys(keys []string) []*ConsensusCheck

+ func (cc *ConsensusChecks) Remove(id string)

+ type ConsensusHandler interface

+ GetID func() string

+ TryGetConsensus func(context.Context) (interface{}, bool)

+ type Context interface

+ Request func(identity string, kind string, message interface{}, timeout ...time.Duration) (interface{}, error)

+ type ContextProducer func(*Cluster) Context

+ type DefaultContext struct

+ func (dcc *DefaultContext) Request(identity, kind string, message interface{}, timeout ...time.Duration) (interface{}, error)

+ type GetGossipStateRequest struct

+ Key string

+ func NewGetGossipStateRequest(key string) GetGossipStateRequest

+ type GetGossipStateResponse struct

+ State map[string]*anypb.Any

+ func NewGetGossipStateResponse(state map[string]*anypb.Any) GetGossipStateResponse

+ type GetPid struct

+ ClusterIdentity *ClusterIdentity

+ type Gossip interface

+ type GossipActor struct

+ func NewGossipActor(requestTimeout time.Duration, myID string, ...) *GossipActor

+ func (ga *GossipActor) Receive(ctx actor.Context)

+ func (ga *GossipActor) ReceiveState(remoteState *GossipState, ctx actor.Context)

+ type GossipConsensusChecker interface

+ AddConsensusCheck func(id string, check *ConsensusCheck)

+ RemoveConsensusCheck func(id string)

+ type GossipCore interface

+ GetMemberStateDelta func(targetMemberID string) *MemberStateDelta

+ ReceiveState func(remoteState *GossipState) []*GossipUpdate

+ SendState func(sendStateToMember LocalStateSender)

+ UpdateClusterTopology func(topology *ClusterTopology)

+ type GossipDeltaValue struct

+ Entries []*GossipDeltaValue_GossipDeltaEntry

+ func (*GossipDeltaValue) Descriptor() ([]byte, []int)

+ func (*GossipDeltaValue) ProtoMessage()

+ func (x *GossipDeltaValue) GetEntries() []*GossipDeltaValue_GossipDeltaEntry

+ func (x *GossipDeltaValue) ProtoReflect() protoreflect.Message

+ func (x *GossipDeltaValue) Reset()

+ func (x *GossipDeltaValue) String() string

+ type GossipDeltaValue_GossipDeltaEntry struct

+ Data []byte

+ SequenceNumber int64

+ func (*GossipDeltaValue_GossipDeltaEntry) Descriptor() ([]byte, []int)

+ func (*GossipDeltaValue_GossipDeltaEntry) ProtoMessage()

+ func (x *GossipDeltaValue_GossipDeltaEntry) GetData() []byte

+ func (x *GossipDeltaValue_GossipDeltaEntry) GetSequenceNumber() int64

+ func (x *GossipDeltaValue_GossipDeltaEntry) ProtoReflect() protoreflect.Message

+ func (x *GossipDeltaValue_GossipDeltaEntry) Reset()

+ func (x *GossipDeltaValue_GossipDeltaEntry) String() string

+ type GossipKeyValue struct

+ LocalTimestampUnixMilliseconds int64

+ SequenceNumber int64

+ Value *anypb.Any

+ func (*GossipKeyValue) Descriptor() ([]byte, []int)

+ func (*GossipKeyValue) ProtoMessage()

+ func (x *GossipKeyValue) GetLocalTimestampUnixMilliseconds() int64

+ func (x *GossipKeyValue) GetSequenceNumber() int64

+ func (x *GossipKeyValue) GetValue() *anypb.Any

+ func (x *GossipKeyValue) ProtoReflect() protoreflect.Message

+ func (x *GossipKeyValue) Reset()

+ func (x *GossipKeyValue) String() string

+ type GossipKeyValues = map[string]*GossipKeyValue

+ type GossipMemberState = GossipState_GossipMemberState

+ type GossipMemberStates = map[string]*GossipMemberState

+ type GossipRequest struct

+ MemberId string

+ State *GossipState

+ func (*GossipRequest) Descriptor() ([]byte, []int)

+ func (*GossipRequest) ProtoMessage()

+ func (x *GossipRequest) GetMemberId() string

+ func (x *GossipRequest) GetState() *GossipState

+ func (x *GossipRequest) ProtoReflect() protoreflect.Message

+ func (x *GossipRequest) Reset()

+ func (x *GossipRequest) String() string

+ type GossipResponse struct

+ State *GossipState

+ func (*GossipResponse) Descriptor() ([]byte, []int)

+ func (*GossipResponse) ProtoMessage()

+ func (x *GossipResponse) GetState() *GossipState

+ func (x *GossipResponse) ProtoReflect() protoreflect.Message

+ func (x *GossipResponse) Reset()

+ func (x *GossipResponse) String() string

+ type GossipResponseAck struct

+ func (*GossipResponseAck) Descriptor() ([]byte, []int)

+ func (*GossipResponseAck) ProtoMessage()

+ func (x *GossipResponseAck) ProtoReflect() protoreflect.Message

+ func (x *GossipResponseAck) Reset()

+ func (x *GossipResponseAck) String() string

+ type GossipState struct

+ Members map[string]*GossipState_GossipMemberState

+ func (*GossipState) Descriptor() ([]byte, []int)

+ func (*GossipState) ProtoMessage()

+ func (x *GossipState) GetMembers() map[string]*GossipState_GossipMemberState

+ func (x *GossipState) ProtoReflect() protoreflect.Message

+ func (x *GossipState) Reset()

+ func (x *GossipState) String() string

+ type GossipStateStorer interface

+ GetState func(key string) map[string]*anypb.Any

+ SetState func(key string, value proto.Message)

+ type GossipState_GossipMemberState struct

+ Values map[string]*GossipKeyValue

+ func (*GossipState_GossipMemberState) Descriptor() ([]byte, []int)

+ func (*GossipState_GossipMemberState) ProtoMessage()

+ func (x *GossipState_GossipMemberState) GetValues() map[string]*GossipKeyValue

+ func (x *GossipState_GossipMemberState) ProtoReflect() protoreflect.Message

+ func (x *GossipState_GossipMemberState) Reset()

+ func (x *GossipState_GossipMemberState) String() string

+ type GossipUpdate struct

+ Key string

+ MemberID string

+ SeqNumber int64

+ Value *anypb.Any

+ type GossipUpdater func(*GossipState, map[string]empty)

+ type Gossiper struct

+ GossipActorName string

+ func (g *Gossiper) GetState(key string) (map[string]*anypb.Any, error)

+ func (g *Gossiper) RegisterConsensusCheck(key string, getValue func(*anypb.Any) interface{}) ConsensusHandler

+ func (g *Gossiper) SendState()

+ func (g *Gossiper) SetState(key string, value proto.Message)

+ func (g *Gossiper) SetStateRequest(key string, value proto.Message) error

+ func (g *Gossiper) Shutdown()

+ func (g *Gossiper) StartGossiping() error

+ type GrainCallConfig struct

+ Context actor.SenderContext

+ RetryAction func(n int)

+ RetryCount int

+ Timeout time.Duration

+ func DefaultGrainCallConfig(cluster *Cluster) *GrainCallConfig

+ func NewGrainCallOptions(cluster *Cluster) *GrainCallConfig

+ type GrainCallOption func(config *GrainCallConfig)

+ func WithContext(ctx actor.SenderContext) GrainCallOption

+ func WithRetry(count int) GrainCallOption

+ func WithRetryAction(act func(i int)) GrainCallOption

+ func WithTimeout(timeout time.Duration) GrainCallOption

+ type GrainContext interface

+ Cluster func() *Cluster

+ Identity func() string

+ Kind func() string

+ func NewGrainContext(context actor.Context, identity *ClusterIdentity, cluster *Cluster) GrainContext

+ type GrainErrorResponse struct

+ Err string

+ func (*GrainErrorResponse) Descriptor() ([]byte, []int)

+ func (*GrainErrorResponse) ProtoMessage()

+ func (x *GrainErrorResponse) GetErr() string

+ func (x *GrainErrorResponse) ProtoReflect() protoreflect.Message

+ func (x *GrainErrorResponse) Reset()

+ func (x *GrainErrorResponse) String() string

+ type GrainRequest struct

+ MessageData []byte

+ MessageTypeName string

+ MethodIndex int32

+ func (*GrainRequest) Descriptor() ([]byte, []int)

+ func (*GrainRequest) ProtoMessage()

+ func (x *GrainRequest) GetMessageData() []byte

+ func (x *GrainRequest) GetMessageTypeName() string

+ func (x *GrainRequest) GetMethodIndex() int32

+ func (x *GrainRequest) ProtoReflect() protoreflect.Message

+ func (x *GrainRequest) Reset()

+ func (x *GrainRequest) String() string

+ type GrainResponse struct

+ MessageData []byte

+ MessageTypeName string

+ func (*GrainResponse) Descriptor() ([]byte, []int)

+ func (*GrainResponse) ProtoMessage()

+ func (x *GrainResponse) GetMessageData() []byte

+ func (x *GrainResponse) GetMessageTypeName() string

+ func (x *GrainResponse) ProtoReflect() protoreflect.Message

+ func (x *GrainResponse) Reset()

+ func (x *GrainResponse) String() string

+ type IdentityHandover struct

+ Actors []*Activation

+ ChunkId int32

+ Final bool

+ Sent int32

+ Skipped int32

+ TopologyHash uint64

+ func (*IdentityHandover) Descriptor() ([]byte, []int)

+ func (*IdentityHandover) ProtoMessage()

+ func (x *IdentityHandover) GetActors() []*Activation

+ func (x *IdentityHandover) GetChunkId() int32

+ func (x *IdentityHandover) GetFinal() bool

+ func (x *IdentityHandover) GetSent() int32

+ func (x *IdentityHandover) GetSkipped() int32

+ func (x *IdentityHandover) GetTopologyHash() uint64

+ func (x *IdentityHandover) ProtoReflect() protoreflect.Message

+ func (x *IdentityHandover) Reset()

+ func (x *IdentityHandover) String() string

+ type IdentityHandoverAck struct

+ ChunkId int32

+ ProcessingState IdentityHandoverAck_State

+ TopologyHash uint64

+ func (*IdentityHandoverAck) Descriptor() ([]byte, []int)

+ func (*IdentityHandoverAck) ProtoMessage()

+ func (x *IdentityHandoverAck) GetChunkId() int32

+ func (x *IdentityHandoverAck) GetProcessingState() IdentityHandoverAck_State

+ func (x *IdentityHandoverAck) GetTopologyHash() uint64

+ func (x *IdentityHandoverAck) ProtoReflect() protoreflect.Message

+ func (x *IdentityHandoverAck) Reset()

+ func (x *IdentityHandoverAck) String() string

+ type IdentityHandoverAck_State int32

+ const IdentityHandoverAck_incorrect_topology

+ const IdentityHandoverAck_processed

+ func (IdentityHandoverAck_State) Descriptor() protoreflect.EnumDescriptor

+ func (IdentityHandoverAck_State) EnumDescriptor() ([]byte, []int)

+ func (IdentityHandoverAck_State) Type() protoreflect.EnumType

+ func (x IdentityHandoverAck_State) Enum() *IdentityHandoverAck_State

+ func (x IdentityHandoverAck_State) Number() protoreflect.EnumNumber

+ func (x IdentityHandoverAck_State) String() string

+ type IdentityHandoverRequest struct

+ Address string

+ CurrentTopology *IdentityHandoverRequest_Topology

+ DeltaTopology *IdentityHandoverRequest_Topology

+ func (*IdentityHandoverRequest) Descriptor() ([]byte, []int)

+ func (*IdentityHandoverRequest) ProtoMessage()

+ func (x *IdentityHandoverRequest) GetAddress() string

+ func (x *IdentityHandoverRequest) GetCurrentTopology() *IdentityHandoverRequest_Topology

+ func (x *IdentityHandoverRequest) GetDeltaTopology() *IdentityHandoverRequest_Topology

+ func (x *IdentityHandoverRequest) ProtoReflect() protoreflect.Message

+ func (x *IdentityHandoverRequest) Reset()

+ func (x *IdentityHandoverRequest) String() string

+ type IdentityHandoverRequest_Topology struct

+ Members []*Member

+ TopologyHash uint64

+ func (*IdentityHandoverRequest_Topology) Descriptor() ([]byte, []int)

+ func (*IdentityHandoverRequest_Topology) ProtoMessage()

+ func (x *IdentityHandoverRequest_Topology) GetMembers() []*Member

+ func (x *IdentityHandoverRequest_Topology) GetTopologyHash() uint64

+ func (x *IdentityHandoverRequest_Topology) ProtoReflect() protoreflect.Message

+ func (x *IdentityHandoverRequest_Topology) Reset()

+ func (x *IdentityHandoverRequest_Topology) String() string

+ type IdentityLookup interface

+ Get func(clusterIdentity *ClusterIdentity) *actor.PID

+ RemovePid func(clusterIdentity *ClusterIdentity, pid *actor.PID)

+ Setup func(cluster *Cluster, kinds []string, isClient bool)

+ Shutdown func()

+ type IdentityStorageLookup struct

+ Storage StorageLookup

+ func (i *IdentityStorageLookup) RemoveMember(memberID string)

+ func (id *IdentityStorageLookup) Get(clusterIdentity *ClusterIdentity) *actor.PID

+ func (id *IdentityStorageLookup) Setup(cluster *Cluster, kinds []string, isClient bool)

+ type IdentityStorageWorker struct

+ func (ids *IdentityStorageWorker) Receive(c actor.Context)

+ type Informer struct

+ func (inf *Informer) AddConsensusCheck(id string, check *ConsensusCheck)

+ func (inf *Informer) CheckConsensus(updatedKeys ...string)

+ func (inf *Informer) GetMemberStateDelta(targetMemberID string) *MemberStateDelta

+ func (inf *Informer) GetState(key string) map[string]*anypb.Any

+ func (inf *Informer) ReceiveState(remoteState *GossipState) []*GossipUpdate

+ func (inf *Informer) RemoveConsensusCheck(id string)

+ func (inf *Informer) SendState(sendStateToMember LocalStateSender)

+ func (inf *Informer) SetState(key string, message proto.Message)

+ func (inf *Informer) UpdateClusterTopology(topology *ClusterTopology)

+ type Kind struct

+ Kind string

+ Props *actor.Props

+ StrategyBuilder func(*Cluster) MemberStrategy

+ func NewKind(kind string, props *actor.Props) *Kind

+ func (k *Kind) Build(cluster *Cluster) *ActivatedKind

+ func (k *Kind) WithMemberStrategy(strategyBuilder func(*Cluster) MemberStrategy)

+ type LocalStateSender func(memberStateDelta *MemberStateDelta, member *Member)

+ type Member struct

+ Host string

+ Id string

+ Kinds []string

+ Port int32

+ func (*Member) Descriptor() ([]byte, []int)

+ func (*Member) ProtoMessage()

+ func (m *Member) Address() string

+ func (m *Member) HasKind(kind string) bool

+ func (x *Member) GetHost() string

+ func (x *Member) GetId() string

+ func (x *Member) GetKinds() []string

+ func (x *Member) GetPort() int32

+ func (x *Member) ProtoReflect() protoreflect.Message

+ func (x *Member) Reset()

+ func (x *Member) String() string

+ type MemberAvailableEvent struct

+ func (*MemberAvailableEvent) MemberStatusEvent()

+ type MemberHeartbeat struct

+ ActorStatistics *ActorStatistics

+ func (*MemberHeartbeat) Descriptor() ([]byte, []int)

+ func (*MemberHeartbeat) ProtoMessage()

+ func (x *MemberHeartbeat) GetActorStatistics() *ActorStatistics

+ func (x *MemberHeartbeat) ProtoReflect() protoreflect.Message

+ func (x *MemberHeartbeat) Reset()

+ func (x *MemberHeartbeat) String() string

+ type MemberJoinedEvent struct

+ func (*MemberJoinedEvent) MemberStatusEvent()

+ type MemberLeftEvent struct

+ func (*MemberLeftEvent) MemberStatusEvent()

+ type MemberList struct

+ func NewMemberList(cluster *Cluster) *MemberList

+ func (ml *MemberList) BroadcastEvent(message interface{}, includeSelf bool)

+ func (ml *MemberList) ContainsMemberID(memberID string) bool

+ func (ml *MemberList) GetActivatorMember(kind string, requestSourceAddress string) string

+ func (ml *MemberList) InitializeTopologyConsensus()

+ func (ml *MemberList) Length() int

+ func (ml *MemberList) Members() *MemberSet

+ func (ml *MemberList) TerminateMember(m *Member)

+ func (ml *MemberList) TopologyConsensus(ctx context.Context) (uint64, bool)

+ func (ml *MemberList) UpdateClusterTopology(members Members)

+ type MemberMeta struct

+ Host string

+ Kinds []string

+ Port int

+ func (e *MemberMeta) GetKinds() []string

+ func (e *MemberMeta) Name() string

+ type MemberRejoinedEvent struct

+ func (*MemberRejoinedEvent) MemberStatusEvent()

+ type MemberSet struct

+ func NewMemberSet(members Members) *MemberSet

+ func (ms *MemberSet) ContainsID(id string) bool

+ func (ms *MemberSet) Equals(other *MemberSet) bool

+ func (ms *MemberSet) Except(other *MemberSet) *MemberSet

+ func (ms *MemberSet) ExceptIds(ids []string) *MemberSet

+ func (ms *MemberSet) GetMemberById(id string) *Member

+ func (ms *MemberSet) Len() int

+ func (ms *MemberSet) Members() Members

+ func (ms *MemberSet) TopologyHash() uint64

+ func (ms *MemberSet) Union(other *MemberSet) *MemberSet

+ type MemberStateDelta struct

+ CommitOffsets func()

+ HasState bool

+ State *GossipState

+ TargetMemberID string

+ type MemberStatus struct

+ Alive bool

+ MemberID string

+ func (m *MemberStatus) Address() string

+ type MemberStatusEvent interface

+ GetKinds func() []string

+ MemberStatusEvent func()

+ type MemberStrategy interface

+ AddMember func(member *Member)

+ GetActivator func(senderAddress string) string

+ GetAllMembers func() Members

+ GetPartition func(key string) string

+ RemoveMember func(member *Member)

+ type MemberUnavailableEvent struct

+ func (*MemberUnavailableEvent) MemberStatusEvent()

+ type Members []*Member

+ func CopySortMembers(members Members) Members

+ func (m *Members) ToSet() *MemberSet

+ type Option func(g *Gossiper)

+ type PackedActivations struct

+ Actors []*PackedActivations_Kind

+ Address string

+ func (*PackedActivations) Descriptor() ([]byte, []int)

+ func (*PackedActivations) ProtoMessage()

+ func (x *PackedActivations) GetActors() []*PackedActivations_Kind

+ func (x *PackedActivations) GetAddress() string

+ func (x *PackedActivations) ProtoReflect() protoreflect.Message

+ func (x *PackedActivations) Reset()

+ func (x *PackedActivations) String() string

+ type PackedActivations_Activation struct

+ ActivationId string

+ Identity string

+ func (*PackedActivations_Activation) Descriptor() ([]byte, []int)

+ func (*PackedActivations_Activation) ProtoMessage()

+ func (x *PackedActivations_Activation) GetActivationId() string

+ func (x *PackedActivations_Activation) GetIdentity() string

+ func (x *PackedActivations_Activation) ProtoReflect() protoreflect.Message

+ func (x *PackedActivations_Activation) Reset()

+ func (x *PackedActivations_Activation) String() string

+ type PackedActivations_Kind struct

+ Activations []*PackedActivations_Activation

+ Name string

+ func (*PackedActivations_Kind) Descriptor() ([]byte, []int)

+ func (*PackedActivations_Kind) ProtoMessage()

+ func (x *PackedActivations_Kind) GetActivations() []*PackedActivations_Activation

+ func (x *PackedActivations_Kind) GetName() string

+ func (x *PackedActivations_Kind) ProtoReflect() protoreflect.Message

+ func (x *PackedActivations_Kind) Reset()

+ func (x *PackedActivations_Kind) String() string

+ type PidCacheValue struct

+ func NewPidCache() *PidCacheValue

+ func (c *PidCacheValue) Get(identity string, kind string) (*actor.PID, bool)

+ func (c *PidCacheValue) Remove(identity string, kind string)

+ func (c *PidCacheValue) RemoveByMember(member *Member)

+ func (c *PidCacheValue) RemoveByValue(identity string, kind string, pid *actor.PID)

+ func (c *PidCacheValue) Set(identity string, kind string, pid *actor.PID)

+ type PidResult struct

+ Pid *actor.PID

+ type ProxyActivationRequest struct

+ ClusterIdentity *ClusterIdentity

+ ReplacedActivation *actor.PID

+ func (*ProxyActivationRequest) Descriptor() ([]byte, []int)

+ func (*ProxyActivationRequest) ProtoMessage()

+ func (x *ProxyActivationRequest) GetClusterIdentity() *ClusterIdentity

+ func (x *ProxyActivationRequest) GetReplacedActivation() *actor.PID

+ func (x *ProxyActivationRequest) ProtoReflect() protoreflect.Message

+ func (x *ProxyActivationRequest) Reset()

+ func (x *ProxyActivationRequest) String() string

+ type ReadyForRebalance struct

+ TopologyHash uint64

+ func (*ReadyForRebalance) Descriptor() ([]byte, []int)

+ func (*ReadyForRebalance) ProtoMessage()

+ func (x *ReadyForRebalance) GetTopologyHash() uint64

+ func (x *ReadyForRebalance) ProtoReflect() protoreflect.Message

+ func (x *ReadyForRebalance) Reset()

+ func (x *ReadyForRebalance) String() string

+ type RebalanceCompleted struct

+ TopologyHash uint64

+ func (*RebalanceCompleted) Descriptor() ([]byte, []int)

+ func (*RebalanceCompleted) ProtoMessage()

+ func (x *RebalanceCompleted) GetTopologyHash() uint64

+ func (x *RebalanceCompleted) ProtoReflect() protoreflect.Message

+ func (x *RebalanceCompleted) Reset()

+ func (x *RebalanceCompleted) String() string

+ type RemoteIdentityHandover struct

+ Actors *PackedActivations

+ ChunkId int32

+ Final bool

+ Sent int32

+ Skipped int32

+ TopologyHash uint64

+ func (*RemoteIdentityHandover) Descriptor() ([]byte, []int)

+ func (*RemoteIdentityHandover) ProtoMessage()

+ func (x *RemoteIdentityHandover) GetActors() *PackedActivations

+ func (x *RemoteIdentityHandover) GetChunkId() int32

+ func (x *RemoteIdentityHandover) GetFinal() bool

+ func (x *RemoteIdentityHandover) GetSent() int32

+ func (x *RemoteIdentityHandover) GetSkipped() int32

+ func (x *RemoteIdentityHandover) GetTopologyHash() uint64

+ func (x *RemoteIdentityHandover) ProtoReflect() protoreflect.Message

+ func (x *RemoteIdentityHandover) Reset()

+ func (x *RemoteIdentityHandover) String() string

+ type RemoveConsensusCheck struct

+ ID string

+ func NewRemoveConsensusCheck(id string) RemoveConsensusCheck

+ type Rendezvous struct

+ func NewRendezvous() *Rendezvous

+ func (r *Rendezvous) GetByClusterIdentity(ci *ClusterIdentity) string

+ func (r *Rendezvous) GetByIdentity(identity string) string

+ func (r *Rendezvous) UpdateMembers(members Members)

+ type SendGossipStateRequest struct

+ type SendGossipStateResponse struct

+ type SetGossipStateKey struct

+ Key string

+ Value proto.Message

+ func NewGossipStateKey(key string, value proto.Message) SetGossipStateKey

+ type SetGossipStateResponse struct

+ type SimpleRoundRobin struct

+ func NewSimpleRoundRobin(memberStrategy MemberStrategy) *SimpleRoundRobin

+ func (r *SimpleRoundRobin) GetByRoundRobin() string

+ type SpawnLock struct

+ ClusterIdentity *ClusterIdentity

+ LockID string

+ type StorageLookup interface

+ RemoveActivation func(pid *SpawnLock)

+ RemoveLock func(spawnLock SpawnLock)

+ RemoveMemberId func(memberID string)

+ StoreActivation func(memberID string, spawnLock *SpawnLock, pid *actor.PID)

+ TryAcquireLock func(clusterIdentity *ClusterIdentity) *SpawnLock

+ TryGetExistingActivation func(clusterIdentity *ClusterIdentity) *StoredActivation

+ WaitForActivation func(clusterIdentity *ClusterIdentity) *StoredActivation

+ type StoredActivation struct

+ MemberID string

+ Pid string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL