protoactor-go: github.com/AsynkronIT/protoactor-go/cluster Index | Files | Directories

package cluster

import "github.com/AsynkronIT/protoactor-go/cluster"

Index

Package Files

cluster.go cluster_provider.go grain.go hashring.go log.go member_status_events.go memberlist.go memberlist_actor.go partition_actor.go pid_cache.go protos.pb.go

Variables

var (
    ErrInvalidLengthProtos = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowProtos   = fmt.Errorf("proto: integer overflow")
)

func Get Uses

func Get(name string, kind string) (*actor.PID, error)

Get a PID to a virtual actor

func SetLogLevel Uses

func SetLogLevel(level log.Level)

SetLogLevel sets the log level for the logger.

SetLogLevel is safe to call concurrently

func Start Uses

func Start(clusterName, address string, provider ClusterProvider)

type ClusterProvider Uses

type ClusterProvider interface {
    RegisterMember(clusterName string, address string, port int, knownKinds []string) error
    MonitorMemberStatusChanges()
    Shutdown() error
}

type ClusterTopologyEvent Uses

type ClusterTopologyEvent []*MemberStatus

type Grain Uses

type Grain struct {
    // contains filtered or unexported fields
}

func (*Grain) ID Uses

func (g *Grain) ID() string

func (*Grain) Init Uses

func (g *Grain) Init(id string)

type GrainCallConfig Uses

type GrainCallConfig struct {
    RetryCount int
    Timeout    time.Duration
}

func ApplyGrainCallOptions Uses

func ApplyGrainCallOptions(options []GrainCallOption) *GrainCallConfig

func DefaultGrainCallConfig Uses

func DefaultGrainCallConfig() *GrainCallConfig

type GrainCallOption Uses

type GrainCallOption func(*GrainCallConfig)

func WithRetry Uses

func WithRetry(count int) GrainCallOption

func WithTimeout Uses

func WithTimeout(timeout time.Duration) GrainCallOption

type GrainErrorResponse Uses

