dispatcher

Sep 11, 2017

Changes in this version

+ func WithChildSpec(childSpec ChildSpec) option

+ func WithFinalizer(finalizer func()) option

+ type ChildSpec struct

+ func NewChildSpec4Test(requests chan consumer.Request) ChildSpec

+ func (cs *ChildSpec) Dispose()

+ func (cs *ChildSpec) Key() Key

+ func (cs *ChildSpec) Requests() <-chan consumer.Request

type Factory

+ SpawnChild func(childSpec ChildSpec)

+ type Key string

type T

+ func Spawn(parentActDesc *actor.Descriptor, factory Factory, cfg *config.Proxy, ...) *T

+ func (d *T) Wait4Stop(timeout time.Duration) bool

May 3, 2016

Changes in this version

+ type Factory interface

+ KeyOf func(req Request) string

+ NewTier func(key string) Tier

+ type Request struct

+ Group string

+ ResponseCh chan<- Response

+ Timestamp time.Time

+ Topic string

+ type Response struct

+ Err error

+ Msg *consumer.Message

+ type T struct

+ func New(namespace *actor.ID, factory Factory, cfg *config.T) *T

+ func (d *T) Requests() chan<- Request

+ func (d *T) Start()

+ func (d *T) Stop()

+ type Tier interface

+ Key func() string

+ Requests func() chan<- Request

+ Start func(stoppedCh chan<- Tier)

+ Stop func()