metricsink

type AbstractMetricSink struct {
	Logger         logger.Logger
	Name           string
	Kind           string
	MetricProvider MetricProvider
	StopChannel    chan struct{}
	StoppedChannel chan struct{}
}

type Configuration struct {
	platformconfig.MetricSink
	Name string
}

type Creator interface {

	// Create creates a metric sink instance
	Create(logger.Logger, *processor.Configuration, string, *platformconfig.MetricSink, MetricProvider) (MetricSink, error)
}

type MetricProvider interface {

	// GetTriggers returns all triggers of the processor, through which metricisinks can read
	// trigger, worker, worker pool metrics
	GetTriggers() []trigger.Trigger
}

type MetricSink interface {

	// Start starts processing metrics
	Start() error

	// Stop stops processing metrics, returns a channel that is closed when the sink actually stops
	Stop() chan struct{}

	// GetKind returns the kind of metric sink
	GetKind() string

	// GetName returns the name of metric sink
	GetName() string
}

type Registry struct {
	registry.Registry
}