Versions in this module Expand all Collapse all v0 v0.0.2 Sep 5, 2019 Changes in this version + var ErrNotEnoughSubscribers = errors.New("not enough subscribers") + type IngestionAssignmentTaskParams struct + AssignmentsMutator common.IngestionAssignmentMutator + ConfigProvider config.Provider + EtcdClient *kvstore.EtcdClient + JobMutator common.JobMutator + Logger *zap.SugaredLogger + NamespaceMutator common.NamespaceMutator + SchemaMutator common.TableSchemaMutator + Scope tally.Scope + SubscriberMutator common.SubscriberMutator + type Task interface + Done func() + Run func()
Go to main page