sinks

Documentation

Index

• type Data
• type InfluxdbSink
  • func (self *InfluxdbSink) StoreData(ip Data) error
• type MemorySink
  • func (self *MemorySink) StoreData(data Data) error
• type Sink
  • func NewInfluxdbSink() (Sink, error)
  • func NewMemorySink() Sink
  • func NewSink() (Sink, error)

Types

type Data

type Data interface{}

type InfluxdbSink

type InfluxdbSink struct {
	// contains filtered or unexported fields
}

func (*InfluxdbSink) StoreData

func (self *InfluxdbSink) StoreData(ip Data) error

type MemorySink

type MemorySink struct {
	// contains filtered or unexported fields
}

func (*MemorySink) StoreData

func (self *MemorySink) StoreData(data Data) error

type Sink

type Sink interface {
	StoreData(data Data) error
}

func NewInfluxdbSink

func NewInfluxdbSink() (Sink, error)

func NewMemorySink

func NewMemorySink() Sink

func NewSink

func NewSink() (Sink, error)