Versions in this module Expand all Collapse all v1 v1.2.0 Sep 26, 2018 Changes in this version + type Aggregator struct + func NewAggregator(c GatewayClient, shardID string, l *log.Logger) *Aggregator + func (a *Aggregator) Add(r Resource) + func (a *Aggregator) Consume() <-chan interface{} + func (a *Aggregator) List() []interface{} + func (a *Aggregator) Remove(id string) + type Communicator struct + func (a Communicator) Add(ctx context.Context, worker, task interface{}) error + func (a Communicator) List(ctx context.Context, worker interface{}) ([]interface{}, error) + func (a Communicator) Remove(ctx context.Context, worker, task interface{}) error + type GatewayClient interface + Stream func(ctx context.Context, req *loggregator_v2.EgressBatchRequest) loggregator.EnvelopeStream + type Getter interface + Get func(url string) (*http.Response, error) + type Orchestrator interface + NextTerm func(ctx context.Context) + UpdateTasks func([]orchestrator.Task) + type Resource struct + GUID string + Name string + type SingleOrSpaceProvider struct + ApiAddr string + IncludeServices bool + Source string + SpaceGuid string + func NewSingleOrSpaceProvider(sourceID string, apiAddr string, spaceID string, includeServices bool, ...) *SingleOrSpaceProvider + func (s *SingleOrSpaceProvider) Resources() ([]Resource, error) + type SingleOrSpaceProviderOption func(*SingleOrSpaceProvider) + func WithSourceProviderClient(httpClient Getter) SingleOrSpaceProviderOption + func WithSourceProviderSpaceExcludeFilter(excludeFilter SourceIDFilter) SingleOrSpaceProviderOption + type SourceIDFilter func(string) bool + type SourceManager struct + func NewSourceManager(s SourceProvider, o Orchestrator, interval time.Duration) *SourceManager + func (s *SourceManager) Start() + type SourceProvider interface + Resources func() ([]Resource, error)
Go to main page