type GrainErrorResponse struct {
    Err string `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
}

func (*GrainErrorResponse) Descriptor Uses

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

func (*GrainErrorResponse) Equal Uses

func (this *GrainErrorResponse) Equal(that interface{}) bool

func (*GrainErrorResponse) Marshal Uses

func (m *GrainErrorResponse) Marshal() (dAtA []byte, err error)

func (*GrainErrorResponse) MarshalTo Uses

func (m *GrainErrorResponse) MarshalTo(dAtA []byte) (int, error)

func (*GrainErrorResponse) ProtoMessage Uses

func (*GrainErrorResponse) ProtoMessage()

func (*GrainErrorResponse) Reset Uses

func (m *GrainErrorResponse) Reset()

func (*GrainErrorResponse) Size Uses

func (m *GrainErrorResponse) Size() (n int)

func (*GrainErrorResponse) String Uses

func (this *GrainErrorResponse) String() string

func (*GrainErrorResponse) Unmarshal Uses

func (m *GrainErrorResponse) Unmarshal(dAtA []byte) error

type GrainRequest Uses

type GrainRequest struct {
    Method      string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
    MessageData []byte `protobuf:"bytes,2,opt,name=message_data,json=messageData,proto3" json:"message_data,omitempty"`
}

func (*GrainRequest) Descriptor Uses

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

func (*GrainRequest) Equal Uses

func (this *GrainRequest) Equal(that interface{}) bool

func (*GrainRequest) Marshal Uses

func (m *GrainRequest) Marshal() (dAtA []byte, err error)

func (*GrainRequest) MarshalTo Uses

func (m *GrainRequest) MarshalTo(dAtA []byte) (int, error)

func (*GrainRequest) ProtoMessage Uses

func (*GrainRequest) ProtoMessage()

func (*GrainRequest) Reset Uses

func (m *GrainRequest) Reset()

func (*GrainRequest) Size Uses

func (m *GrainRequest) Size() (n int)

func (*GrainRequest) String Uses

func (this *GrainRequest) String() string

func (*GrainRequest) Unmarshal Uses

func (m *GrainRequest) Unmarshal(dAtA []byte) error

type GrainResponse Uses

type GrainResponse struct {
    MessageData []byte `protobuf:"bytes,1,opt,name=message_data,json=messageData,proto3" json:"message_data,omitempty"`
}

func (*GrainResponse) Descriptor Uses

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

func (*GrainResponse) Equal Uses

func (this *GrainResponse) Equal(that interface{}) bool

func (*GrainResponse) Marshal Uses

func (m *GrainResponse) Marshal() (dAtA []byte, err error)

func (*GrainResponse) MarshalTo Uses

func (m *GrainResponse) MarshalTo(dAtA []byte) (int, error)

func (*GrainResponse) ProtoMessage Uses

func (*GrainResponse) ProtoMessage()

func (*GrainResponse) Reset Uses

func (m *GrainResponse) Reset()

func (*GrainResponse) Size Uses

func (m *GrainResponse) Size() (n int)

func (*GrainResponse) String Uses

func (this *GrainResponse) String() string

func (*GrainResponse) Unmarshal Uses

func (m *GrainResponse) Unmarshal(dAtA []byte) error

type MemberAvailableEvent Uses

type MemberAvailableEvent struct {
    MemberMeta
}

func (*MemberAvailableEvent) MemberStatusEvent Uses

func (*MemberAvailableEvent) MemberStatusEvent()

type MemberByKindRequest Uses

type MemberByKindRequest struct {
    // contains filtered or unexported fields
}

type MemberByKindResponse Uses

type MemberByKindResponse struct {
    // contains filtered or unexported fields
}

type MemberJoinedEvent Uses

type MemberJoinedEvent struct {
    MemberMeta
}

func (*MemberJoinedEvent) MemberStatusEvent Uses

func (*MemberJoinedEvent) MemberStatusEvent()

type MemberLeftEvent Uses

type MemberLeftEvent struct {
    MemberMeta
}

func (*MemberLeftEvent) MemberStatusEvent Uses

func (*MemberLeftEvent) MemberStatusEvent()

type MemberMeta Uses

type MemberMeta struct {
    Host  string
    Port  int
    Kinds []string
}

func (*MemberMeta) GetKinds Uses

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

func (*MemberMeta) Name Uses

func (e *MemberMeta) Name() string

type MemberRejoinedEvent Uses

type MemberRejoinedEvent struct {
    MemberMeta
}

func (*MemberRejoinedEvent) MemberStatusEvent Uses

func (*MemberRejoinedEvent) MemberStatusEvent()

type MemberStatus Uses

type MemberStatus struct {
    MemberID string
    Host     string
    Port     int
    Kinds    []string
    Alive    bool
}

type MemberStatusEvent Uses

type MemberStatusEvent interface {
    MemberStatusEvent()
    GetKinds() []string
}

type MemberUnavailableEvent Uses

type MemberUnavailableEvent struct {
    MemberMeta
}

func (*MemberUnavailableEvent) MemberStatusEvent Uses

func (*MemberUnavailableEvent) MemberStatusEvent()

type TakeOwnership Uses

type TakeOwnership struct {
    Pid  *actor.PID `protobuf:"bytes,1,opt,name=pid" json:"pid,omitempty"`
    Name string     `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
}

func (*TakeOwnership) Descriptor Uses

func (*TakeOwnership) Descriptor() ([]byte, []int)

func (*TakeOwnership) Equal Uses

func (this *TakeOwnership) Equal(that interface{}) bool

func (*TakeOwnership) GetPid Uses

func (m *TakeOwnership) GetPid() *actor.PID

func (*TakeOwnership) Marshal Uses

func (m *TakeOwnership) Marshal() (dAtA []byte, err error)

func (*TakeOwnership) MarshalTo Uses

func (m *TakeOwnership) MarshalTo(dAtA []byte) (int, error)

func (*TakeOwnership) ProtoMessage Uses

func (*TakeOwnership) ProtoMessage()

func (*TakeOwnership) Reset Uses

func (m *TakeOwnership) Reset()

func (*TakeOwnership) Size Uses

func (m *TakeOwnership) Size() (n int)

func (*TakeOwnership) String Uses

func (this *TakeOwnership) String() string

func (*TakeOwnership) Unmarshal Uses

func (m *TakeOwnership) Unmarshal(dAtA []byte) error

Directories

PathSynopsis
consul

Package cluster imports 17 packages (graph) and is imported by 1 packages. Updated 2017-08-08. Refresh now. Tools for package owners.