lokiplugin

Documentation

Index

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

Types

type Loki

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

Loki plugin interface

func NewPlugin

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

NewPlugin returns Loki output plugin