timescale

Documentation

Index

• type FactoryInterface
• type Interface
  • func Factory(ctx context.Context, config util.Config) (Interface, error)
• type QueriesRequestElement
• type QueriesRequestElementColumn
• type Timescale
  • func NewTimescale(timescaleWrapperUrl string) *Timescale
  • func (this *Timescale) Query(token string, request []messages.TimescaleRequest, timeout time.Duration) (result []messages.TimescaleResponse, err error)
• type TimescaleQuery
  • func CastRequest(request []messages.TimescaleRequest) (result TimescaleQuery)
• type TimescaleQueryResponse

Types

type FactoryInterface

type FactoryInterface func(ctx context.Context, config util.Config) (Interface, error)

type Interface

type Interface interface {
	Query(token string, request []messages.TimescaleRequest, timeout time.Duration) (result []messages.TimescaleResponse, err error)
}

func Factory

func Factory(ctx context.Context, config util.Config) (Interface, error)

type QueriesRequestElement

type QueriesRequestElement struct {
	DeviceId  string
	ServiceId string
	Limit     int
	Columns   []QueriesRequestElementColumn
}

type QueriesRequestElementColumn

type QueriesRequestElementColumn struct {
	Name string
}

type Timescale

type Timescale struct {
	TimescaleWrapperUrl string
}

func NewTimescale

func NewTimescale(timescaleWrapperUrl string) *Timescale

func (*Timescale) Query

func (this *Timescale) Query(token string, request []messages.TimescaleRequest, timeout time.Duration) (result []messages.TimescaleResponse, err error)

type TimescaleQuery

type TimescaleQuery = []QueriesRequestElement

func CastRequest

func CastRequest(request []messages.TimescaleRequest) (result TimescaleQuery)

type TimescaleQueryResponse

type TimescaleQueryResponse = [][][]interface{} //[query-index][0][column-index + 1]