metathings_data_storage_sdk

Documentation

Index

• Variables
• func ToDataStorage(ds *DataStorage) func(string, interface{}) error
• type DataStorage
  • func NewDataStorage(name string, args ...interface{}) (DataStorage, error)
  • func NewDummyDataStorage(args ...interface{}) (DataStorage, error)
  • func NewInfluxdb2DataStorage(args ...interface{}) (DataStorage, error)
• type DataStorageFactory
• type DummyDataStorage
  • func (s *DummyDataStorage) Query(ctx context.Context, measurement string, tags map[string]string, ...) (QueryResult, error)
  • func (s *DummyDataStorage) Write(ctx context.Context, measurement string, tags map[string]string, ...) error
• type Influxdb2DataStorage
  • func (s *Influxdb2DataStorage) Query(ctx context.Context, measurement string, tags map[string]string, ...) (QueryResult, error)
  • func (s *Influxdb2DataStorage) Write(ctx context.Context, measurement string, tags map[string]string, ...) error
• type Influxdb2DataStorageOption
  • func NewInfluxdb2DataStorageOption() *Influxdb2DataStorageOption
• type MockDataStorage
  • func (m *MockDataStorage) Query(ctx context.Context, measurement string, tags map[string]string, ...) (QueryResult, error)
  • func (m *MockDataStorage) SetQueryResult(qr QueryResult)
  • func (m *MockDataStorage) Write(ctx context.Context, measurement string, tags map[string]string, ...) error
• type QueryOption
  • func PageSize(size int32) QueryOption
  • func PageToken(token string) QueryOption
  • func QueryString(s string) QueryOption
  • func RangeFrom(t time.Time) QueryOption
  • func RangeTo(t time.Time) QueryOption
• type QueryRecord
  • func NewQueryRecord(tm time.Time, dat map[string]interface{}) QueryRecord
• type QueryResult
  • func NewQueryResult(recs []QueryRecord, npt string) QueryResult

Variables

var (
	ErrUnsupportedDataStorageDriver = errors.New("unsupported data storage driver")
)

Functions

func ToDataStorage

func ToDataStorage(ds *DataStorage) func(string, interface{}) error

Types

type DataStorage

type DataStorage interface {
	Write(ctx context.Context, measurement string, tags map[string]string, data map[string]interface{}) error
	Query(ctx context.Context, measurement string, tags map[string]string, opts ...QueryOption) (QueryResult, error)
}

func NewDataStorage

func NewDataStorage(name string, args ...interface{}) (DataStorage, error)

func NewDummyDataStorage

func NewDummyDataStorage(args ...interface{}) (DataStorage, error)

func NewInfluxdb2DataStorage

func NewInfluxdb2DataStorage(args ...interface{}) (DataStorage, error)

type DataStorageFactory

type DataStorageFactory func(...interface{}) (DataStorage, error)

type DummyDataStorage

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

func (*DummyDataStorage) Query

func (s *DummyDataStorage) Query(ctx context.Context, measurement string, tags map[string]string, opts ...QueryOption) (QueryResult, error)

func (*DummyDataStorage) Write

func (s *DummyDataStorage) Write(ctx context.Context, measurement string, tags map[string]string, data map[string]interface{}) error

type Influxdb2DataStorage

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

func (*Influxdb2DataStorage) Query

func (s *Influxdb2DataStorage) Query(ctx context.Context, measurement string, tags map[string]string, opts ...QueryOption) (QueryResult, error)

func (*Influxdb2DataStorage) Write

func (s *Influxdb2DataStorage) Write(ctx context.Context, measurement string, tags map[string]string, data map[string]interface{}) error

type Influxdb2DataStorageOption

type Influxdb2DataStorageOption struct {
	Address  string
	Token    string
	Username string
	Password string
	Org      string
	Bucket   string

	QueryPageSize        int32
	QueryRangeFromOffset time.Duration
}

func NewInfluxdb2DataStorageOption

func NewInfluxdb2DataStorageOption() *Influxdb2DataStorageOption

type MockDataStorage

type MockDataStorage struct {
	mock.Mock
	// contains filtered or unexported fields
}

func (*MockDataStorage) Query

func (m *MockDataStorage) Query(ctx context.Context, measurement string, tags map[string]string, opts ...QueryOption) (QueryResult, error)

func (*MockDataStorage) SetQueryResult

func (m *MockDataStorage) SetQueryResult(qr QueryResult)

func (*MockDataStorage) Write

func (m *MockDataStorage) Write(ctx context.Context, measurement string, tags map[string]string, data map[string]interface{}) error

type QueryOption

type QueryOption func(map[string]interface{})

func PageSize

func PageSize(size int32) QueryOption

func PageToken

func PageToken(token string) QueryOption

func QueryString

func QueryString(s string) QueryOption

func RangeFrom

func RangeFrom(t time.Time) QueryOption

func RangeTo

func RangeTo(t time.Time) QueryOption

type QueryRecord

type QueryRecord interface {
	Time() time.Time
	Data() map[string]interface{}
}

func NewQueryRecord

func NewQueryRecord(tm time.Time, dat map[string]interface{}) QueryRecord

type QueryResult

type QueryResult interface {
	Records() []QueryRecord
	NextPageToken() string
}

func NewQueryResult

func NewQueryResult(recs []QueryRecord, npt string) QueryResult