receiver

Documentation

Index

• func Register(protocol string, newOptions func() interface{}, ...)
• func WithProtocol(options interface{}, protocol string) (map[string]interface{}, error)
• type Receiver
  • func New(name string, opts map[string]interface{}, store func(*points.Points)) (Receiver, error)

Functions

func Register

func Register(protocol string,
	newOptions func() interface{},
	newReceiver func(name string, options interface{}, store func(*points.Points)) (Receiver, error))

func WithProtocol

func WithProtocol(options interface{}, protocol string) (map[string]interface{}, error)

WithProtocol marshal options to toml, unmarshal to map[string]interface{} and add "protocol" key to them

Types

type Receiver

type Receiver interface {
	Stop()
	Stat(helper.StatCallback)
}

func New

func New(name string, opts map[string]interface{}, store func(*points.Points)) (Receiver, error)