snow

Documentation

Index

• type SnowDataReader
  • func NewSnowDataReader(config base.BaseConfig, writer base.DataWriter, checkpoint base.Checkpointer) *SnowDataReader
  • func (snow *SnowDataReader) IndexData() error
  • func (snow *SnowDataReader) ReadData() ([]byte, error)
  • func (snow *SnowDataReader) Start()
  • func (snow *SnowDataReader) Stop()

Types

type SnowDataReader

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

func NewSnowDataReader

func NewSnowDataReader(
	config base.BaseConfig, writer base.DataWriter, checkpoint base.Checkpointer) *SnowDataReader

NewSnowDataReader @config: shall contain snow "ServerURL", "Username", "Password" "Metric", "TimestampField" "NextRecordTime", "RecordCount" key/values

func (*SnowDataReader) IndexData

func (snow *SnowDataReader) IndexData() error

func (*SnowDataReader) ReadData

func (snow *SnowDataReader) ReadData() ([]byte, error)

func (*SnowDataReader) Start

func (snow *SnowDataReader) Start()

func (*SnowDataReader) Stop

func (snow *SnowDataReader) Stop()