offsetmgr

Sep 11, 2017

Changes in this version

type Factory

+ Spawn func(parentActDesc *actor.Descriptor, group, topic string, partition int32) (T, error)

Mar 23, 2017

Changes in this version

+ type Factory interface

+ SpawnOffsetManager func(namespace *actor.ID, group, topic string, partition int32) (T, error)

+ Stop func()

+ func SpawnFactory(namespace *actor.ID, cfg *config.Proxy, kafkaClt sarama.Client) Factory

+ type Offset struct

+ Meta string

+ Val int64

+ type T interface

+ CommittedOffsets func() <-chan Offset

+ Stop func()

+ SubmitOffset func(offset Offset)