Documentation ¶
Index ¶
- Constants
- Variables
- func NewGossipConsensusHandler() *gossipConsensusHandler
- func SetLogLevel(level log.Level)
- type Activation
- func (*Activation) Descriptor() ([]byte, []int)
- func (this *Activation) Equal(that interface{}) bool
- func (m *Activation) GetClusterIdentity() *ClusterIdentity
- func (m *Activation) GetEventId() uint64
- func (m *Activation) GetPid() *actor.PID
- func (m *Activation) Marshal() (dAtA []byte, err error)
- func (m *Activation) MarshalTo(dAtA []byte) (int, error)
- func (m *Activation) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Activation) ProtoMessage()
- func (m *Activation) Reset()
- func (m *Activation) Size() (n int)
- func (this *Activation) String() string
- func (m *Activation) Unmarshal(dAtA []byte) error
- func (m *Activation) XXX_DiscardUnknown()
- func (m *Activation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Activation) XXX_Merge(src proto.Message)
- func (m *Activation) XXX_Size() int
- func (m *Activation) XXX_Unmarshal(b []byte) error
- type ActivationRequest
- func (*ActivationRequest) Descriptor() ([]byte, []int)
- func (this *ActivationRequest) Equal(that interface{}) bool
- func (m *ActivationRequest) GetClusterIdentity() *ClusterIdentity
- func (m *ActivationRequest) GetRequestId() string
- func (m *ActivationRequest) Marshal() (dAtA []byte, err error)
- func (m *ActivationRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ActivationRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ActivationRequest) ProtoMessage()
- func (m *ActivationRequest) Reset()
- func (m *ActivationRequest) Size() (n int)
- func (this *ActivationRequest) String() string
- func (m *ActivationRequest) Unmarshal(dAtA []byte) error
- func (m *ActivationRequest) XXX_DiscardUnknown()
- func (m *ActivationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ActivationRequest) XXX_Merge(src proto.Message)
- func (m *ActivationRequest) XXX_Size() int
- func (m *ActivationRequest) XXX_Unmarshal(b []byte) error
- type ActivationResponse
- func (*ActivationResponse) Descriptor() ([]byte, []int)
- func (this *ActivationResponse) Equal(that interface{}) bool
- func (m *ActivationResponse) GetPid() *actor.PID
- func (m *ActivationResponse) GetStatusCode() uint32
- func (m *ActivationResponse) Marshal() (dAtA []byte, err error)
- func (m *ActivationResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ActivationResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ActivationResponse) ProtoMessage()
- func (m *ActivationResponse) Reset()
- func (m *ActivationResponse) Size() (n int)
- func (this *ActivationResponse) String() string
- func (m *ActivationResponse) Unmarshal(dAtA []byte) error
- func (m *ActivationResponse) XXX_DiscardUnknown()
- func (m *ActivationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ActivationResponse) XXX_Merge(src proto.Message)
- func (m *ActivationResponse) XXX_Size() int
- func (m *ActivationResponse) XXX_Unmarshal(b []byte) error
- type ActivationTerminated
- func (*ActivationTerminated) Descriptor() ([]byte, []int)
- func (this *ActivationTerminated) Equal(that interface{}) bool
- func (m *ActivationTerminated) GetClusterIdentity() *ClusterIdentity
- func (m *ActivationTerminated) GetEventId() uint64
- func (m *ActivationTerminated) GetPid() *actor.PID
- func (m *ActivationTerminated) Marshal() (dAtA []byte, err error)
- func (m *ActivationTerminated) MarshalTo(dAtA []byte) (int, error)
- func (m *ActivationTerminated) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ActivationTerminated) ProtoMessage()
- func (m *ActivationTerminated) Reset()
- func (m *ActivationTerminated) Size() (n int)
- func (this *ActivationTerminated) String() string
- func (m *ActivationTerminated) Unmarshal(dAtA []byte) error
- func (m *ActivationTerminated) XXX_DiscardUnknown()
- func (m *ActivationTerminated) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ActivationTerminated) XXX_Merge(src proto.Message)
- func (m *ActivationTerminated) XXX_Size() int
- func (m *ActivationTerminated) XXX_Unmarshal(b []byte) error
- type AddConsensusCheck
- type Cluster
- func (c *Cluster) Call(name string, kind string, msg interface{}, callopts ...*GrainCallOptions) (interface{}, error)
- func (c *Cluster) Get(name string, kind string) (*actor.PID, remote.ResponseStatusCode)
- func (c *Cluster) GetBlockedMembers() map[string]struct{}
- func (c *Cluster) GetClusterKind(kind string) *actor.Props
- func (c *Cluster) GetClusterKinds() []string
- func (c *Cluster) GetV1(name string, kind string) (*actor.PID, remote.ResponseStatusCode)
- func (c *Cluster) Id() extensions.ExtensionId
- func (c *Cluster) Shutdown(graceful bool)
- func (c *Cluster) Start()
- func (c *Cluster) StartClient()
- type ClusterIdentity
- func (ci *ClusterIdentity) AsKey() string
- func (*ClusterIdentity) Descriptor() ([]byte, []int)
- func (this *ClusterIdentity) Equal(that interface{}) bool
- func (m *ClusterIdentity) GetIdentity() string
- func (m *ClusterIdentity) GetKind() string
- func (m *ClusterIdentity) Marshal() (dAtA []byte, err error)
- func (m *ClusterIdentity) MarshalTo(dAtA []byte) (int, error)
- func (m *ClusterIdentity) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ClusterIdentity) ProtoMessage()
- func (m *ClusterIdentity) Reset()
- func (m *ClusterIdentity) Size() (n int)
- func (this *ClusterIdentity) String() string
- func (m *ClusterIdentity) Unmarshal(dAtA []byte) error
- func (m *ClusterIdentity) XXX_DiscardUnknown()
- func (m *ClusterIdentity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClusterIdentity) XXX_Merge(src proto.Message)
- func (m *ClusterIdentity) XXX_Size() int
- func (m *ClusterIdentity) XXX_Unmarshal(b []byte) error
- type ClusterInit
- type ClusterProvider
- type ClusterState
- type ClusterTopology
- func (*ClusterTopology) Descriptor() ([]byte, []int)
- func (this *ClusterTopology) Equal(that interface{}) bool
- func (m *ClusterTopology) GetBanned() []*Member
- func (m *ClusterTopology) GetEventId() uint64
- func (m *ClusterTopology) GetJoined() []*Member
- func (m *ClusterTopology) GetLeft() []*Member
- func (m *ClusterTopology) GetMembers() []*Member
- func (m *ClusterTopology) Marshal() (dAtA []byte, err error)
- func (m *ClusterTopology) MarshalTo(dAtA []byte) (int, error)
- func (m *ClusterTopology) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ClusterTopology) ProtoMessage()
- func (m *ClusterTopology) Reset()
- func (m *ClusterTopology) Size() (n int)
- func (this *ClusterTopology) String() string
- func (m *ClusterTopology) Unmarshal(dAtA []byte) error
- func (m *ClusterTopology) XXX_DiscardUnknown()
- func (m *ClusterTopology) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClusterTopology) XXX_Merge(src proto.Message)
- func (m *ClusterTopology) XXX_Size() int
- func (m *ClusterTopology) XXX_Unmarshal(b []byte) error
- type ClusterTopologyEventV2
- type Config
- type ConsensusCheck
- type 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
- type ConsensusChecker
- type ConsensusChecks
- type ConsensusHandler
- type GetGossipStateRequest
- type GetGossipStateResponse
- type Gossip
- type GossipActor
- type GossipConsensusChecker
- type GossipCore
- type GossipDeltaValue
- func (*GossipDeltaValue) Descriptor() ([]byte, []int)
- func (this *GossipDeltaValue) Equal(that interface{}) bool
- func (m *GossipDeltaValue) GetEntries() []*GossipDeltaValue_GossipDeltaEntry
- func (this *GossipDeltaValue) GoString() string
- func (m *GossipDeltaValue) Marshal() (dAtA []byte, err error)
- func (m *GossipDeltaValue) MarshalTo(dAtA []byte) (int, error)
- func (m *GossipDeltaValue) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GossipDeltaValue) ProtoMessage()
- func (m *GossipDeltaValue) Reset()
- func (m *GossipDeltaValue) Size() (n int)
- func (this *GossipDeltaValue) String() string
- func (m *GossipDeltaValue) Unmarshal(dAtA []byte) error
- func (m *GossipDeltaValue) XXX_DiscardUnknown()
- func (m *GossipDeltaValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GossipDeltaValue) XXX_Merge(src proto.Message)
- func (m *GossipDeltaValue) XXX_Size() int
- func (m *GossipDeltaValue) XXX_Unmarshal(b []byte) error
- type GossipDeltaValue_GossipDeltaEntry
- func (*GossipDeltaValue_GossipDeltaEntry) Descriptor() ([]byte, []int)
- func (this *GossipDeltaValue_GossipDeltaEntry) Equal(that interface{}) bool
- func (m *GossipDeltaValue_GossipDeltaEntry) GetData() []byte
- func (m *GossipDeltaValue_GossipDeltaEntry) GetSequenceNumber() int64
- func (this *GossipDeltaValue_GossipDeltaEntry) GoString() string
- func (m *GossipDeltaValue_GossipDeltaEntry) Marshal() (dAtA []byte, err error)
- func (m *GossipDeltaValue_GossipDeltaEntry) MarshalTo(dAtA []byte) (int, error)
- func (m *GossipDeltaValue_GossipDeltaEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GossipDeltaValue_GossipDeltaEntry) ProtoMessage()
- func (m *GossipDeltaValue_GossipDeltaEntry) Reset()
- func (m *GossipDeltaValue_GossipDeltaEntry) Size() (n int)
- func (this *GossipDeltaValue_GossipDeltaEntry) String() string
- func (m *GossipDeltaValue_GossipDeltaEntry) Unmarshal(dAtA []byte) error
- func (m *GossipDeltaValue_GossipDeltaEntry) XXX_DiscardUnknown()
- func (m *GossipDeltaValue_GossipDeltaEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GossipDeltaValue_GossipDeltaEntry) XXX_Merge(src proto.Message)
- func (m *GossipDeltaValue_GossipDeltaEntry) XXX_Size() int
- func (m *GossipDeltaValue_GossipDeltaEntry) XXX_Unmarshal(b []byte) error
- type GossipKeyValue
- func (*GossipKeyValue) Descriptor() ([]byte, []int)
- func (this *GossipKeyValue) Equal(that interface{}) bool
- func (m *GossipKeyValue) GetSequenceNumber() int64
- func (m *GossipKeyValue) GetValue() *types.Any
- func (this *GossipKeyValue) GoString() string
- func (m *GossipKeyValue) Marshal() (dAtA []byte, err error)
- func (m *GossipKeyValue) MarshalTo(dAtA []byte) (int, error)
- func (m *GossipKeyValue) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GossipKeyValue) ProtoMessage()
- func (m *GossipKeyValue) Reset()
- func (m *GossipKeyValue) Size() (n int)
- func (this *GossipKeyValue) String() string
- func (m *GossipKeyValue) Unmarshal(dAtA []byte) error
- func (m *GossipKeyValue) XXX_DiscardUnknown()
- func (m *GossipKeyValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GossipKeyValue) XXX_Merge(src proto.Message)
- func (m *GossipKeyValue) XXX_Size() int
- func (m *GossipKeyValue) XXX_Unmarshal(b []byte) error
- type GossipMemberState
- type GossipRequest
- func (*GossipRequest) Descriptor() ([]byte, []int)
- func (this *GossipRequest) Equal(that interface{}) bool
- func (m *GossipRequest) GetMemberId() string
- func (m *GossipRequest) GetState() *GossipState
- func (this *GossipRequest) GoString() string
- func (m *GossipRequest) Marshal() (dAtA []byte, err error)
- func (m *GossipRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GossipRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GossipRequest) ProtoMessage()
- func (m *GossipRequest) Reset()
- func (m *GossipRequest) Size() (n int)
- func (this *GossipRequest) String() string
- func (m *GossipRequest) Unmarshal(dAtA []byte) error
- func (m *GossipRequest) XXX_DiscardUnknown()
- func (m *GossipRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GossipRequest) XXX_Merge(src proto.Message)
- func (m *GossipRequest) XXX_Size() int
- func (m *GossipRequest) XXX_Unmarshal(b []byte) error
- type GossipResponse
- func (*GossipResponse) Descriptor() ([]byte, []int)
- func (this *GossipResponse) Equal(that interface{}) bool
- func (m *GossipResponse) GetState() *GossipState
- func (this *GossipResponse) GoString() string
- func (m *GossipResponse) Marshal() (dAtA []byte, err error)
- func (m *GossipResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GossipResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GossipResponse) ProtoMessage()
- func (m *GossipResponse) Reset()
- func (m *GossipResponse) Size() (n int)
- func (this *GossipResponse) String() string
- func (m *GossipResponse) Unmarshal(dAtA []byte) error
- func (m *GossipResponse) XXX_DiscardUnknown()
- func (m *GossipResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GossipResponse) XXX_Merge(src proto.Message)
- func (m *GossipResponse) XXX_Size() int
- func (m *GossipResponse) XXX_Unmarshal(b []byte) error
- type GossipResponseAck
- func (*GossipResponseAck) Descriptor() ([]byte, []int)
- func (this *GossipResponseAck) Equal(that interface{}) bool
- func (this *GossipResponseAck) GoString() string
- func (m *GossipResponseAck) Marshal() (dAtA []byte, err error)
- func (m *GossipResponseAck) MarshalTo(dAtA []byte) (int, error)
- func (m *GossipResponseAck) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GossipResponseAck) ProtoMessage()
- func (m *GossipResponseAck) Reset()
- func (m *GossipResponseAck) Size() (n int)
- func (this *GossipResponseAck) String() string
- func (m *GossipResponseAck) Unmarshal(dAtA []byte) error
- func (m *GossipResponseAck) XXX_DiscardUnknown()
- func (m *GossipResponseAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GossipResponseAck) XXX_Merge(src proto.Message)
- func (m *GossipResponseAck) XXX_Size() int
- func (m *GossipResponseAck) XXX_Unmarshal(b []byte) error
- type GossipState
- func (*GossipState) Descriptor() ([]byte, []int)
- func (this *GossipState) Equal(that interface{}) bool
- func (m *GossipState) GetMembers() map[string]*GossipState_GossipMemberState
- func (this *GossipState) GoString() string
- func (m *GossipState) Marshal() (dAtA []byte, err error)
- func (m *GossipState) MarshalTo(dAtA []byte) (int, error)
- func (m *GossipState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GossipState) ProtoMessage()
- func (m *GossipState) Reset()
- func (m *GossipState) Size() (n int)
- func (this *GossipState) String() string
- func (m *GossipState) Unmarshal(dAtA []byte) error
- func (m *GossipState) XXX_DiscardUnknown()
- func (m *GossipState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GossipState) XXX_Merge(src proto.Message)
- func (m *GossipState) XXX_Size() int
- func (m *GossipState) XXX_Unmarshal(b []byte) error
- type GossipStateStorer
- type GossipState_GossipMemberState
- func (*GossipState_GossipMemberState) Descriptor() ([]byte, []int)
- func (this *GossipState_GossipMemberState) Equal(that interface{}) bool
- func (m *GossipState_GossipMemberState) GetValues() map[string]*GossipKeyValue
- func (this *GossipState_GossipMemberState) GoString() string
- func (m *GossipState_GossipMemberState) Marshal() (dAtA []byte, err error)
- func (m *GossipState_GossipMemberState) MarshalTo(dAtA []byte) (int, error)
- func (m *GossipState_GossipMemberState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GossipState_GossipMemberState) ProtoMessage()
- func (m *GossipState_GossipMemberState) Reset()
- func (m *GossipState_GossipMemberState) Size() (n int)
- func (this *GossipState_GossipMemberState) String() string
- func (m *GossipState_GossipMemberState) Unmarshal(dAtA []byte) error
- func (m *GossipState_GossipMemberState) XXX_DiscardUnknown()
- func (m *GossipState_GossipMemberState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GossipState_GossipMemberState) XXX_Merge(src proto.Message)
- func (m *GossipState_GossipMemberState) XXX_Size() int
- func (m *GossipState_GossipMemberState) XXX_Unmarshal(b []byte) error
- type GossipUpdate
- type GossipUpdater
- type Gossiper
- func (g *Gossiper) GetState(key string) (map[string]*types.Any, error)
- func (g *Gossiper) RegisterConsensusCheck(key string, getValue func(*types.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 Grain
- type GrainCallOptions
- type GrainContext
- type GrainErrorResponse
- func (*GrainErrorResponse) Descriptor() ([]byte, []int)
- func (this *GrainErrorResponse) Equal(that interface{}) bool
- func (m *GrainErrorResponse) GetCode() int32
- func (m *GrainErrorResponse) GetErr() string
- func (m *GrainErrorResponse) Marshal() (dAtA []byte, err error)
- func (m *GrainErrorResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GrainErrorResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GrainErrorResponse) ProtoMessage()
- func (m *GrainErrorResponse) Reset()
- func (m *GrainErrorResponse) Size() (n int)
- func (this *GrainErrorResponse) String() string
- func (m *GrainErrorResponse) Unmarshal(dAtA []byte) error
- func (m *GrainErrorResponse) XXX_DiscardUnknown()
- func (m *GrainErrorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GrainErrorResponse) XXX_Merge(src proto.Message)
- func (m *GrainErrorResponse) XXX_Size() int
- func (m *GrainErrorResponse) XXX_Unmarshal(b []byte) error
- type GrainMeta
- type GrainRequest
- func (*GrainRequest) Descriptor() ([]byte, []int)
- func (this *GrainRequest) Equal(that interface{}) bool
- func (m *GrainRequest) GetMessageData() []byte
- func (m *GrainRequest) GetMethodIndex() int32
- func (m *GrainRequest) Marshal() (dAtA []byte, err error)
- func (m *GrainRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GrainRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GrainRequest) ProtoMessage()
- func (m *GrainRequest) Reset()
- func (m *GrainRequest) Size() (n int)
- func (this *GrainRequest) String() string
- func (m *GrainRequest) Unmarshal(dAtA []byte) error
- func (m *GrainRequest) XXX_DiscardUnknown()
- func (m *GrainRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GrainRequest) XXX_Merge(src proto.Message)
- func (m *GrainRequest) XXX_Size() int
- func (m *GrainRequest) XXX_Unmarshal(b []byte) error
- type GrainResponse
- func (*GrainResponse) Descriptor() ([]byte, []int)
- func (this *GrainResponse) Equal(that interface{}) bool
- func (m *GrainResponse) GetMessageData() []byte
- func (m *GrainResponse) Marshal() (dAtA []byte, err error)
- func (m *GrainResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GrainResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GrainResponse) ProtoMessage()
- func (m *GrainResponse) Reset()
- func (m *GrainResponse) Size() (n int)
- func (this *GrainResponse) String() string
- func (m *GrainResponse) Unmarshal(dAtA []byte) error
- func (m *GrainResponse) XXX_DiscardUnknown()
- func (m *GrainResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GrainResponse) XXX_Merge(src proto.Message)
- func (m *GrainResponse) XXX_Size() int
- func (m *GrainResponse) XXX_Unmarshal(b []byte) error
- type HeartbeatRequest
- func (*HeartbeatRequest) Descriptor() ([]byte, []int)
- func (this *HeartbeatRequest) Equal(that interface{}) bool
- func (m *HeartbeatRequest) Marshal() (dAtA []byte, err error)
- func (m *HeartbeatRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *HeartbeatRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*HeartbeatRequest) ProtoMessage()
- func (m *HeartbeatRequest) Reset()
- func (m *HeartbeatRequest) Size() (n int)
- func (this *HeartbeatRequest) String() string
- func (m *HeartbeatRequest) Unmarshal(dAtA []byte) error
- func (m *HeartbeatRequest) XXX_DiscardUnknown()
- func (m *HeartbeatRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HeartbeatRequest) XXX_Merge(src proto.Message)
- func (m *HeartbeatRequest) XXX_Size() int
- func (m *HeartbeatRequest) XXX_Unmarshal(b []byte) error
- type HeartbeatResponse
- func (*HeartbeatResponse) Descriptor() ([]byte, []int)
- func (this *HeartbeatResponse) Equal(that interface{}) bool
- func (m *HeartbeatResponse) GetActorCount() uint32
- func (m *HeartbeatResponse) Marshal() (dAtA []byte, err error)
- func (m *HeartbeatResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *HeartbeatResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*HeartbeatResponse) ProtoMessage()
- func (m *HeartbeatResponse) Reset()
- func (m *HeartbeatResponse) Size() (n int)
- func (this *HeartbeatResponse) String() string
- func (m *HeartbeatResponse) Unmarshal(dAtA []byte) error
- func (m *HeartbeatResponse) XXX_DiscardUnknown()
- func (m *HeartbeatResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HeartbeatResponse) XXX_Merge(src proto.Message)
- func (m *HeartbeatResponse) XXX_Size() int
- func (m *HeartbeatResponse) XXX_Unmarshal(b []byte) error
- type IdentityHandoverRequest
- func (*IdentityHandoverRequest) Descriptor() ([]byte, []int)
- func (this *IdentityHandoverRequest) Equal(that interface{}) bool
- func (m *IdentityHandoverRequest) GetAddress() string
- func (m *IdentityHandoverRequest) GetEventId() uint64
- func (m *IdentityHandoverRequest) GetMembers() []*Member
- func (m *IdentityHandoverRequest) Marshal() (dAtA []byte, err error)
- func (m *IdentityHandoverRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *IdentityHandoverRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*IdentityHandoverRequest) ProtoMessage()
- func (m *IdentityHandoverRequest) Reset()
- func (m *IdentityHandoverRequest) Size() (n int)
- func (this *IdentityHandoverRequest) String() string
- func (m *IdentityHandoverRequest) Unmarshal(dAtA []byte) error
- func (m *IdentityHandoverRequest) XXX_DiscardUnknown()
- func (m *IdentityHandoverRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IdentityHandoverRequest) XXX_Merge(src proto.Message)
- func (m *IdentityHandoverRequest) XXX_Size() int
- func (m *IdentityHandoverRequest) XXX_Unmarshal(b []byte) error
- type IdentityHandoverResponse
- func (*IdentityHandoverResponse) Descriptor() ([]byte, []int)
- func (this *IdentityHandoverResponse) Equal(that interface{}) bool
- func (m *IdentityHandoverResponse) GetActors() []*Activation
- func (m *IdentityHandoverResponse) Marshal() (dAtA []byte, err error)
- func (m *IdentityHandoverResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *IdentityHandoverResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*IdentityHandoverResponse) ProtoMessage()
- func (m *IdentityHandoverResponse) Reset()
- func (m *IdentityHandoverResponse) Size() (n int)
- func (this *IdentityHandoverResponse) String() string
- func (m *IdentityHandoverResponse) Unmarshal(dAtA []byte) error
- func (m *IdentityHandoverResponse) XXX_DiscardUnknown()
- func (m *IdentityHandoverResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IdentityHandoverResponse) XXX_Merge(src proto.Message)
- func (m *IdentityHandoverResponse) XXX_Size() int
- func (m *IdentityHandoverResponse) XXX_Unmarshal(b []byte) error
- type IdentityLookup
- type Informer
- 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]*types.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
- type LocalStateSender
- type Member
- func (m *Member) Address() string
- func (*Member) Descriptor() ([]byte, []int)
- func (this *Member) Equal(that interface{}) bool
- func (m *Member) GetHost() string
- func (m *Member) GetId() string
- func (m *Member) GetKinds() []string
- func (m *Member) GetPort() int32
- func (m *Member) Marshal() (dAtA []byte, err error)
- func (m *Member) MarshalTo(dAtA []byte) (int, error)
- func (m *Member) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Member) ProtoMessage()
- func (m *Member) Reset()
- func (m *Member) Size() (n int)
- func (this *Member) String() string
- func (m *Member) Unmarshal(dAtA []byte) error
- func (m *Member) XXX_DiscardUnknown()
- func (m *Member) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Member) XXX_Merge(src proto.Message)
- func (m *Member) XXX_Size() int
- func (m *Member) XXX_Unmarshal(b []byte) error
- type MemberAvailableEvent
- type MemberHeartbeat
- func (*MemberHeartbeat) Descriptor() ([]byte, []int)
- func (this *MemberHeartbeat) Equal(that interface{}) bool
- func (m *MemberHeartbeat) Marshal() (dAtA []byte, err error)
- func (m *MemberHeartbeat) MarshalTo(dAtA []byte) (int, error)
- func (m *MemberHeartbeat) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MemberHeartbeat) ProtoMessage()
- func (m *MemberHeartbeat) Reset()
- func (m *MemberHeartbeat) Size() (n int)
- func (this *MemberHeartbeat) String() string
- func (m *MemberHeartbeat) Unmarshal(dAtA []byte) error
- func (m *MemberHeartbeat) XXX_DiscardUnknown()
- func (m *MemberHeartbeat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MemberHeartbeat) XXX_Merge(src proto.Message)
- func (m *MemberHeartbeat) XXX_Size() int
- func (m *MemberHeartbeat) XXX_Unmarshal(b []byte) error
- type MemberJoinedEvent
- type MemberLeftEvent
- type MemberList
- func (ml *MemberList) BroadcastEvent(message interface{})
- func (ml *MemberList) ContainsMemberID(memberID string) bool
- func (ml *MemberList) InitializeTopologyConsensus()
- func (ml *MemberList) Length() int
- func (ml *MemberList) TopologyConsensus(ctx context.Context) (uint64, bool)
- func (ml *MemberList) UpdateClusterTopology(members []*Member, eventId uint64)
- type MemberMeta
- type MemberRejoinedEvent
- type MemberStateDelta
- type MemberStatus
- type MemberStatusEvent
- type MemberStrategy
- type MemberUnavailableEvent
- type Option
- type PartitionKind
- type PartitionManager
- type RemoveConsensusCheck
- type Rendezvous
- type RendezvousV2
- type SendGossipStateRequest
- type SendGossipStateResponse
- type SetGossipStateKey
- type SetGossipStateResponse
- type SimpleRoundRobin
- type TakeOwnership
- func (*TakeOwnership) Descriptor() ([]byte, []int)
- func (this *TakeOwnership) Equal(that interface{}) bool
- func (m *TakeOwnership) GetName() string
- func (m *TakeOwnership) GetPid() *actor.PID
- func (m *TakeOwnership) Marshal() (dAtA []byte, err error)
- func (m *TakeOwnership) MarshalTo(dAtA []byte) (int, error)
- func (m *TakeOwnership) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TakeOwnership) ProtoMessage()
- func (m *TakeOwnership) Reset()
- func (m *TakeOwnership) Size() (n int)
- func (this *TakeOwnership) String() string
- func (m *TakeOwnership) Unmarshal(dAtA []byte) error
- func (m *TakeOwnership) XXX_DiscardUnknown()
- func (m *TakeOwnership) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TakeOwnership) XXX_Merge(src proto.Message)
- func (m *TakeOwnership) XXX_Size() int
- func (m *TakeOwnership) XXX_Unmarshal(b []byte) error
- type TopologyEvent
Constants ¶
const ( TopologyKey string = "topology" HearthbeatKey string = "heathbeat" )
const ( ActorNameIdentity = "partition-identity" ActorNamePlacement = "partition-activator" )
const DefaultGossipActorName string = "gossip"
Variables ¶
Functions ¶
func NewGossipConsensusHandler ¶
func NewGossipConsensusHandler() *gossipConsensusHandler
func SetLogLevel ¶
SetLogLevel sets the log level for the logger.
SetLogLevel is safe to call concurrently
Types ¶
type Activation ¶
type Activation struct { Pid *actor.PID `protobuf:"bytes,1,opt,name=pid,proto3" json:"pid,omitempty"` ClusterIdentity *ClusterIdentity `protobuf:"bytes,2,opt,name=cluster_identity,json=clusterIdentity,proto3" json:"cluster_identity,omitempty"` EventId uint64 `protobuf:"varint,3,opt,name=eventId,proto3" json:"eventId,omitempty"` }
func (*Activation) Descriptor ¶
func (*Activation) Descriptor() ([]byte, []int)
func (*Activation) Equal ¶
func (this *Activation) Equal(that interface{}) bool
func (*Activation) GetClusterIdentity ¶
func (m *Activation) GetClusterIdentity() *ClusterIdentity
func (*Activation) GetEventId ¶
func (m *Activation) GetEventId() uint64
func (*Activation) GetPid ¶
func (m *Activation) GetPid() *actor.PID
func (*Activation) Marshal ¶
func (m *Activation) Marshal() (dAtA []byte, err error)
func (*Activation) MarshalToSizedBuffer ¶
func (m *Activation) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Activation) ProtoMessage ¶
func (*Activation) ProtoMessage()
func (*Activation) Reset ¶
func (m *Activation) Reset()
func (*Activation) Size ¶
func (m *Activation) Size() (n int)
func (*Activation) String ¶
func (this *Activation) String() string
func (*Activation) Unmarshal ¶
func (m *Activation) Unmarshal(dAtA []byte) error
func (*Activation) XXX_DiscardUnknown ¶
func (m *Activation) XXX_DiscardUnknown()
func (*Activation) XXX_Marshal ¶
func (m *Activation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Activation) XXX_Merge ¶
func (m *Activation) XXX_Merge(src proto.Message)
func (*Activation) XXX_Size ¶
func (m *Activation) XXX_Size() int
func (*Activation) XXX_Unmarshal ¶
func (m *Activation) XXX_Unmarshal(b []byte) error
type ActivationRequest ¶
type ActivationRequest struct { ClusterIdentity *ClusterIdentity `protobuf:"bytes,1,opt,name=cluster_identity,json=clusterIdentity,proto3" json:"cluster_identity,omitempty"` RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` }
func (*ActivationRequest) Descriptor ¶
func (*ActivationRequest) Descriptor() ([]byte, []int)
func (*ActivationRequest) Equal ¶
func (this *ActivationRequest) Equal(that interface{}) bool
func (*ActivationRequest) GetClusterIdentity ¶
func (m *ActivationRequest) GetClusterIdentity() *ClusterIdentity
func (*ActivationRequest) GetRequestId ¶
func (m *ActivationRequest) GetRequestId() string
func (*ActivationRequest) Marshal ¶
func (m *ActivationRequest) Marshal() (dAtA []byte, err error)
func (*ActivationRequest) MarshalTo ¶
func (m *ActivationRequest) MarshalTo(dAtA []byte) (int, error)
func (*ActivationRequest) MarshalToSizedBuffer ¶
func (m *ActivationRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ActivationRequest) ProtoMessage ¶
func (*ActivationRequest) ProtoMessage()
func (*ActivationRequest) Reset ¶
func (m *ActivationRequest) Reset()
func (*ActivationRequest) Size ¶
func (m *ActivationRequest) Size() (n int)
func (*ActivationRequest) String ¶
func (this *ActivationRequest) String() string
func (*ActivationRequest) Unmarshal ¶
func (m *ActivationRequest) Unmarshal(dAtA []byte) error
func (*ActivationRequest) XXX_DiscardUnknown ¶
func (m *ActivationRequest) XXX_DiscardUnknown()
func (*ActivationRequest) XXX_Marshal ¶
func (m *ActivationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ActivationRequest) XXX_Merge ¶
func (m *ActivationRequest) XXX_Merge(src proto.Message)
func (*ActivationRequest) XXX_Size ¶
func (m *ActivationRequest) XXX_Size() int
func (*ActivationRequest) XXX_Unmarshal ¶
func (m *ActivationRequest) XXX_Unmarshal(b []byte) error
type ActivationResponse ¶
type ActivationResponse struct { Pid *actor.PID `protobuf:"bytes,1,opt,name=pid,proto3" json:"pid,omitempty"` StatusCode uint32 `protobuf:"varint,2,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"` }
func (*ActivationResponse) Descriptor ¶
func (*ActivationResponse) Descriptor() ([]byte, []int)
func (*ActivationResponse) Equal ¶
func (this *ActivationResponse) Equal(that interface{}) bool
func (*ActivationResponse) GetPid ¶
func (m *ActivationResponse) GetPid() *actor.PID
func (*ActivationResponse) GetStatusCode ¶
func (m *ActivationResponse) GetStatusCode() uint32
func (*ActivationResponse) Marshal ¶
func (m *ActivationResponse) Marshal() (dAtA []byte, err error)
func (*ActivationResponse) MarshalTo ¶
func (m *ActivationResponse) MarshalTo(dAtA []byte) (int, error)
func (*ActivationResponse) MarshalToSizedBuffer ¶
func (m *ActivationResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ActivationResponse) ProtoMessage ¶
func (*ActivationResponse) ProtoMessage()
func (*ActivationResponse) Reset ¶
func (m *ActivationResponse) Reset()
func (*ActivationResponse) Size ¶
func (m *ActivationResponse) Size() (n int)
func (*ActivationResponse) String ¶
func (this *ActivationResponse) String() string
func (*ActivationResponse) Unmarshal ¶
func (m *ActivationResponse) Unmarshal(dAtA []byte) error
func (*ActivationResponse) XXX_DiscardUnknown ¶
func (m *ActivationResponse) XXX_DiscardUnknown()
func (*ActivationResponse) XXX_Marshal ¶
func (m *ActivationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ActivationResponse) XXX_Merge ¶
func (m *ActivationResponse) XXX_Merge(src proto.Message)
func (*ActivationResponse) XXX_Size ¶
func (m *ActivationResponse) XXX_Size() int
func (*ActivationResponse) XXX_Unmarshal ¶
func (m *ActivationResponse) XXX_Unmarshal(b []byte) error
type ActivationTerminated ¶
type ActivationTerminated struct { Pid *actor.PID `protobuf:"bytes,1,opt,name=pid,proto3" json:"pid,omitempty"` ClusterIdentity *ClusterIdentity `protobuf:"bytes,2,opt,name=cluster_identity,json=clusterIdentity,proto3" json:"cluster_identity,omitempty"` EventId uint64 `protobuf:"varint,3,opt,name=eventId,proto3" json:"eventId,omitempty"` }
func (*ActivationTerminated) Descriptor ¶
func (*ActivationTerminated) Descriptor() ([]byte, []int)
func (*ActivationTerminated) Equal ¶
func (this *ActivationTerminated) Equal(that interface{}) bool
func (*ActivationTerminated) GetClusterIdentity ¶
func (m *ActivationTerminated) GetClusterIdentity() *ClusterIdentity
func (*ActivationTerminated) GetEventId ¶
func (m *ActivationTerminated) GetEventId() uint64
func (*ActivationTerminated) GetPid ¶
func (m *ActivationTerminated) GetPid() *actor.PID
func (*ActivationTerminated) Marshal ¶
func (m *ActivationTerminated) Marshal() (dAtA []byte, err error)
func (*ActivationTerminated) MarshalTo ¶
func (m *ActivationTerminated) MarshalTo(dAtA []byte) (int, error)
func (*ActivationTerminated) MarshalToSizedBuffer ¶
func (m *ActivationTerminated) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ActivationTerminated) ProtoMessage ¶
func (*ActivationTerminated) ProtoMessage()
func (*ActivationTerminated) Reset ¶
func (m *ActivationTerminated) Reset()
func (*ActivationTerminated) Size ¶
func (m *ActivationTerminated) Size() (n int)
func (*ActivationTerminated) String ¶
func (this *ActivationTerminated) String() string
func (*ActivationTerminated) Unmarshal ¶
func (m *ActivationTerminated) Unmarshal(dAtA []byte) error
func (*ActivationTerminated) XXX_DiscardUnknown ¶
func (m *ActivationTerminated) XXX_DiscardUnknown()
func (*ActivationTerminated) XXX_Marshal ¶
func (m *ActivationTerminated) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ActivationTerminated) XXX_Merge ¶
func (m *ActivationTerminated) XXX_Merge(src proto.Message)
func (*ActivationTerminated) XXX_Size ¶
func (m *ActivationTerminated) XXX_Size() int
func (*ActivationTerminated) XXX_Unmarshal ¶
func (m *ActivationTerminated) XXX_Unmarshal(b []byte) error
type AddConsensusCheck ¶
type AddConsensusCheck struct { ID string Check *ConsensusCheck }
func NewAddConsensusCheck ¶
func NewAddConsensusCheck(id string, check *ConsensusCheck) AddConsensusCheck
type Cluster ¶
type Cluster struct { ActorSystem *actor.ActorSystem Config *Config Gossip Gossiper MemberList *MemberList // contains filtered or unexported fields }
func GetCluster ¶
func GetCluster(actorSystem *actor.ActorSystem) *Cluster
func (*Cluster) Call ¶
func (c *Cluster) Call(name string, kind string, msg interface{}, callopts ...*GrainCallOptions) (interface{}, error)
Call is a wrap of context.RequestFuture with retries.
func (*Cluster) GetBlockedMembers ¶
func (*Cluster) GetClusterKinds ¶
GetClusterKinds Get kinds of virtual actor
func (*Cluster) Id ¶
func (c *Cluster) Id() extensions.ExtensionId
func (*Cluster) StartClient ¶
func (c *Cluster) StartClient()
type ClusterIdentity ¶
type ClusterIdentity struct { Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"` Kind string `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"` }
func (*ClusterIdentity) AsKey ¶
func (ci *ClusterIdentity) AsKey() string
func (*ClusterIdentity) Descriptor ¶
func (*ClusterIdentity) Descriptor() ([]byte, []int)
func (*ClusterIdentity) Equal ¶
func (this *ClusterIdentity) Equal(that interface{}) bool
func (*ClusterIdentity) GetIdentity ¶
func (m *ClusterIdentity) GetIdentity() string
func (*ClusterIdentity) GetKind ¶
func (m *ClusterIdentity) GetKind() string
func (*ClusterIdentity) Marshal ¶
func (m *ClusterIdentity) Marshal() (dAtA []byte, err error)
func (*ClusterIdentity) MarshalToSizedBuffer ¶
func (m *ClusterIdentity) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ClusterIdentity) ProtoMessage ¶
func (*ClusterIdentity) ProtoMessage()
func (*ClusterIdentity) Reset ¶
func (m *ClusterIdentity) Reset()
func (*ClusterIdentity) Size ¶
func (m *ClusterIdentity) Size() (n int)
func (*ClusterIdentity) String ¶
func (this *ClusterIdentity) String() string
func (*ClusterIdentity) Unmarshal ¶
func (m *ClusterIdentity) Unmarshal(dAtA []byte) error
func (*ClusterIdentity) XXX_DiscardUnknown ¶
func (m *ClusterIdentity) XXX_DiscardUnknown()
func (*ClusterIdentity) XXX_Marshal ¶
func (m *ClusterIdentity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClusterIdentity) XXX_Merge ¶
func (m *ClusterIdentity) XXX_Merge(src proto.Message)
func (*ClusterIdentity) XXX_Size ¶
func (m *ClusterIdentity) XXX_Size() int
func (*ClusterIdentity) XXX_Unmarshal ¶
func (m *ClusterIdentity) XXX_Unmarshal(b []byte) error
type ClusterInit ¶
type ClusterProvider ¶
type ClusterState ¶
type ClusterState struct {
BannedMembers []string `json:"bannedMembers"`
}
type ClusterTopology ¶
type ClusterTopology struct { EventId uint64 `protobuf:"varint,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"` Members []*Member `protobuf:"bytes,2,rep,name=members,proto3" json:"members,omitempty"` Joined []*Member `protobuf:"bytes,3,rep,name=joined,proto3" json:"joined,omitempty"` Left []*Member `protobuf:"bytes,4,rep,name=left,proto3" json:"left,omitempty"` Banned []*Member `protobuf:"bytes,5,rep,name=banned,proto3" json:"banned,omitempty"` }
func (*ClusterTopology) Descriptor ¶
func (*ClusterTopology) Descriptor() ([]byte, []int)
func (*ClusterTopology) Equal ¶
func (this *ClusterTopology) Equal(that interface{}) bool
func (*ClusterTopology) GetBanned ¶
func (m *ClusterTopology) GetBanned() []*Member
func (*ClusterTopology) GetEventId ¶
func (m *ClusterTopology) GetEventId() uint64
func (*ClusterTopology) GetJoined ¶
func (m *ClusterTopology) GetJoined() []*Member
func (*ClusterTopology) GetLeft ¶
func (m *ClusterTopology) GetLeft() []*Member
func (*ClusterTopology) GetMembers ¶
func (m *ClusterTopology) GetMembers() []*Member
func (*ClusterTopology) Marshal ¶
func (m *ClusterTopology) Marshal() (dAtA []byte, err error)
func (*ClusterTopology) MarshalToSizedBuffer ¶
func (m *ClusterTopology) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ClusterTopology) ProtoMessage ¶
func (*ClusterTopology) ProtoMessage()
func (*ClusterTopology) Reset ¶
func (m *ClusterTopology) Reset()
func (*ClusterTopology) Size ¶
func (m *ClusterTopology) Size() (n int)
func (*ClusterTopology) String ¶
func (this *ClusterTopology) String() string
func (*ClusterTopology) Unmarshal ¶
func (m *ClusterTopology) Unmarshal(dAtA []byte) error
func (*ClusterTopology) XXX_DiscardUnknown ¶
func (m *ClusterTopology) XXX_DiscardUnknown()
func (*ClusterTopology) XXX_Marshal ¶
func (m *ClusterTopology) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClusterTopology) XXX_Merge ¶
func (m *ClusterTopology) XXX_Merge(src proto.Message)
func (*ClusterTopology) XXX_Size ¶
func (m *ClusterTopology) XXX_Size() int
func (*ClusterTopology) XXX_Unmarshal ¶
func (m *ClusterTopology) XXX_Unmarshal(b []byte) error
type ClusterTopologyEventV2 ¶
type ClusterTopologyEventV2 struct { *ClusterTopology // contains filtered or unexported fields }
type Config ¶
type Config struct { Name string Address string ClusterProvider ClusterProvider RemoteConfig remote.Config TimeoutTime time.Duration GossipInterval time.Duration GossipRequestTimeout time.Duration GossipFanOut int GossipMaxSend int MemberStrategyBuilder func(kind string) MemberStrategy Kinds map[string]*actor.Props }
type ConsensusCheck ¶
type ConsensusCheck struct {
// contains filtered or unexported fields
}
data structure helpful to store consensus check information and behavior
func NewConsensusCheck ¶
func NewConsensusCheck(affectedKeys []string, check GossipUpdater) ConsensusCheck
creates a new ConsensusCheck value with the given data and return it back
type ConsensusCheckBuilder ¶
type ConsensusCheckBuilder struct {
// contains filtered or unexported fields
}
func NewConsensusCheckBuilder ¶
func NewConsensusCheckBuilder(key string, getValue func(*types.Any) interface{}) *ConsensusCheckBuilder
func (*ConsensusCheckBuilder) AffectedKeys ¶
func (ccb *ConsensusCheckBuilder) AffectedKeys() []string
func (*ConsensusCheckBuilder) Build ¶
func (ccb *ConsensusCheckBuilder) Build() (ConsensusHandler, *ConsensusCheck)
Builds a new ConsensusHandler and ConsensusCheck values and returns pointers to them
func (*ConsensusCheckBuilder) Check ¶
func (ccb *ConsensusCheckBuilder) Check() ConsensusChecker
func (*ConsensusCheckBuilder) HasConsensus ¶
func (ccb *ConsensusCheckBuilder) HasConsensus(memberValues []*consensusMemberValue) (bool, uint64)
func (*ConsensusCheckBuilder) MapToValue ¶
func (ccb *ConsensusCheckBuilder) MapToValue(valueTuple *consensusValue) func(string, *GossipMemberState) (string, string, uint64)
type ConsensusCheckDefinition ¶
type ConsensusCheckDefinition interface { Check() *ConsensusCheck AffectedKeys() map[string]struct{} }
type ConsensusChecker ¶
type ConsensusChecker func(*GossipState, map[string]empty) (bool, interface{})
Customary type used to provide consensus check callbacks of any type note: this is equivalent to (for future go v1.18):
type ConsensusChecker[T] func(GossipState, map[string]empty) (bool, T)
type ConsensusChecks ¶
type ConsensusChecks struct {
// contains filtered or unexported fields
}
acts as an storage of pointers to ConsensusCheck stored by key
func NewConsensusChecks ¶
func NewConsensusChecks() *ConsensusChecks
creates a new ConsensusChecks value and returns a pointer to it
func (*ConsensusChecks) Add ¶
func (cc *ConsensusChecks) Add(id string, check *ConsensusCheck)
adds a new pointer to a ConsensusCheck value in the storage and registers its affected by keys index
func (*ConsensusChecks) GetByUpdatedKey ¶
func (cc *ConsensusChecks) GetByUpdatedKey(key string) []*ConsensusCheck
iterates over all the keys stored in the set (map[string]empty) found in the given key map and populates a slice of pointers to ConsensusCheck values that is returned back as a set of ConsensusCheck updated by the given key
func (*ConsensusChecks) GetByUpdatedKeys ¶
func (cc *ConsensusChecks) GetByUpdatedKeys(keys []string) []*ConsensusCheck
iterate over all of the keys stored in the set (map[string]empty) found in the given key maps and populates a slice of pointers to ConsensusCheck values that is returned back as a set of ConsensusCheck updated by the given keys with removed duplicates on it (as it is a "set")
func (*ConsensusChecks) Remove ¶
func (cc *ConsensusChecks) Remove(id string)
removed the given ConsensusCheck id from the storage and removes its affected by keys index if needed after cleaning
type ConsensusHandler ¶
type GetGossipStateRequest ¶
type GetGossipStateRequest struct {
Key string
}
Used to query the GossipActor about a given key status
func NewGetGossipStateRequest ¶
func NewGetGossipStateRequest(key string) GetGossipStateRequest
Create a new GetGossipStateRequest value and return it back
type GetGossipStateResponse ¶
Used by the GossipActor to send back the status value of a given key
func NewGetGossipStateResponse ¶
func NewGetGossipStateResponse(state map[string]*types.Any) GetGossipStateResponse
type Gossip ¶
type Gossip interface { GossipStateStorer GossipConsensusChecker GossipCore }
The Gossip interface must be implemented by any value that pretends to participate with-in the Gossip protocol
type GossipActor ¶
type GossipActor struct {
// contains filtered or unexported fields
}
Actor used to send gossip messages around
func NewGossipActor ¶
func NewGossipActor(requestTimeout time.Duration, myID string, getBlockedMembers func() map[string]empty, fanOut int, maxSend int) *GossipActor
Creates a new GossipActor and returns a pointer to its location in the heap
func (*GossipActor) ReceiveState ¶
func (ga *GossipActor) ReceiveState(remoteState *GossipState, ctx actor.Context)
type GossipConsensusChecker ¶
type GossipConsensusChecker interface { AddConsensusCheck(id string, check *ConsensusCheck) RemoveConsensusCheck(id string) }
This interface must be implemented by any value that wants to add or remove consensus checkers
type GossipCore ¶
type GossipCore interface { UpdateClusterTopology(topology *ClusterTopology) ReceiveState(remoteState *GossipState) []*GossipUpdate SendState(sendStateToMember LocalStateSender) GetMemberStateDelta(targetMemberID string) MemberStateDelta }
This interface must be implemented by any value that wants to react to cluster topology events
type GossipDeltaValue ¶
type GossipDeltaValue struct {
Entries []*GossipDeltaValue_GossipDeltaEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
}
represents a value that can be sent in form of a delta change instead of a full value replace
func (*GossipDeltaValue) Descriptor ¶
func (*GossipDeltaValue) Descriptor() ([]byte, []int)
func (*GossipDeltaValue) Equal ¶
func (this *GossipDeltaValue) Equal(that interface{}) bool
func (*GossipDeltaValue) GetEntries ¶
func (m *GossipDeltaValue) GetEntries() []*GossipDeltaValue_GossipDeltaEntry
func (*GossipDeltaValue) GoString ¶
func (this *GossipDeltaValue) GoString() string
func (*GossipDeltaValue) Marshal ¶
func (m *GossipDeltaValue) Marshal() (dAtA []byte, err error)
func (*GossipDeltaValue) MarshalToSizedBuffer ¶
func (m *GossipDeltaValue) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GossipDeltaValue) ProtoMessage ¶
func (*GossipDeltaValue) ProtoMessage()
func (*GossipDeltaValue) Reset ¶
func (m *GossipDeltaValue) Reset()
func (*GossipDeltaValue) Size ¶
func (m *GossipDeltaValue) Size() (n int)
func (*GossipDeltaValue) String ¶
func (this *GossipDeltaValue) String() string
func (*GossipDeltaValue) Unmarshal ¶
func (m *GossipDeltaValue) Unmarshal(dAtA []byte) error
func (*GossipDeltaValue) XXX_DiscardUnknown ¶
func (m *GossipDeltaValue) XXX_DiscardUnknown()
func (*GossipDeltaValue) XXX_Marshal ¶
func (m *GossipDeltaValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GossipDeltaValue) XXX_Merge ¶
func (m *GossipDeltaValue) XXX_Merge(src proto.Message)
func (*GossipDeltaValue) XXX_Size ¶
func (m *GossipDeltaValue) XXX_Size() int
func (*GossipDeltaValue) XXX_Unmarshal ¶
func (m *GossipDeltaValue) XXX_Unmarshal(b []byte) error
type GossipDeltaValue_GossipDeltaEntry ¶
type GossipDeltaValue_GossipDeltaEntry struct { SequenceNumber int64 `protobuf:"varint,1,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` }
these are the entries of a delta value this can be seen as an array with data, where each element in the array is tagged with a sequence number
func (*GossipDeltaValue_GossipDeltaEntry) Descriptor ¶
func (*GossipDeltaValue_GossipDeltaEntry) Descriptor() ([]byte, []int)
func (*GossipDeltaValue_GossipDeltaEntry) Equal ¶
func (this *GossipDeltaValue_GossipDeltaEntry) Equal(that interface{}) bool
func (*GossipDeltaValue_GossipDeltaEntry) GetData ¶
func (m *GossipDeltaValue_GossipDeltaEntry) GetData() []byte
func (*GossipDeltaValue_GossipDeltaEntry) GetSequenceNumber ¶
func (m *GossipDeltaValue_GossipDeltaEntry) GetSequenceNumber() int64
func (*GossipDeltaValue_GossipDeltaEntry) GoString ¶
func (this *GossipDeltaValue_GossipDeltaEntry) GoString() string
func (*GossipDeltaValue_GossipDeltaEntry) Marshal ¶
func (m *GossipDeltaValue_GossipDeltaEntry) Marshal() (dAtA []byte, err error)
func (*GossipDeltaValue_GossipDeltaEntry) MarshalTo ¶
func (m *GossipDeltaValue_GossipDeltaEntry) MarshalTo(dAtA []byte) (int, error)
func (*GossipDeltaValue_GossipDeltaEntry) MarshalToSizedBuffer ¶
func (m *GossipDeltaValue_GossipDeltaEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GossipDeltaValue_GossipDeltaEntry) ProtoMessage ¶
func (*GossipDeltaValue_GossipDeltaEntry) ProtoMessage()
func (*GossipDeltaValue_GossipDeltaEntry) Reset ¶
func (m *GossipDeltaValue_GossipDeltaEntry) Reset()
func (*GossipDeltaValue_GossipDeltaEntry) Size ¶
func (m *GossipDeltaValue_GossipDeltaEntry) Size() (n int)
func (*GossipDeltaValue_GossipDeltaEntry) String ¶
func (this *GossipDeltaValue_GossipDeltaEntry) String() string
func (*GossipDeltaValue_GossipDeltaEntry) Unmarshal ¶
func (m *GossipDeltaValue_GossipDeltaEntry) Unmarshal(dAtA []byte) error
func (*GossipDeltaValue_GossipDeltaEntry) XXX_DiscardUnknown ¶
func (m *GossipDeltaValue_GossipDeltaEntry) XXX_DiscardUnknown()
func (*GossipDeltaValue_GossipDeltaEntry) XXX_Marshal ¶
func (m *GossipDeltaValue_GossipDeltaEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GossipDeltaValue_GossipDeltaEntry) XXX_Merge ¶
func (m *GossipDeltaValue_GossipDeltaEntry) XXX_Merge(src proto.Message)
func (*GossipDeltaValue_GossipDeltaEntry) XXX_Size ¶
func (m *GossipDeltaValue_GossipDeltaEntry) XXX_Size() int
func (*GossipDeltaValue_GossipDeltaEntry) XXX_Unmarshal ¶
func (m *GossipDeltaValue_GossipDeltaEntry) XXX_Unmarshal(b []byte) error
type GossipKeyValue ¶
type GossipKeyValue struct { SequenceNumber int64 `protobuf:"varint,2,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number,omitempty"` Value *types.Any `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"` }
a known key might be heartbeat. if we locally tag each entry with a local timestamp this means that we can measure if we have not received a new heartbeat from one member in some time even if we don't know the exact time the heartbeat was issued, due to clock differences. we still know when _we_ as in this node, got this data. and we can measure time from then til now.
if we got a hear-beat from another node, and X seconds pass, we can assume it to be dead
func (*GossipKeyValue) Descriptor ¶
func (*GossipKeyValue) Descriptor() ([]byte, []int)
func (*GossipKeyValue) Equal ¶
func (this *GossipKeyValue) Equal(that interface{}) bool
func (*GossipKeyValue) GetSequenceNumber ¶
func (m *GossipKeyValue) GetSequenceNumber() int64
func (*GossipKeyValue) GetValue ¶
func (m *GossipKeyValue) GetValue() *types.Any
func (*GossipKeyValue) GoString ¶
func (this *GossipKeyValue) GoString() string
func (*GossipKeyValue) Marshal ¶
func (m *GossipKeyValue) Marshal() (dAtA []byte, err error)
func (*GossipKeyValue) MarshalToSizedBuffer ¶
func (m *GossipKeyValue) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GossipKeyValue) ProtoMessage ¶
func (*GossipKeyValue) ProtoMessage()
func (*GossipKeyValue) Reset ¶
func (m *GossipKeyValue) Reset()
func (*GossipKeyValue) Size ¶
func (m *GossipKeyValue) Size() (n int)
func (*GossipKeyValue) String ¶
func (this *GossipKeyValue) String() string
func (*GossipKeyValue) Unmarshal ¶
func (m *GossipKeyValue) Unmarshal(dAtA []byte) error
func (*GossipKeyValue) XXX_DiscardUnknown ¶
func (m *GossipKeyValue) XXX_DiscardUnknown()
func (*GossipKeyValue) XXX_Marshal ¶
func (m *GossipKeyValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GossipKeyValue) XXX_Merge ¶
func (m *GossipKeyValue) XXX_Merge(src proto.Message)
func (*GossipKeyValue) XXX_Size ¶
func (m *GossipKeyValue) XXX_Size() int
func (*GossipKeyValue) XXX_Unmarshal ¶
func (m *GossipKeyValue) XXX_Unmarshal(b []byte) error
type GossipMemberState ¶
type GossipMemberState = GossipState_GossipMemberState
convenience type alias
type GossipRequest ¶
type GossipRequest struct { State *GossipState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"` MemberId string `protobuf:"bytes,2,opt,name=member_id,json=memberId,proto3" json:"member_id,omitempty"` }
func (*GossipRequest) Descriptor ¶
func (*GossipRequest) Descriptor() ([]byte, []int)
func (*GossipRequest) Equal ¶
func (this *GossipRequest) Equal(that interface{}) bool
func (*GossipRequest) GetMemberId ¶
func (m *GossipRequest) GetMemberId() string
func (*GossipRequest) GetState ¶
func (m *GossipRequest) GetState() *GossipState
func (*GossipRequest) GoString ¶
func (this *GossipRequest) GoString() string
func (*GossipRequest) Marshal ¶
func (m *GossipRequest) Marshal() (dAtA []byte, err error)
func (*GossipRequest) MarshalToSizedBuffer ¶
func (m *GossipRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GossipRequest) ProtoMessage ¶
func (*GossipRequest) ProtoMessage()
func (*GossipRequest) Reset ¶
func (m *GossipRequest) Reset()
func (*GossipRequest) Size ¶
func (m *GossipRequest) Size() (n int)
func (*GossipRequest) String ¶
func (this *GossipRequest) String() string
func (*GossipRequest) Unmarshal ¶
func (m *GossipRequest) Unmarshal(dAtA []byte) error
func (*GossipRequest) XXX_DiscardUnknown ¶
func (m *GossipRequest) XXX_DiscardUnknown()
func (*GossipRequest) XXX_Marshal ¶
func (m *GossipRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GossipRequest) XXX_Merge ¶
func (m *GossipRequest) XXX_Merge(src proto.Message)
func (*GossipRequest) XXX_Size ¶
func (m *GossipRequest) XXX_Size() int
func (*GossipRequest) XXX_Unmarshal ¶
func (m *GossipRequest) XXX_Unmarshal(b []byte) error
type GossipResponse ¶
type GossipResponse struct {
State *GossipState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
}
Ack a gossip request
func (*GossipResponse) Descriptor ¶
func (*GossipResponse) Descriptor() ([]byte, []int)
func (*GossipResponse) Equal ¶
func (this *GossipResponse) Equal(that interface{}) bool
func (*GossipResponse) GetState ¶
func (m *GossipResponse) GetState() *GossipState
func (*GossipResponse) GoString ¶
func (this *GossipResponse) GoString() string
func (*GossipResponse) Marshal ¶
func (m *GossipResponse) Marshal() (dAtA []byte, err error)
func (*GossipResponse) MarshalToSizedBuffer ¶
func (m *GossipResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GossipResponse) ProtoMessage ¶
func (*GossipResponse) ProtoMessage()
func (*GossipResponse) Reset ¶
func (m *GossipResponse) Reset()
func (*GossipResponse) Size ¶
func (m *GossipResponse) Size() (n int)
func (*GossipResponse) String ¶
func (this *GossipResponse) String() string
func (*GossipResponse) Unmarshal ¶
func (m *GossipResponse) Unmarshal(dAtA []byte) error
func (*GossipResponse) XXX_DiscardUnknown ¶
func (m *GossipResponse) XXX_DiscardUnknown()
func (*GossipResponse) XXX_Marshal ¶
func (m *GossipResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GossipResponse) XXX_Merge ¶
func (m *GossipResponse) XXX_Merge(src proto.Message)
func (*GossipResponse) XXX_Size ¶
func (m *GossipResponse) XXX_Size() int
func (*GossipResponse) XXX_Unmarshal ¶
func (m *GossipResponse) XXX_Unmarshal(b []byte) error
type GossipResponseAck ¶
type GossipResponseAck struct { }
func (*GossipResponseAck) Descriptor ¶
func (*GossipResponseAck) Descriptor() ([]byte, []int)
func (*GossipResponseAck) Equal ¶
func (this *GossipResponseAck) Equal(that interface{}) bool
func (*GossipResponseAck) GoString ¶
func (this *GossipResponseAck) GoString() string
func (*GossipResponseAck) Marshal ¶
func (m *GossipResponseAck) Marshal() (dAtA []byte, err error)
func (*GossipResponseAck) MarshalTo ¶
func (m *GossipResponseAck) MarshalTo(dAtA []byte) (int, error)
func (*GossipResponseAck) MarshalToSizedBuffer ¶
func (m *GossipResponseAck) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GossipResponseAck) ProtoMessage ¶
func (*GossipResponseAck) ProtoMessage()
func (*GossipResponseAck) Reset ¶
func (m *GossipResponseAck) Reset()
func (*GossipResponseAck) Size ¶
func (m *GossipResponseAck) Size() (n int)
func (*GossipResponseAck) String ¶
func (this *GossipResponseAck) String() string
func (*GossipResponseAck) Unmarshal ¶
func (m *GossipResponseAck) Unmarshal(dAtA []byte) error
func (*GossipResponseAck) XXX_DiscardUnknown ¶
func (m *GossipResponseAck) XXX_DiscardUnknown()
func (*GossipResponseAck) XXX_Marshal ¶
func (m *GossipResponseAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GossipResponseAck) XXX_Merge ¶
func (m *GossipResponseAck) XXX_Merge(src proto.Message)
func (*GossipResponseAck) XXX_Size ¶
func (m *GossipResponseAck) XXX_Size() int
func (*GossipResponseAck) XXX_Unmarshal ¶
func (m *GossipResponseAck) XXX_Unmarshal(b []byte) error
type GossipState ¶
type GossipState struct {
Members map[string]*GossipState_GossipMemberState `` /* 155-byte string literal not displayed */
}
two GossipState objects can be merged key + member_id gets it's own entry, if collision, highest version is selected
func (*GossipState) Descriptor ¶
func (*GossipState) Descriptor() ([]byte, []int)
func (*GossipState) Equal ¶
func (this *GossipState) Equal(that interface{}) bool
func (*GossipState) GetMembers ¶
func (m *GossipState) GetMembers() map[string]*GossipState_GossipMemberState
func (*GossipState) GoString ¶
func (this *GossipState) GoString() string
func (*GossipState) Marshal ¶
func (m *GossipState) Marshal() (dAtA []byte, err error)
func (*GossipState) MarshalToSizedBuffer ¶
func (m *GossipState) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GossipState) ProtoMessage ¶
func (*GossipState) ProtoMessage()
func (*GossipState) Reset ¶
func (m *GossipState) Reset()
func (*GossipState) Size ¶
func (m *GossipState) Size() (n int)
func (*GossipState) String ¶
func (this *GossipState) String() string
func (*GossipState) Unmarshal ¶
func (m *GossipState) Unmarshal(dAtA []byte) error
func (*GossipState) XXX_DiscardUnknown ¶
func (m *GossipState) XXX_DiscardUnknown()
func (*GossipState) XXX_Marshal ¶
func (m *GossipState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GossipState) XXX_Merge ¶
func (m *GossipState) XXX_Merge(src proto.Message)
func (*GossipState) XXX_Size ¶
func (m *GossipState) XXX_Size() int
func (*GossipState) XXX_Unmarshal ¶
func (m *GossipState) XXX_Unmarshal(b []byte) error
type GossipStateStorer ¶
type GossipStateStorer interface { GetState(key string) map[string]*types.Any SetState(key string, value proto.Message) }
This interface must be implemented by any value that wants to be used as a gossip state storage
type GossipState_GossipMemberState ¶
type GossipState_GossipMemberState struct {
Values map[string]*GossipKeyValue `` /* 153-byte string literal not displayed */
}
func (*GossipState_GossipMemberState) Descriptor ¶
func (*GossipState_GossipMemberState) Descriptor() ([]byte, []int)
func (*GossipState_GossipMemberState) Equal ¶
func (this *GossipState_GossipMemberState) Equal(that interface{}) bool
func (*GossipState_GossipMemberState) GetValues ¶
func (m *GossipState_GossipMemberState) GetValues() map[string]*GossipKeyValue
func (*GossipState_GossipMemberState) GoString ¶
func (this *GossipState_GossipMemberState) GoString() string
func (*GossipState_GossipMemberState) Marshal ¶
func (m *GossipState_GossipMemberState) Marshal() (dAtA []byte, err error)
func (*GossipState_GossipMemberState) MarshalTo ¶
func (m *GossipState_GossipMemberState) MarshalTo(dAtA []byte) (int, error)
func (*GossipState_GossipMemberState) MarshalToSizedBuffer ¶
func (m *GossipState_GossipMemberState) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GossipState_GossipMemberState) ProtoMessage ¶
func (*GossipState_GossipMemberState) ProtoMessage()
func (*GossipState_GossipMemberState) Reset ¶
func (m *GossipState_GossipMemberState) Reset()
func (*GossipState_GossipMemberState) Size ¶
func (m *GossipState_GossipMemberState) Size() (n int)
func (*GossipState_GossipMemberState) String ¶
func (this *GossipState_GossipMemberState) String() string
func (*GossipState_GossipMemberState) Unmarshal ¶
func (m *GossipState_GossipMemberState) Unmarshal(dAtA []byte) error
func (*GossipState_GossipMemberState) XXX_DiscardUnknown ¶
func (m *GossipState_GossipMemberState) XXX_DiscardUnknown()
func (*GossipState_GossipMemberState) XXX_Marshal ¶
func (m *GossipState_GossipMemberState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GossipState_GossipMemberState) XXX_Merge ¶
func (m *GossipState_GossipMemberState) XXX_Merge(src proto.Message)
func (*GossipState_GossipMemberState) XXX_Size ¶
func (m *GossipState_GossipMemberState) XXX_Size() int
func (*GossipState_GossipMemberState) XXX_Unmarshal ¶
func (m *GossipState_GossipMemberState) XXX_Unmarshal(b []byte) error
type GossipUpdate ¶
Used to update gossip data when a Clustertopology event occurs
type GossipUpdater ¶
type GossipUpdater func(*GossipState, map[string]empty)
type Gossiper ¶
type Gossiper struct { // The Gossiper Actor Name, defaults to "gossip" GossipActorName string // contains filtered or unexported fields }
The Gossiper data structure manages Gossip
func (*Gossiper) RegisterConsensusCheck ¶
func (g *Gossiper) RegisterConsensusCheck(key string, getValue func(*types.Any) interface{}) ConsensusHandler
Builds a consensus handler and a consensus checker, send the checker to the Gossip actor and returns the handler back to the caller
func (*Gossiper) SetStateRequest ¶
Sends a Request (that blocks) to update member state
func (*Gossiper) StartGossiping ¶
type GrainCallOptions ¶
func DefaultGrainCallOptions ¶
func DefaultGrainCallOptions(cluster *Cluster) *GrainCallOptions
func NewGrainCallOptions ¶
func NewGrainCallOptions(cluster *Cluster) *GrainCallOptions
func (*GrainCallOptions) WithRetry ¶
func (config *GrainCallOptions) WithRetry(count int) *GrainCallOptions
func (*GrainCallOptions) WithRetryAction ¶
func (config *GrainCallOptions) WithRetryAction(act func(i int)) *GrainCallOptions
func (*GrainCallOptions) WithTimeout ¶
func (config *GrainCallOptions) WithTimeout(timeout time.Duration) *GrainCallOptions
type GrainContext ¶
type GrainContext interface { // Self returns the PID for the current actor Self() *actor.PID // Returns a slice of the actors children Children() []*actor.PID // Watch registers the actor as a monitor for the specified PID Watch(pid *actor.PID) // Unwatch unregisters the actor as a monitor for the specified PID Unwatch(pid *actor.PID) // Sender returns the PID of actor that sent currently processed message Sender() *actor.PID // Message returns the current message to be processed Message() interface{} // Tell sends a message to the given PID Send(pid *actor.PID, message interface{}) // Request sends a message to the given PID and also provides a Sender PID Request(pid *actor.PID, message interface{}) // RequestFuture sends a message to a given PID and returns a Future RequestFuture(pid *actor.PID, message interface{}, timeout time.Duration) *actor.Future // Spawn starts a new child actor based on props and named with a unique id Spawn(props *actor.Props) *actor.PID // SpawnPrefix starts a new child actor based on props and named using a prefix followed by a unique id SpawnPrefix(props *actor.Props, prefix string) *actor.PID // SpawnNamed starts a new child actor based on props and named using the specified name // // ErrNameExists will be returned if id already exists SpawnNamed(props *actor.Props, id string) (*actor.PID, error) }
type GrainErrorResponse ¶
type GrainErrorResponse struct { Err string `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"` Code int32 `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"` }
func (*GrainErrorResponse) Descriptor ¶
func (*GrainErrorResponse) Descriptor() ([]byte, []int)
func (*GrainErrorResponse) Equal ¶
func (this *GrainErrorResponse) Equal(that interface{}) bool
func (*GrainErrorResponse) GetCode ¶
func (m *GrainErrorResponse) GetCode() int32
func (*GrainErrorResponse) GetErr ¶
func (m *GrainErrorResponse) GetErr() string
func (*GrainErrorResponse) Marshal ¶
func (m *GrainErrorResponse) Marshal() (dAtA []byte, err error)
func (*GrainErrorResponse) MarshalTo ¶
func (m *GrainErrorResponse) MarshalTo(dAtA []byte) (int, error)
func (*GrainErrorResponse) MarshalToSizedBuffer ¶
func (m *GrainErrorResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GrainErrorResponse) ProtoMessage ¶
func (*GrainErrorResponse) ProtoMessage()
func (*GrainErrorResponse) Reset ¶
func (m *GrainErrorResponse) Reset()
func (*GrainErrorResponse) Size ¶
func (m *GrainErrorResponse) Size() (n int)
func (*GrainErrorResponse) String ¶
func (this *GrainErrorResponse) String() string
func (*GrainErrorResponse) Unmarshal ¶
func (m *GrainErrorResponse) Unmarshal(dAtA []byte) error
func (*GrainErrorResponse) XXX_DiscardUnknown ¶
func (m *GrainErrorResponse) XXX_DiscardUnknown()
func (*GrainErrorResponse) XXX_Marshal ¶
func (m *GrainErrorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GrainErrorResponse) XXX_Merge ¶
func (m *GrainErrorResponse) XXX_Merge(src proto.Message)
func (*GrainErrorResponse) XXX_Size ¶
func (m *GrainErrorResponse) XXX_Size() int
func (*GrainErrorResponse) XXX_Unmarshal ¶
func (m *GrainErrorResponse) XXX_Unmarshal(b []byte) error
type GrainRequest ¶
type GrainRequest struct { MethodIndex int32 `protobuf:"varint,1,opt,name=method_index,json=methodIndex,proto3" json:"method_index,omitempty"` MessageData []byte `protobuf:"bytes,2,opt,name=message_data,json=messageData,proto3" json:"message_data,omitempty"` }
func (*GrainRequest) Descriptor ¶
func (*GrainRequest) Descriptor() ([]byte, []int)
func (*GrainRequest) Equal ¶
func (this *GrainRequest) Equal(that interface{}) bool
func (*GrainRequest) GetMessageData ¶
func (m *GrainRequest) GetMessageData() []byte
func (*GrainRequest) GetMethodIndex ¶
func (m *GrainRequest) GetMethodIndex() int32
func (*GrainRequest) Marshal ¶
func (m *GrainRequest) Marshal() (dAtA []byte, err error)
func (*GrainRequest) MarshalToSizedBuffer ¶
func (m *GrainRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GrainRequest) ProtoMessage ¶
func (*GrainRequest) ProtoMessage()
func (*GrainRequest) Reset ¶
func (m *GrainRequest) Reset()
func (*GrainRequest) Size ¶
func (m *GrainRequest) Size() (n int)
func (*GrainRequest) String ¶
func (this *GrainRequest) String() string
func (*GrainRequest) Unmarshal ¶
func (m *GrainRequest) Unmarshal(dAtA []byte) error
func (*GrainRequest) XXX_DiscardUnknown ¶
func (m *GrainRequest) XXX_DiscardUnknown()
func (*GrainRequest) XXX_Marshal ¶
func (m *GrainRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GrainRequest) XXX_Merge ¶
func (m *GrainRequest) XXX_Merge(src proto.Message)
func (*GrainRequest) XXX_Size ¶
func (m *GrainRequest) XXX_Size() int
func (*GrainRequest) XXX_Unmarshal ¶
func (m *GrainRequest) XXX_Unmarshal(b []byte) error
type GrainResponse ¶
type GrainResponse struct {
MessageData []byte `protobuf:"bytes,1,opt,name=message_data,json=messageData,proto3" json:"message_data,omitempty"`
}
func (*GrainResponse) Descriptor ¶
func (*GrainResponse) Descriptor() ([]byte, []int)
func (*GrainResponse) Equal ¶
func (this *GrainResponse) Equal(that interface{}) bool
func (*GrainResponse) GetMessageData ¶
func (m *GrainResponse) GetMessageData() []byte
func (*GrainResponse) Marshal ¶
func (m *GrainResponse) Marshal() (dAtA []byte, err error)
func (*GrainResponse) MarshalToSizedBuffer ¶
func (m *GrainResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GrainResponse) ProtoMessage ¶
func (*GrainResponse) ProtoMessage()
func (*GrainResponse) Reset ¶
func (m *GrainResponse) Reset()
func (*GrainResponse) Size ¶
func (m *GrainResponse) Size() (n int)
func (*GrainResponse) String ¶
func (this *GrainResponse) String() string
func (*GrainResponse) Unmarshal ¶
func (m *GrainResponse) Unmarshal(dAtA []byte) error
func (*GrainResponse) XXX_DiscardUnknown ¶
func (m *GrainResponse) XXX_DiscardUnknown()
func (*GrainResponse) XXX_Marshal ¶
func (m *GrainResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GrainResponse) XXX_Merge ¶
func (m *GrainResponse) XXX_Merge(src proto.Message)
func (*GrainResponse) XXX_Size ¶
func (m *GrainResponse) XXX_Size() int
func (*GrainResponse) XXX_Unmarshal ¶
func (m *GrainResponse) XXX_Unmarshal(b []byte) error
type HeartbeatRequest ¶
type HeartbeatRequest struct { }
func (*HeartbeatRequest) Descriptor ¶
func (*HeartbeatRequest) Descriptor() ([]byte, []int)
func (*HeartbeatRequest) Equal ¶
func (this *HeartbeatRequest) Equal(that interface{}) bool
func (*HeartbeatRequest) Marshal ¶
func (m *HeartbeatRequest) Marshal() (dAtA []byte, err error)
func (*HeartbeatRequest) MarshalToSizedBuffer ¶
func (m *HeartbeatRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*HeartbeatRequest) ProtoMessage ¶
func (*HeartbeatRequest) ProtoMessage()
func (*HeartbeatRequest) Reset ¶
func (m *HeartbeatRequest) Reset()
func (*HeartbeatRequest) Size ¶
func (m *HeartbeatRequest) Size() (n int)
func (*HeartbeatRequest) String ¶
func (this *HeartbeatRequest) String() string
func (*HeartbeatRequest) Unmarshal ¶
func (m *HeartbeatRequest) Unmarshal(dAtA []byte) error
func (*HeartbeatRequest) XXX_DiscardUnknown ¶
func (m *HeartbeatRequest) XXX_DiscardUnknown()
func (*HeartbeatRequest) XXX_Marshal ¶
func (m *HeartbeatRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HeartbeatRequest) XXX_Merge ¶
func (m *HeartbeatRequest) XXX_Merge(src proto.Message)
func (*HeartbeatRequest) XXX_Size ¶
func (m *HeartbeatRequest) XXX_Size() int
func (*HeartbeatRequest) XXX_Unmarshal ¶
func (m *HeartbeatRequest) XXX_Unmarshal(b []byte) error
type HeartbeatResponse ¶
type HeartbeatResponse struct {
ActorCount uint32 `protobuf:"varint,1,opt,name=actor_count,json=actorCount,proto3" json:"actor_count,omitempty"`
}
func (*HeartbeatResponse) Descriptor ¶
func (*HeartbeatResponse) Descriptor() ([]byte, []int)
func (*HeartbeatResponse) Equal ¶
func (this *HeartbeatResponse) Equal(that interface{}) bool
func (*HeartbeatResponse) GetActorCount ¶
func (m *HeartbeatResponse) GetActorCount() uint32
func (*HeartbeatResponse) Marshal ¶
func (m *HeartbeatResponse) Marshal() (dAtA []byte, err error)
func (*HeartbeatResponse) MarshalTo ¶
func (m *HeartbeatResponse) MarshalTo(dAtA []byte) (int, error)
func (*HeartbeatResponse) MarshalToSizedBuffer ¶
func (m *HeartbeatResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*HeartbeatResponse) ProtoMessage ¶
func (*HeartbeatResponse) ProtoMessage()
func (*HeartbeatResponse) Reset ¶
func (m *HeartbeatResponse) Reset()
func (*HeartbeatResponse) Size ¶
func (m *HeartbeatResponse) Size() (n int)
func (*HeartbeatResponse) String ¶
func (this *HeartbeatResponse) String() string
func (*HeartbeatResponse) Unmarshal ¶
func (m *HeartbeatResponse) Unmarshal(dAtA []byte) error
func (*HeartbeatResponse) XXX_DiscardUnknown ¶
func (m *HeartbeatResponse) XXX_DiscardUnknown()
func (*HeartbeatResponse) XXX_Marshal ¶
func (m *HeartbeatResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HeartbeatResponse) XXX_Merge ¶
func (m *HeartbeatResponse) XXX_Merge(src proto.Message)
func (*HeartbeatResponse) XXX_Size ¶
func (m *HeartbeatResponse) XXX_Size() int
func (*HeartbeatResponse) XXX_Unmarshal ¶
func (m *HeartbeatResponse) XXX_Unmarshal(b []byte) error
type IdentityHandoverRequest ¶
type IdentityHandoverRequest struct { EventId uint64 `protobuf:"varint,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` Members []*Member `protobuf:"bytes,3,rep,name=members,proto3" json:"members,omitempty"` }
request response call from Identity actor sent to each member asking what activations they hold that belong to the requester
func (*IdentityHandoverRequest) Descriptor ¶
func (*IdentityHandoverRequest) Descriptor() ([]byte, []int)
func (*IdentityHandoverRequest) Equal ¶
func (this *IdentityHandoverRequest) Equal(that interface{}) bool
func (*IdentityHandoverRequest) GetAddress ¶
func (m *IdentityHandoverRequest) GetAddress() string
func (*IdentityHandoverRequest) GetEventId ¶
func (m *IdentityHandoverRequest) GetEventId() uint64
func (*IdentityHandoverRequest) GetMembers ¶
func (m *IdentityHandoverRequest) GetMembers() []*Member
func (*IdentityHandoverRequest) Marshal ¶
func (m *IdentityHandoverRequest) Marshal() (dAtA []byte, err error)
func (*IdentityHandoverRequest) MarshalTo ¶
func (m *IdentityHandoverRequest) MarshalTo(dAtA []byte) (int, error)
func (*IdentityHandoverRequest) MarshalToSizedBuffer ¶
func (m *IdentityHandoverRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*IdentityHandoverRequest) ProtoMessage ¶
func (*IdentityHandoverRequest) ProtoMessage()
func (*IdentityHandoverRequest) Reset ¶
func (m *IdentityHandoverRequest) Reset()
func (*IdentityHandoverRequest) Size ¶
func (m *IdentityHandoverRequest) Size() (n int)
func (*IdentityHandoverRequest) String ¶
func (this *IdentityHandoverRequest) String() string
func (*IdentityHandoverRequest) Unmarshal ¶
func (m *IdentityHandoverRequest) Unmarshal(dAtA []byte) error
func (*IdentityHandoverRequest) XXX_DiscardUnknown ¶
func (m *IdentityHandoverRequest) XXX_DiscardUnknown()
func (*IdentityHandoverRequest) XXX_Marshal ¶
func (m *IdentityHandoverRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*IdentityHandoverRequest) XXX_Merge ¶
func (m *IdentityHandoverRequest) XXX_Merge(src proto.Message)
func (*IdentityHandoverRequest) XXX_Size ¶
func (m *IdentityHandoverRequest) XXX_Size() int
func (*IdentityHandoverRequest) XXX_Unmarshal ¶
func (m *IdentityHandoverRequest) XXX_Unmarshal(b []byte) error
type IdentityHandoverResponse ¶
type IdentityHandoverResponse struct {
Actors []*Activation `protobuf:"bytes,1,rep,name=actors,proto3" json:"actors,omitempty"`
}
response message to the above
func (*IdentityHandoverResponse) Descriptor ¶
func (*IdentityHandoverResponse) Descriptor() ([]byte, []int)
func (*IdentityHandoverResponse) Equal ¶
func (this *IdentityHandoverResponse) Equal(that interface{}) bool
func (*IdentityHandoverResponse) GetActors ¶
func (m *IdentityHandoverResponse) GetActors() []*Activation
func (*IdentityHandoverResponse) Marshal ¶
func (m *IdentityHandoverResponse) Marshal() (dAtA []byte, err error)
func (*IdentityHandoverResponse) MarshalTo ¶
func (m *IdentityHandoverResponse) MarshalTo(dAtA []byte) (int, error)
func (*IdentityHandoverResponse) MarshalToSizedBuffer ¶
func (m *IdentityHandoverResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*IdentityHandoverResponse) ProtoMessage ¶
func (*IdentityHandoverResponse) ProtoMessage()
func (*IdentityHandoverResponse) Reset ¶
func (m *IdentityHandoverResponse) Reset()
func (*IdentityHandoverResponse) Size ¶
func (m *IdentityHandoverResponse) Size() (n int)
func (*IdentityHandoverResponse) String ¶
func (this *IdentityHandoverResponse) String() string
func (*IdentityHandoverResponse) Unmarshal ¶
func (m *IdentityHandoverResponse) Unmarshal(dAtA []byte) error
func (*IdentityHandoverResponse) XXX_DiscardUnknown ¶
func (m *IdentityHandoverResponse) XXX_DiscardUnknown()
func (*IdentityHandoverResponse) XXX_Marshal ¶
func (m *IdentityHandoverResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*IdentityHandoverResponse) XXX_Merge ¶
func (m *IdentityHandoverResponse) XXX_Merge(src proto.Message)
func (*IdentityHandoverResponse) XXX_Size ¶
func (m *IdentityHandoverResponse) XXX_Size() int
func (*IdentityHandoverResponse) XXX_Unmarshal ¶
func (m *IdentityHandoverResponse) XXX_Unmarshal(b []byte) error
type IdentityLookup ¶
type IdentityLookup interface { Get(clusterIdentity *ClusterIdentity) RemovePid(clusterIdentity *ClusterIdentity, pid *actor.PID) Setup(cluster *Cluster, kinds []string, isClient bool) Shutdown() }
type Informer ¶
type Informer struct {
// contains filtered or unexported fields
}
The Informer data structure implements the Gossip interface
func (*Informer) AddConsensusCheck ¶
func (inf *Informer) AddConsensusCheck(id string, check *ConsensusCheck)
adds a new consensus checker to this informer
func (*Informer) CheckConsensus ¶
check consensus for the given keys
func (*Informer) GetMemberStateDelta ¶
func (inf *Informer) GetMemberStateDelta(targetMemberID string) MemberStateDelta
func (*Informer) ReceiveState ¶
func (inf *Informer) ReceiveState(remoteState *GossipState) []*GossipUpdate
receives a remote informer state
func (*Informer) RemoveConsensusCheck ¶
removes a consensus checker from this informer
func (*Informer) SendState ¶
func (inf *Informer) SendState(sendStateToMember LocalStateSender)
sends this informer local state to remote informers chosen randomly from the slice of other members known by this informer until gossipFanOut number of sent has been reached
func (*Informer) UpdateClusterTopology ¶
func (inf *Informer) UpdateClusterTopology(topology *ClusterTopology)
called when there is a cluster topology update
type LocalStateSender ¶
type LocalStateSender func(memberStateDelta *MemberStateDelta, member *Member)
customary type that defines a states sender callback
type Member ¶
type Member struct { Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` Id string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"` Kinds []string `protobuf:"bytes,4,rep,name=kinds,proto3" json:"kinds,omitempty"` }
func (*Member) Descriptor ¶
func (*Member) MarshalToSizedBuffer ¶
func (*Member) ProtoMessage ¶
func (*Member) ProtoMessage()
func (*Member) XXX_DiscardUnknown ¶
func (m *Member) XXX_DiscardUnknown()
func (*Member) XXX_Marshal ¶
func (*Member) XXX_Unmarshal ¶
type MemberAvailableEvent ¶
type MemberAvailableEvent struct {
MemberMeta
}
func (*MemberAvailableEvent) MemberStatusEvent ¶
func (*MemberAvailableEvent) MemberStatusEvent()
type MemberHeartbeat ¶
type MemberHeartbeat struct { }
func (*MemberHeartbeat) Descriptor ¶
func (*MemberHeartbeat) Descriptor() ([]byte, []int)
func (*MemberHeartbeat) Equal ¶
func (this *MemberHeartbeat) Equal(that interface{}) bool
func (*MemberHeartbeat) Marshal ¶
func (m *MemberHeartbeat) Marshal() (dAtA []byte, err error)
func (*MemberHeartbeat) MarshalToSizedBuffer ¶
func (m *MemberHeartbeat) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MemberHeartbeat) ProtoMessage ¶
func (*MemberHeartbeat) ProtoMessage()
func (*MemberHeartbeat) Reset ¶
func (m *MemberHeartbeat) Reset()
func (*MemberHeartbeat) Size ¶
func (m *MemberHeartbeat) Size() (n int)
func (*MemberHeartbeat) String ¶
func (this *MemberHeartbeat) String() string
func (*MemberHeartbeat) Unmarshal ¶
func (m *MemberHeartbeat) Unmarshal(dAtA []byte) error
func (*MemberHeartbeat) XXX_DiscardUnknown ¶
func (m *MemberHeartbeat) XXX_DiscardUnknown()
func (*MemberHeartbeat) XXX_Marshal ¶
func (m *MemberHeartbeat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MemberHeartbeat) XXX_Merge ¶
func (m *MemberHeartbeat) XXX_Merge(src proto.Message)
func (*MemberHeartbeat) XXX_Size ¶
func (m *MemberHeartbeat) XXX_Size() int
func (*MemberHeartbeat) XXX_Unmarshal ¶
func (m *MemberHeartbeat) XXX_Unmarshal(b []byte) error
type MemberJoinedEvent ¶
type MemberJoinedEvent struct {
MemberMeta
}
func (*MemberJoinedEvent) MemberStatusEvent ¶
func (*MemberJoinedEvent) MemberStatusEvent()
type MemberLeftEvent ¶
type MemberLeftEvent struct {
MemberMeta
}
func (*MemberLeftEvent) MemberStatusEvent ¶
func (*MemberLeftEvent) MemberStatusEvent()
type MemberList ¶
type MemberList struct {
// contains filtered or unexported fields
}
MemberList is responsible to keep track of the current cluster topology it does so by listening to changes from the ClusterProvider. the default ClusterProvider is consul.ConsulProvider which uses the Consul HTTP API to scan for changes
func NewMemberList ¶
func NewMemberList(cluster *Cluster) *MemberList
func (*MemberList) BroadcastEvent ¶
func (ml *MemberList) BroadcastEvent(message interface{})
func (*MemberList) ContainsMemberID ¶
func (ml *MemberList) ContainsMemberID(memberID string) bool
func (*MemberList) InitializeTopologyConsensus ¶
func (ml *MemberList) InitializeTopologyConsensus()
func (*MemberList) Length ¶
func (ml *MemberList) Length() int
func (*MemberList) TopologyConsensus ¶
func (ml *MemberList) TopologyConsensus(ctx context.Context) (uint64, bool)
func (*MemberList) UpdateClusterTopology ¶
func (ml *MemberList) UpdateClusterTopology(members []*Member, eventId uint64)
type MemberMeta ¶
func (*MemberMeta) GetKinds ¶
func (e *MemberMeta) GetKinds() []string
func (*MemberMeta) Name ¶
func (e *MemberMeta) Name() string
type MemberRejoinedEvent ¶
type MemberRejoinedEvent struct {
MemberMeta
}
func (*MemberRejoinedEvent) MemberStatusEvent ¶
func (*MemberRejoinedEvent) MemberStatusEvent()
type MemberStateDelta ¶
type MemberStateDelta struct { TargetMemberID string HasState bool State *GossipState CommitOffsets func() }
type MemberStatus ¶
func (*MemberStatus) Address ¶
func (m *MemberStatus) Address() string
type MemberStatusEvent ¶
type MemberStatusEvent interface { MemberStatusEvent() GetKinds() []string }
type MemberStrategy ¶
type MemberUnavailableEvent ¶
type MemberUnavailableEvent struct {
}func (*MemberUnavailableEvent) MemberStatusEvent ¶
func (*MemberUnavailableEvent) MemberStatusEvent()
type PartitionKind ¶
type PartitionKind struct { Kind string // contains filtered or unexported fields }
func (*PartitionKind) PidOfIdentityActor ¶
func (pm *PartitionKind) PidOfIdentityActor(addr string) *actor.PID
PidOfIdentityActor ...
func (*PartitionKind) PidOfPlacementActor ¶
func (pm *PartitionKind) PidOfPlacementActor(addr string) *actor.PID
PidOfPlacementActor ...
type PartitionManager ¶
type PartitionManager struct {
// contains filtered or unexported fields
}
func (*PartitionManager) PidOfIdentityActor ¶
func (pm *PartitionManager) PidOfIdentityActor(kind, addr string) *actor.PID
PidOfIdentityActor ...
type RemoveConsensusCheck ¶
type RemoveConsensusCheck struct {
ID string
}
Mimic .NET ReenterAfterCancellation on GossipActor
func NewRemoveConsensusCheck ¶
func NewRemoveConsensusCheck(id string) RemoveConsensusCheck
type Rendezvous ¶
type Rendezvous struct {
// contains filtered or unexported fields
}
func NewRendezvous ¶
func NewRendezvous(memberStrategy MemberStrategy) *Rendezvous
func (*Rendezvous) GetByRdv ¶
func (r *Rendezvous) GetByRdv(key string) string
Get returns the node with the highest score for the given key. If this Hash has no nodes, an empty string is returned.
func (*Rendezvous) UpdateRdv ¶
func (r *Rendezvous) UpdateRdv()
type RendezvousV2 ¶
type RendezvousV2 struct {
// contains filtered or unexported fields
}
RendezvousV2 ...
type SendGossipStateRequest ¶
type SendGossipStateRequest struct{}
type SendGossipStateResponse ¶
type SendGossipStateResponse struct{}
type SetGossipStateKey ¶
Used to setup Gossip Status Keys in the GossipActor
func NewGossipStateKey ¶
func NewGossipStateKey(key string, value proto.Message) SetGossipStateKey
Create a new SetGossipStateKey value with the given data and return it back
type SetGossipStateResponse ¶
type SetGossipStateResponse struct{}
Used by the GossipActor to respond SetGossipStatus requests
type SimpleRoundRobin ¶
type SimpleRoundRobin struct {
// contains filtered or unexported fields
}
func NewSimpleRoundRobin ¶
func NewSimpleRoundRobin(memberStrategy MemberStrategy) *SimpleRoundRobin
func (*SimpleRoundRobin) GetByRoundRobin ¶
func (r *SimpleRoundRobin) GetByRoundRobin() string
type TakeOwnership ¶
type TakeOwnership struct { Pid *actor.PID `protobuf:"bytes,1,opt,name=pid,proto3" json:"pid,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` }
func (*TakeOwnership) Descriptor ¶
func (*TakeOwnership) Descriptor() ([]byte, []int)
func (*TakeOwnership) Equal ¶
func (this *TakeOwnership) Equal(that interface{}) bool
func (*TakeOwnership) GetName ¶
func (m *TakeOwnership) GetName() string
func (*TakeOwnership) GetPid ¶
func (m *TakeOwnership) GetPid() *actor.PID
func (*TakeOwnership) Marshal ¶
func (m *TakeOwnership) Marshal() (dAtA []byte, err error)
func (*TakeOwnership) MarshalToSizedBuffer ¶
func (m *TakeOwnership) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TakeOwnership) ProtoMessage ¶
func (*TakeOwnership) ProtoMessage()
func (*TakeOwnership) Reset ¶
func (m *TakeOwnership) Reset()
func (*TakeOwnership) Size ¶
func (m *TakeOwnership) Size() (n int)
func (*TakeOwnership) String ¶
func (this *TakeOwnership) String() string
func (*TakeOwnership) Unmarshal ¶
func (m *TakeOwnership) Unmarshal(dAtA []byte) error
func (*TakeOwnership) XXX_DiscardUnknown ¶
func (m *TakeOwnership) XXX_DiscardUnknown()
func (*TakeOwnership) XXX_Marshal ¶
func (m *TakeOwnership) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TakeOwnership) XXX_Merge ¶
func (m *TakeOwnership) XXX_Merge(src proto.Message)
func (*TakeOwnership) XXX_Size ¶
func (m *TakeOwnership) XXX_Size() int
func (*TakeOwnership) XXX_Unmarshal ¶
func (m *TakeOwnership) XXX_Unmarshal(b []byte) error
type TopologyEvent ¶
type TopologyEvent []*Member
Source Files ¶
- cluster.go
- cluster_identity.go
- cluster_provider.go
- config.go
- consensus.go
- consensus_check_builder.go
- consensus_checks.go
- gossip.go
- gossip.pb.go
- gossip_actor.go
- gossip_state_management.go
- gossiper.go
- grain.go
- grain_context.go
- heartbeat_actor.go
- identity_lookup.go
- informer.go
- log.go
- member.go
- member_list.go
- member_state_delta.go
- member_status.go
- member_status_events.go
- member_strategy.go
- member_strategyv2.go
- messages.go
- options.go
- partition.go
- partition_identity_actor.go
- partition_kind.go
- partition_lookup.go
- partition_manager.go
- partition_placement_actor.go
- pid_cache.go
- protos.pb.go
- rendezvous.go
- rendezvousv2.go
- round_robin.go