Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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()
Click to show internal directories.
Click to hide internal directories.