Documentation ¶
Index ¶
- Variables
- func NewBroadcastGroup(routees ...*actor.PID) *actor.Props
- func NewBroadcastPool(size int) *actor.Props
- func NewConsistentHashGroup(routees ...*actor.PID) *actor.Props
- func NewConsistentHashPool(size int) *actor.Props
- func NewRandomGroup(routees ...*actor.PID) *actor.Props
- func NewRandomPool(size int) *actor.Props
- func NewRoundRobinGroup(routees ...*actor.PID) *actor.Props
- func NewRoundRobinPool(size int) *actor.Props
- type AddRoutee
- func (*AddRoutee) Descriptor() ([]byte, []int)
- func (this *AddRoutee) Equal(that interface{}) bool
- func (m *AddRoutee) GetPID() *actor.PID
- func (this *AddRoutee) GoString() string
- func (*AddRoutee) ManagementMessage()
- func (m *AddRoutee) Marshal() (dAtA []byte, err error)
- func (m *AddRoutee) MarshalTo(dAtA []byte) (int, error)
- func (*AddRoutee) ProtoMessage()
- func (m *AddRoutee) Reset()
- func (m *AddRoutee) Size() (n int)
- func (this *AddRoutee) String() string
- func (m *AddRoutee) Unmarshal(dAtA []byte) error
- type AdjustPoolSize
- func (*AdjustPoolSize) Descriptor() ([]byte, []int)
- func (this *AdjustPoolSize) Equal(that interface{}) bool
- func (this *AdjustPoolSize) GoString() string
- func (*AdjustPoolSize) ManagementMessage()
- func (m *AdjustPoolSize) Marshal() (dAtA []byte, err error)
- func (m *AdjustPoolSize) MarshalTo(dAtA []byte) (int, error)
- func (*AdjustPoolSize) ProtoMessage()
- func (m *AdjustPoolSize) Reset()
- func (m *AdjustPoolSize) Size() (n int)
- func (this *AdjustPoolSize) String() string
- func (m *AdjustPoolSize) Unmarshal(dAtA []byte) error
- type BroadcastMessage
- type GetRoutees
- func (*GetRoutees) Descriptor() ([]byte, []int)
- func (this *GetRoutees) Equal(that interface{}) bool
- func (this *GetRoutees) GoString() string
- func (*GetRoutees) ManagementMessage()
- func (m *GetRoutees) Marshal() (dAtA []byte, err error)
- func (m *GetRoutees) MarshalTo(dAtA []byte) (int, error)
- func (*GetRoutees) ProtoMessage()
- func (m *GetRoutees) Reset()
- func (m *GetRoutees) Size() (n int)
- func (this *GetRoutees) String() string
- func (m *GetRoutees) Unmarshal(dAtA []byte) error
- type GroupRouter
- type Hasher
- type ManagementMessage
- type PoolRouter
- type RemoveRoutee
- func (*RemoveRoutee) Descriptor() ([]byte, []int)
- func (this *RemoveRoutee) Equal(that interface{}) bool
- func (m *RemoveRoutee) GetPID() *actor.PID
- func (this *RemoveRoutee) GoString() string
- func (*RemoveRoutee) ManagementMessage()
- func (m *RemoveRoutee) Marshal() (dAtA []byte, err error)
- func (m *RemoveRoutee) MarshalTo(dAtA []byte) (int, error)
- func (*RemoveRoutee) ProtoMessage()
- func (m *RemoveRoutee) Reset()
- func (m *RemoveRoutee) Size() (n int)
- func (this *RemoveRoutee) String() string
- func (m *RemoveRoutee) Unmarshal(dAtA []byte) error
- type Routees
- func (*Routees) Descriptor() ([]byte, []int)
- func (this *Routees) Equal(that interface{}) bool
- func (m *Routees) GetPIDs() []*actor.PID
- func (this *Routees) GoString() string
- func (m *Routees) Marshal() (dAtA []byte, err error)
- func (m *Routees) MarshalTo(dAtA []byte) (int, error)
- func (*Routees) ProtoMessage()
- func (m *Routees) Reset()
- func (m *Routees) Size() (n int)
- func (this *Routees) String() string
- func (m *Routees) Unmarshal(dAtA []byte) error
- type RouterConfig
- type RouterState
- type RouterType
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthProtos = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowProtos = fmt.Errorf("proto: integer overflow") )
Functions ¶
func NewBroadcastPool ¶
func NewConsistentHashPool ¶
func NewRandomPool ¶
func NewRoundRobinPool ¶
Types ¶
type AddRoutee ¶
func (*AddRoutee) Descriptor ¶
func (*AddRoutee) ManagementMessage ¶
func (*AddRoutee) ManagementMessage()
func (*AddRoutee) ProtoMessage ¶
func (*AddRoutee) ProtoMessage()
type AdjustPoolSize ¶
type AdjustPoolSize struct {
Change int32 `protobuf:"varint,1,opt,name=change,proto3" json:"change,omitempty"`
}
func (*AdjustPoolSize) Descriptor ¶
func (*AdjustPoolSize) Descriptor() ([]byte, []int)
func (*AdjustPoolSize) Equal ¶
func (this *AdjustPoolSize) Equal(that interface{}) bool
func (*AdjustPoolSize) GoString ¶
func (this *AdjustPoolSize) GoString() string
func (*AdjustPoolSize) ManagementMessage ¶
func (*AdjustPoolSize) ManagementMessage()
func (*AdjustPoolSize) Marshal ¶
func (m *AdjustPoolSize) Marshal() (dAtA []byte, err error)
func (*AdjustPoolSize) ProtoMessage ¶
func (*AdjustPoolSize) ProtoMessage()
func (*AdjustPoolSize) Reset ¶
func (m *AdjustPoolSize) Reset()
func (*AdjustPoolSize) Size ¶
func (m *AdjustPoolSize) Size() (n int)
func (*AdjustPoolSize) String ¶
func (this *AdjustPoolSize) String() string
func (*AdjustPoolSize) Unmarshal ¶
func (m *AdjustPoolSize) Unmarshal(dAtA []byte) error
type BroadcastMessage ¶
type BroadcastMessage struct {
Message interface{}
}
func (*BroadcastMessage) ManagementMessage ¶
func (*BroadcastMessage) ManagementMessage()
type GetRoutees ¶
type GetRoutees struct { }
func (*GetRoutees) Descriptor ¶
func (*GetRoutees) Descriptor() ([]byte, []int)
func (*GetRoutees) Equal ¶
func (this *GetRoutees) Equal(that interface{}) bool
func (*GetRoutees) GoString ¶
func (this *GetRoutees) GoString() string
func (*GetRoutees) ManagementMessage ¶
func (*GetRoutees) ManagementMessage()
func (*GetRoutees) Marshal ¶
func (m *GetRoutees) Marshal() (dAtA []byte, err error)
func (*GetRoutees) ProtoMessage ¶
func (*GetRoutees) ProtoMessage()
func (*GetRoutees) Reset ¶
func (m *GetRoutees) Reset()
func (*GetRoutees) Size ¶
func (m *GetRoutees) Size() (n int)
func (*GetRoutees) String ¶
func (this *GetRoutees) String() string
func (*GetRoutees) Unmarshal ¶
func (m *GetRoutees) Unmarshal(dAtA []byte) error
type GroupRouter ¶
func (*GroupRouter) OnStarted ¶
func (config *GroupRouter) OnStarted(context actor.Context, props *actor.Props, state RouterState)
func (*GroupRouter) RouterType ¶
func (config *GroupRouter) RouterType() RouterType
type ManagementMessage ¶
type ManagementMessage interface {
ManagementMessage()
}
type PoolRouter ¶
type PoolRouter struct {
PoolSize int
}
func (*PoolRouter) OnStarted ¶
func (config *PoolRouter) OnStarted(context actor.Context, props *actor.Props, state RouterState)
func (*PoolRouter) RouterType ¶
func (config *PoolRouter) RouterType() RouterType
type RemoveRoutee ¶
func (*RemoveRoutee) Descriptor ¶
func (*RemoveRoutee) Descriptor() ([]byte, []int)
func (*RemoveRoutee) Equal ¶
func (this *RemoveRoutee) Equal(that interface{}) bool
func (*RemoveRoutee) GetPID ¶
func (m *RemoveRoutee) GetPID() *actor.PID
func (*RemoveRoutee) GoString ¶
func (this *RemoveRoutee) GoString() string
func (*RemoveRoutee) ManagementMessage ¶
func (*RemoveRoutee) ManagementMessage()
func (*RemoveRoutee) Marshal ¶
func (m *RemoveRoutee) Marshal() (dAtA []byte, err error)
func (*RemoveRoutee) ProtoMessage ¶
func (*RemoveRoutee) ProtoMessage()
func (*RemoveRoutee) Reset ¶
func (m *RemoveRoutee) Reset()
func (*RemoveRoutee) Size ¶
func (m *RemoveRoutee) Size() (n int)
func (*RemoveRoutee) String ¶
func (this *RemoveRoutee) String() string
func (*RemoveRoutee) Unmarshal ¶
func (m *RemoveRoutee) Unmarshal(dAtA []byte) error
type Routees ¶
func (*Routees) Descriptor ¶
func (*Routees) ProtoMessage ¶
func (*Routees) ProtoMessage()
type RouterConfig ¶
type RouterConfig interface { RouterType() RouterType OnStarted(context actor.Context, props *actor.Props, state RouterState) CreateRouterState() RouterState }
Click to show internal directories.
Click to hide internal directories.