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

package router

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

Index

Package Files

broadcast_router.go config.go consistent_hash_router.go messages.go process.go protos.pb.go random_router.go roundrobin_router.go router.go routeractor_group.go routeractor_pool.go spawn.go

Variables

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

func NewBroadcastGroup Uses

func NewBroadcastGroup(routees ...*actor.PID) *actor.Props

func NewBroadcastPool Uses

func NewBroadcastPool(size int) *actor.Props

func NewConsistentHashGroup Uses

func NewConsistentHashGroup(routees ...*actor.PID) *actor.Props

func NewConsistentHashPool Uses

func NewConsistentHashPool(size int) *actor.Props

func NewRandomGroup Uses

func NewRandomGroup(routees ...*actor.PID) *actor.Props

func NewRandomPool Uses

func NewRandomPool(size int) *actor.Props

func NewRoundRobinGroup Uses

func NewRoundRobinGroup(routees ...*actor.PID) *actor.Props

func NewRoundRobinPool Uses

func NewRoundRobinPool(size int) *actor.Props

type AddRoutee Uses

type AddRoutee struct {
    PID *actor.PID `protobuf:"bytes,1,opt,name=PID" json:"PID,omitempty"`
}

func (*AddRoutee) Descriptor Uses

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

func (*AddRoutee) Equal Uses

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

func (*AddRoutee) GetPID Uses

func (m *AddRoutee) GetPID() *actor.PID

func (*AddRoutee) GoString Uses

func (this *AddRoutee) GoString() string

func (*AddRoutee) ManagementMessage Uses

func (*AddRoutee) ManagementMessage()

func (*AddRoutee) Marshal Uses

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

func (*AddRoutee) MarshalTo Uses

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

func (*AddRoutee) ProtoMessage Uses

func (*AddRoutee) ProtoMessage()

func (*AddRoutee) Reset Uses

func (m *AddRoutee) Reset()

func (*AddRoutee) Size Uses

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

func (*AddRoutee) String Uses

func (this *AddRoutee) String() string

func (*AddRoutee) Unmarshal Uses

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

type AdjustPoolSize Uses

type AdjustPoolSize struct {
    Change int32 `protobuf:"varint,1,opt,name=change,proto3" json:"change,omitempty"`
}

func (*AdjustPoolSize) Descriptor Uses

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

func (*AdjustPoolSize) Equal Uses

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

func (*AdjustPoolSize) GoString Uses

func (this *AdjustPoolSize) GoString() string

func (*AdjustPoolSize) ManagementMessage Uses

func (*AdjustPoolSize) ManagementMessage()

func (*AdjustPoolSize) Marshal Uses

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

func (*AdjustPoolSize) MarshalTo Uses

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

func (*AdjustPoolSize) ProtoMessage Uses

func (*AdjustPoolSize) ProtoMessage()

func (*AdjustPoolSize) Reset Uses

func (m *AdjustPoolSize) Reset()

func (*AdjustPoolSize) Size Uses

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

func (*AdjustPoolSize) String Uses

func (this *AdjustPoolSize) String() string

func (*AdjustPoolSize) Unmarshal Uses

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

type BroadcastMessage Uses

type BroadcastMessage struct {
    Message interface{}
}

func (*BroadcastMessage) ManagementMessage Uses

func (*BroadcastMessage) ManagementMessage()

type GetRoutees Uses

type GetRoutees struct {
}

func (*GetRoutees) Descriptor Uses

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

func (*GetRoutees) Equal Uses

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

func (*GetRoutees) GoString Uses

func (this *GetRoutees) GoString() string

func (*GetRoutees) ManagementMessage Uses

func (*GetRoutees) ManagementMessage()

func (*GetRoutees) Marshal Uses

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

func (*GetRoutees) MarshalTo Uses

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

func (*GetRoutees) ProtoMessage Uses

func (*GetRoutees) ProtoMessage()

func (*GetRoutees) Reset Uses

func (m *GetRoutees) Reset()

func (*GetRoutees) Size Uses

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

func (*GetRoutees) String Uses

func (this *GetRoutees) String() string

func (*GetRoutees) Unmarshal Uses

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

type GroupRouter Uses

type GroupRouter struct {
    Routees *actor.PIDSet
}

func (*GroupRouter) OnStarted Uses

func (config *GroupRouter) OnStarted(context actor.Context, props *actor.Props, router Interface)

func (*GroupRouter) RouterType Uses

func (config *GroupRouter) RouterType() RouterType

type Hasher Uses

type Hasher interface {
    Hash() string
}

type Interface Uses

type Interface interface {
    RouteMessage(message interface{}, sender *actor.PID)
    SetRoutees(routees *actor.PIDSet)
    GetRoutees() *actor.PIDSet
}

A type that satisfies router.Interface can be used as a router

type ManagementMessage Uses

type ManagementMessage interface {
    ManagementMessage()
}

type PoolRouter Uses

type PoolRouter struct {
    PoolSize int
}

func (*PoolRouter) OnStarted Uses

func (config *PoolRouter) OnStarted(context actor.Context, props *actor.Props, router Interface)

func (*PoolRouter) RouterType Uses

func (config *PoolRouter) RouterType() RouterType

type RemoveRoutee Uses

type RemoveRoutee struct {
    PID *actor.PID `protobuf:"bytes,1,opt,name=PID" json:"PID,omitempty"`
}

func (*RemoveRoutee) Descriptor Uses

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

func (*RemoveRoutee) Equal Uses

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

func (*RemoveRoutee) GetPID Uses

func (m *RemoveRoutee) GetPID() *actor.PID

func (*RemoveRoutee) GoString Uses

func (this *RemoveRoutee) GoString() string

func (*RemoveRoutee) ManagementMessage Uses

func (*RemoveRoutee) ManagementMessage()

func (*RemoveRoutee) Marshal Uses

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

func (*RemoveRoutee) MarshalTo Uses

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

func (*RemoveRoutee) ProtoMessage Uses

func (*RemoveRoutee) ProtoMessage()

func (*RemoveRoutee) Reset Uses

func (m *RemoveRoutee) Reset()

func (*RemoveRoutee) Size Uses

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

func (*RemoveRoutee) String Uses

func (this *RemoveRoutee) String() string

func (*RemoveRoutee) Unmarshal Uses

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

type Routees Uses

type Routees struct {
    PIDs []*actor.PID `protobuf:"bytes,1,rep,name=PIDs" json:"PIDs,omitempty"`
}

func (*Routees) Descriptor Uses

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

func (*Routees) Equal Uses

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

func (*Routees) GetPIDs Uses

func (m *Routees) GetPIDs() []*actor.PID

func (*Routees) GoString Uses

func (this *Routees) GoString() string

func (*Routees) Marshal Uses

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

func (*Routees) MarshalTo Uses

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

func (*Routees) ProtoMessage Uses

func (*Routees) ProtoMessage()

func (*Routees) Reset Uses

func (m *Routees) Reset()

func (*Routees) Size Uses

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

func (*Routees) String Uses

func (this *Routees) String() string

func (*Routees) Unmarshal Uses

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

type RouterConfig Uses

type RouterConfig interface {
    RouterType() RouterType
    OnStarted(context actor.Context, props *actor.Props, router Interface)
    CreateRouterState() Interface
}

type RouterType Uses

type RouterType int
const (
    GroupRouterType RouterType = iota
    PoolRouterType
)

Package router imports 15 packages (graph) and is imported by 1 packages. Updated 2017-07-31. Refresh now. Tools for package owners.