aggregator

Documentation

Index

• type Aggregator
  • func NewK8sAggregator(config *config.Config, restConfig *rest.Config) (Aggregator, error)
• type PipeCloser

Types

type Aggregator

type Aggregator interface {
	Serve(ctx context.Context) error
}

Aggregator pulls data from workers and sends them to Wharf API.

func NewK8sAggregator

func NewK8sAggregator(config *config.Config, restConfig *rest.Config) (Aggregator, error)

NewK8sAggregator returns a new Aggregator implementation that targets Kubernetes using a specific Kubernetes namespace and REST config.

type PipeCloser

type PipeCloser interface {
	// PipeMessage should pipe a single message, and when done should return
	// io.EOF to indicate success.
	PipeMessage() error

	io.Closer
}

PipeCloser pipes data, and should always be closed when done with it.