output

Documentation

Index

• func NewOutputs(cfg *Config) (map[string]Interface, error)
• type Config
• type Interface

Functions

func NewOutputs

func NewOutputs(cfg *Config) (map[string]Interface, error)

NewOutputs -

Types

type Config

type Config struct {
	Elastic *elastic.Config `yaml:"elasticsearch,omitempty"`
}

Config -

type Interface

type Interface interface {
	Digest(documents []collection.Document) error
	Ensure(collection *collection.Collection) error
}

Interface interface to send msg to recipents