Versions in this module Expand all Collapse all v1 v1.0.0 Feb 19, 2019 Changes in this version + var ErrIntOverflowProtos = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthProtos = fmt.Errorf("proto: negative length found during unmarshaling") + func Get(name string, kind string) (*actor.PID, remote.ResponseStatusCode) + func GetMemberPIDs(kind string) actor.PIDSet + func RemoveCache(name string) + func Shutdown(graceful bool) + func Start(clusterName, address string, provider ClusterProvider) + func StartWithConfig(config *ClusterConfig) + type ClusterConfig struct + Address string + ClusterProvider ClusterProvider + InitialMemberStatusValue MemberStatusValue + MemberStatusValueSerializer MemberStatusValueSerializer + MemberStrategyBuilder func(kind string) MemberStrategy + Name string + RemotingOption []remote.RemotingOption + TimeoutTime time.Duration + func NewClusterConfig(name string, address string, clusterProvider ClusterProvider) *ClusterConfig + func (c *ClusterConfig) WithInitialMemberStatusValue(val MemberStatusValue) *ClusterConfig + func (c *ClusterConfig) WithMemberStatusValueSerializer(serializer MemberStatusValueSerializer) *ClusterConfig + func (c *ClusterConfig) WithMemberStrategyBuilder(builder func(kind string) MemberStrategy) *ClusterConfig + func (c *ClusterConfig) WithRemotingOption(remotingOption []remote.RemotingOption) *ClusterConfig + func (c *ClusterConfig) WithTimeout(t time.Duration) *ClusterConfig + type ClusterProvider interface + DeregisterMember func() error + MonitorMemberStatusChanges func() + RegisterMember func(clusterName string, address string, port int, knownKinds []string, ...) error + Shutdown func() error + UpdateMemberStatusValue func(statusValue MemberStatusValue) error + type ClusterTopologyEvent []*MemberStatus + type Grain struct + func (g *Grain) ID() string + func (g *Grain) Init(id string) + type GrainCallOptions struct + RetryAction func(n int) + RetryCount int + Timeout time.Duration + func DefaultGrainCallOptions() *GrainCallOptions + func NewGrainCallOptions() *GrainCallOptions + func (config *GrainCallOptions) WithRetry(count int) *GrainCallOptions + func (config *GrainCallOptions) WithRetryAction(act func(i int)) *GrainCallOptions + func (config *GrainCallOptions) WithTimeout(timeout time.Duration) *GrainCallOptions + type GrainContext interface + Children func() []*actor.PID + Message func() interface{} + Request func(pid *actor.PID, message interface{}) + RequestFuture func(pid *actor.PID, message interface{}, timeout time.Duration) *actor.Future + Self func() *actor.PID + Sender func() *actor.PID + Spawn func(props *actor.Props) *actor.PID + SpawnNamed func(props *actor.Props, id string) (*actor.PID, error) + SpawnPrefix func(props *actor.Props, prefix string) *actor.PID + Tell func(pid *actor.PID, message interface{}) + Unwatch func(pid *actor.PID) + Watch func(pid *actor.PID) + type GrainErrorResponse struct + Err string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*GrainErrorResponse) Descriptor() ([]byte, []int) + func (*GrainErrorResponse) ProtoMessage() + func (dst *GrainErrorResponse) XXX_Merge(src proto.Message) + func (m *GrainErrorResponse) GetErr() string + func (m *GrainErrorResponse) Marshal() (dAtA []byte, err error) + func (m *GrainErrorResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GrainErrorResponse) Reset() + func (m *GrainErrorResponse) Size() (n int) + 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_Size() int + func (m *GrainErrorResponse) XXX_Unmarshal(b []byte) error + func (this *GrainErrorResponse) Equal(that interface{}) bool + func (this *GrainErrorResponse) String() string + type GrainRequest struct + MessageData []byte + Method string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*GrainRequest) Descriptor() ([]byte, []int) + func (*GrainRequest) ProtoMessage() + func (dst *GrainRequest) XXX_Merge(src proto.Message) + func (m *GrainRequest) GetMessageData() []byte + func (m *GrainRequest) GetMethod() string + func (m *GrainRequest) Marshal() (dAtA []byte, err error) + func (m *GrainRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GrainRequest) Reset() + func (m *GrainRequest) Size() (n int) + 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_Size() int + func (m *GrainRequest) XXX_Unmarshal(b []byte) error + func (this *GrainRequest) Equal(that interface{}) bool + func (this *GrainRequest) String() string + type GrainResponse struct + MessageData []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*GrainResponse) Descriptor() ([]byte, []int) + func (*GrainResponse) ProtoMessage() + func (dst *GrainResponse) XXX_Merge(src proto.Message) + func (m *GrainResponse) GetMessageData() []byte + func (m *GrainResponse) Marshal() (dAtA []byte, err error) + func (m *GrainResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GrainResponse) Reset() + func (m *GrainResponse) Size() (n int) + 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_Size() int + func (m *GrainResponse) XXX_Unmarshal(b []byte) error + func (this *GrainResponse) Equal(that interface{}) bool + func (this *GrainResponse) String() string + type MemberAvailableEvent struct + func (*MemberAvailableEvent) MemberStatusEvent() + type MemberJoinedEvent struct + func (*MemberJoinedEvent) MemberStatusEvent() + type MemberLeftEvent struct + func (*MemberLeftEvent) MemberStatusEvent() + 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 MemberStatus struct + Alive bool + Host string + Kinds []string + MemberID string + Port int + StatusValue MemberStatusValue + func (m *MemberStatus) Address() string + type MemberStatusEvent interface + GetKinds func() []string + MemberStatusEvent func() + type MemberStatusValue interface + IsSame func(val MemberStatusValue) bool + type MemberStatusValueSerializer interface + FromValueBytes func(val []byte) MemberStatusValue + ToValueBytes func(val MemberStatusValue) []byte + type MemberStrategy interface + AddMember func(member *MemberStatus) + GetActivator func() string + GetAllMembers func() []*MemberStatus + GetPartition func(key string) string + RemoveMember func(member *MemberStatus) + UpdateMember func(member *MemberStatus) + type MemberUnavailableEvent struct + func (*MemberUnavailableEvent) MemberStatusEvent() + type NilMemberStatusValueSerializer struct + func (s *NilMemberStatusValueSerializer) FromValueBytes(val []byte) MemberStatusValue + func (s *NilMemberStatusValueSerializer) ToValueBytes(val MemberStatusValue) []byte + type Rendezvous struct + func NewRendezvous(memberStrategy MemberStrategy) *Rendezvous + func (r *Rendezvous) GetByRdv(key string) string + func (r *Rendezvous) UpdateRdv() + type SimpleRoundRobin struct + func NewSimpleRoundRobin(memberStrategy MemberStrategy) *SimpleRoundRobin + func (r *SimpleRoundRobin) GetByRoundRobin() string + type TakeOwnership struct + Name string + Pid *actor.PID + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*TakeOwnership) Descriptor() ([]byte, []int) + func (*TakeOwnership) ProtoMessage() + func (dst *TakeOwnership) XXX_Merge(src proto.Message) + 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) Reset() + func (m *TakeOwnership) Size() (n int) + 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_Size() int + func (m *TakeOwnership) XXX_Unmarshal(b []byte) error + func (this *TakeOwnership) Equal(that interface{}) bool + func (this *TakeOwnership) String() string