outputs

Documentation

Index

• Variables
• func AddSubscriptionTarget(msg proto.Message, meta Meta, addTarget string, tpl *template.Template) error
• func DecodeConfig(src, dst interface{}) error
• func Register(name string, initFn Initializer)
• type Initializer
• type Meta
• type Option
  • func WithClusterName(name string) Option
  • func WithEventProcessors(eps map[string]map[string]interface{}, log *log.Logger, ...) Option
  • func WithLogger(logger *log.Logger) Option
  • func WithName(name string) Option
  • func WithRegister(reg *prometheus.Registry) Option
  • func WithTargetsConfig(tcs map[string]*types.TargetConfig) Option
• type Output

Variables

var (
	DefaultTargetTemplate = template.Must(
		template.New("target-template").
			Funcs(TemplateFuncs).
			Parse(defaultTargetTemplateString))
)

var OutputTypes = []string{
	"file",
	"influxdb",
	"kafka",
	"nats",
	"prometheus",
	"stan",
	"tcp",
	"udp",
	"gnmi",
}

var Outputs = map[string]Initializer{}

var TemplateFuncs = template.FuncMap{
	"host": utils.GetHost,
}

Functions

func AddSubscriptionTarget

func AddSubscriptionTarget(msg proto.Message, meta Meta, addTarget string, tpl *template.Template) error

func DecodeConfig

func DecodeConfig(src, dst interface{}) error

func Register

func Register(name string, initFn Initializer)

Types

type Initializer

type Initializer func() Output

type Meta

type Meta map[string]string

type Option

type Option func(Output)

func WithClusterName

func WithClusterName(name string) Option

func WithEventProcessors

func WithEventProcessors(eps map[string]map[string]interface{}, log *log.Logger, tcs map[string]*types.TargetConfig) Option

func WithLogger

func WithLogger(logger *log.Logger) Option

func WithName

func WithName(name string) Option

func WithRegister

func WithRegister(reg *prometheus.Registry) Option

func WithTargetsConfig

func WithTargetsConfig(tcs map[string]*types.TargetConfig) Option

type Output

type Output interface {
	Init(context.Context, string, map[string]interface{}, ...Option) error
	Write(context.Context, proto.Message, Meta)
	WriteEvent(context.Context, *formatters.EventMsg)
	Close() error
	RegisterMetrics(*prometheus.Registry)
	String() string

	SetLogger(*log.Logger)
	SetEventProcessors(map[string]map[string]interface{}, *log.Logger, map[string]*types.TargetConfig)
	SetName(string)
	SetClusterName(string)
	SetTargetsConfig(map[string]*types.TargetConfig)
}