RawDataConvert

Documentation

Index

• type RawData
  • func NewRawData(databaseName string, measurementName string, tags []string, ...) *RawData
  • func (n *RawData) GetClusterID() string
  • func (n *RawData) GetFieldKey(keyName string) *common.InfluxField
  • func (n *RawData) GetSourceData() interface{}
  • func (n *RawData) GetWriteRequest() (*dpRawData.WriteRawdataRequest, error)
  • func (n *RawData) IsTagKey(keyName string) bool

Types

type RawData

type RawData struct {
	DatabaseName    string
	MeasurementName string
	TagKeys         []string
	FieldKeys       []*common.InfluxField
	SourceData      interface{}
	Convert         *common.DataSourceConverter
	ConvertType     common.ConvertInt
	Granularity     int
	ClusterID       string
}

func NewRawData

func NewRawData(databaseName string, measurementName string, tags []string, fields []*common.InfluxField, sourceData interface{}, convert common.ConvertInt, granularity int, clusterID string) *RawData

func (*RawData) GetClusterID

func (n *RawData) GetClusterID() string

func (*RawData) GetFieldKey

func (n *RawData) GetFieldKey(keyName string) *common.InfluxField

func (*RawData) GetSourceData

func (n *RawData) GetSourceData() interface{}

func (*RawData) GetWriteRequest

func (n *RawData) GetWriteRequest() (*dpRawData.WriteRawdataRequest, error)

func (*RawData) IsTagKey

func (n *RawData) IsTagKey(keyName string) bool