groupcsm

Sep 11, 2017

Changes in this version

type T

+ func Spawn(parentActDesc *actor.Descriptor, childSpec dispatcher.ChildSpec, ...) *T

+ func (gc *T) SpawnChild(childSpec dispatcher.ChildSpec)

May 3, 2016

Changes in this version

+ type Int32Slice []int32

+ func (p Int32Slice) Len() int

+ func (p Int32Slice) Less(i, j int) bool

+ func (p Int32Slice) Swap(i, j int)

+ type T struct

+ func New(namespace *actor.ID, group string, cfg *config.T, saramaClient sarama.Client, ...) *T

+ func (gc *T) Key() string

+ func (gc *T) KeyOf(req dispatcher.Request) string

+ func (gc *T) NewTier(key string) dispatcher.Tier

+ func (gc *T) Requests() chan<- dispatcher.Request

+ func (gc *T) Start(stoppedCh chan<- dispatcher.Tier)

+ func (gc *T) Stop()

+ func (gc *T) String() string