sinks

Documentation

Index

• Variables
• func NewLogSink() *collectors.FuncCollector
• func NewLogSinkToMemory() *collectors.FuncCollector
• type MQTTSink
  • func (ms *MQTTSink) Close(ctx api.StreamContext) error
  • func (ms *MQTTSink) Collect(ctx api.StreamContext, item interface{}) error
  • func (ms *MQTTSink) Configure(ps map[string]interface{}) error
  • func (ms *MQTTSink) Open(ctx api.StreamContext) error
• type MultiErrors
  • func (me MultiErrors) AddError(err error) MultiErrors
  • func (me MultiErrors) Error() string
• type NopSink
  • func (ns *NopSink) Close(ctx api.StreamContext) error
  • func (ns *NopSink) Collect(ctx api.StreamContext, item interface{}) error
  • func (ns *NopSink) Configure(ps map[string]interface{}) error
  • func (ns *NopSink) Open(ctx api.StreamContext) error
• type QueryResult
• type RestSink
  • func (ms *RestSink) Close(ctx api.StreamContext) error
  • func (ms *RestSink) Collect(ctx api.StreamContext, item interface{}) error
  • func (ms *RestSink) Configure(ps map[string]interface{}) error
  • func (ms *RestSink) Open(ctx api.StreamContext) error
  • func (ms *RestSink) Send(v interface{}, logger api.Logger) (*http.Response, error)

Variables

var QR = &QueryResult{LastFetch: time.Now()}

Functions

func NewLogSink

func NewLogSink() *collectors.FuncCollector

log action, no properties now example: {"log":{}}

func NewLogSinkToMemory

func NewLogSinkToMemory() *collectors.FuncCollector

Types

type MQTTSink

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

func (*MQTTSink) Close

func (ms *MQTTSink) Close(ctx api.StreamContext) error

func (*MQTTSink) Collect

func (ms *MQTTSink) Collect(ctx api.StreamContext, item interface{}) error

func (*MQTTSink) Configure

func (ms *MQTTSink) Configure(ps map[string]interface{}) error

func (*MQTTSink) Open

func (ms *MQTTSink) Open(ctx api.StreamContext) error

type MultiErrors

type MultiErrors []error

func (MultiErrors) AddError

func (me MultiErrors) AddError(err error) MultiErrors

func (MultiErrors) Error

func (me MultiErrors) Error() string

type NopSink

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

func (*NopSink) Close

func (ns *NopSink) Close(ctx api.StreamContext) error

func (*NopSink) Collect

func (ns *NopSink) Collect(ctx api.StreamContext, item interface{}) error

func (*NopSink) Configure

func (ns *NopSink) Configure(ps map[string]interface{}) error

func (*NopSink) Open

func (ns *NopSink) Open(ctx api.StreamContext) error

type QueryResult

type QueryResult struct {
	Results   []string
	LastFetch time.Time
	Mux       sync.Mutex
}

type RestSink

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

func (*RestSink) Close

func (ms *RestSink) Close(ctx api.StreamContext) error

func (*RestSink) Collect

func (ms *RestSink) Collect(ctx api.StreamContext, item interface{}) error

func (*RestSink) Configure

func (ms *RestSink) Configure(ps map[string]interface{}) error

func (*RestSink) Open

func (ms *RestSink) Open(ctx api.StreamContext) error

func (*RestSink) Send

func (ms *RestSink) Send(v interface{}, logger api.Logger) (*http.Response, error)