valiplugin

Documentation

Index

• type Vali
  • func NewPlugin(informer cache.SharedIndexInformer, cfg *config.Config, logger log.Logger) (Vali, error)

Types

type Vali

type Vali interface {
	SendRecord(r map[interface{}]interface{}, ts time.Time) error
	Close()
}

Vali plugin interface

func NewPlugin

func NewPlugin(informer cache.SharedIndexInformer, cfg *config.Config, logger log.Logger) (Vali, error)

NewPlugin returns Vali output plugin