kdb

Documentation

Index

• Constants
• func Init()
• func NewKDBObserver(properties map[string]interface{}) (observer.Observer, error)
• func NewKDBSink(properties map[string]interface{}) (sink.Sink, error)
• type KDBObserver
  • func (o *KDBObserver) Observe() error
  • func (o *KDBObserver) Stop()
  • func (o *KDBObserver) Wait()
• type KDBSink
  • func (s *KDBSink) GetStats() *sink.Stats
  • func (s *KDBSink) Init(name string, fields []common.Field) error
  • func (s *KDBSink) Write(headers []string, rows [][]interface{}, index int) error

Constants

const KDB_OB_TYPE = "kdb"

const KDB_SINK_TYPE = "kdb"

Functions

func Init

func Init()

func NewKDBObserver

func NewKDBObserver(properties map[string]interface{}) (observer.Observer, error)

func NewKDBSink

func NewKDBSink(properties map[string]interface{}) (sink.Sink, error)

Types

type KDBObserver

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

func (*KDBObserver) Observe

func (o *KDBObserver) Observe() error

func (*KDBObserver) Stop

func (o *KDBObserver) Stop()

func (*KDBObserver) Wait

func (o *KDBObserver) Wait()

type KDBSink

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

func (*KDBSink) GetStats

func (s *KDBSink) GetStats() *sink.Stats

func (*KDBSink) Init

func (s *KDBSink) Init(name string, fields []common.Field) error

func (*KDBSink) Write

func (s *KDBSink) Write(headers []string, rows [][]interface{}, index int) error