builder

Documentation

Index

• func NewOperatorBuilder(outputCfg output.Config, executorCfg JobRunnerBuilder) operator.Builder
• type JobRunner
• type JobRunnerBuilder

Functions

func NewOperatorBuilder

func NewOperatorBuilder(outputCfg output.Config, executorCfg JobRunnerBuilder) operator.Builder

NewOperatorBuilder builds a stanza operator.Builder from monitoring job configuration objects.

Types

type JobRunner

type JobRunner interface {
	Start(operator.Persister) error
	Stop() error
}

type JobRunnerBuilder

type JobRunnerBuilder interface {
	Build(logger *zap.SugaredLogger, consumer consumer.Interface) (JobRunner, error)
}