consumertest

Sep 9, 2019

Changes in this version

+ func CreateShards(c *gc.C, cmr *Consumer, specs ...*consumer.ShardSpec)

+ func WaitForShards(ctx context.Context, rjc pb.RoutedJournalClient, conn *grpc.ClientConn, ...) error

+ type Args struct

+ App consumer.Application

+ C *gc.C

+ Etcd *clientv3.Client

+ Journals pb.RoutedJournalClient

+ Root string

+ Suffix string

+ Zone string

+ type Consumer struct

+ Server *server.Server

+ Service *consumer.Service

+ Tasks *task.Group

+ func NewConsumer(args Args) *Consumer

+ func (cmr *Consumer) AllocateIdleCh() <-chan struct{}

+ func (cmr *Consumer) Signal()