mapper

Mar 23, 2017

Changes in this version

type T

+ func (m *T) OnWorkerSpawned(w Worker)

+ func (m *T) OnWorkerStopped(w Worker)

+ func (m *T) TriggerReassign(w Worker)

May 3, 2016

Changes in this version

+ type Executor interface

+ BrokerConn func() *sarama.Broker

+ Stop func()

+ type Resolver interface

+ ResolveBroker func(pw Worker) (*sarama.Broker, error)

+ SpawnExecutor func(brokerConn *sarama.Broker) Executor

+ type T struct

+ func Spawn(namespace *actor.ID, resolver Resolver) *T

+ func (m *T) Stop()

+ func (m *T) WorkerReassign() chan<- Worker

+ func (m *T) WorkerSpawned() chan<- Worker

+ func (m *T) WorkerStopped() chan<- Worker

+ type Worker interface

+ Assignment func() chan<- Executor