cloud

Documentation

Index

• func ComFactory(ctx context.Context, config configuration.Config, ...) (producer interfaces.Producer, err error)
• func GetCacheConfig() cache.Config
• func IotFactory(ctx context.Context, config configuration.Config) (interfaces.Iot, error)
• func MarshallerFactory(ctx context.Context, config configuration.Config, iot interfaces.Iot) (interfaces.Marshaller, error)
• func TimescaleFactory(ctx context.Context, config configuration.Config) (interfaces.Timescale, error)
• type IdWrapper
• type Iot
  • func NewIot(config configuration.Config, cache *cache.Cache, cacheDevices bool, ...) *Iot
  • func (this *Iot) GetAspectNode(token string, id string) (result model.AspectNode, err error)
  • func (this *Iot) GetCharacteristic(token string, id string) (result model.Characteristic, err error)
  • func (this *Iot) GetConcept(token string, id string) (result model.Concept, err error)
  • func (this *Iot) GetConceptIds(token string) (ids []string, err error)
  • func (this *Iot) GetDevice(token string, id string) (result model.Device, err error)
  • func (this *Iot) GetDeviceGroup(token string, id string) (result model.DeviceGroup, err error)
  • func (this *Iot) GetDeviceType(token string, id string) (result model.DeviceType, err error)
  • func (this *Iot) GetFunction(token string, id string) (result model.Function, err error)
  • func (this *Iot) GetJson(token string, endpoint string, result interface{}) (err error)
  • func (this *Iot) GetProtocol(token string, id string) (result model.Protocol, err error)
  • func (this *Iot) GetService(token string, device model.Device, id string) (result model.Service, err error)
  • func (this *Iot) ListFunctions(token string) (functionInfos []model.Function, err error)
• type Producer
  • func (this *Producer) SendCommand(msg messages.ProtocolMsg) (err error)
• type QueriesRequestElement
• type QueriesRequestElementColumn
• type Timescale
  • func NewTimescale(timescaleWrapperUrl string) *Timescale
  • func (this *Timescale) Query(token auth.Token, request []interfaces.TimescaleRequest, timeout time.Duration) (result []interfaces.TimescaleResponse, err error)
• type TimescaleQuery
• type TimescaleQueryResponse

Functions

func ComFactory

func ComFactory(ctx context.Context, config configuration.Config, responseListener func(msg messages.ProtocolMsg) error, errorListener func(msg messages.ProtocolMsg) error) (producer interfaces.Producer, err error)

func GetCacheConfig

func GetCacheConfig() cache.Config

func IotFactory

func IotFactory(ctx context.Context, config configuration.Config) (interfaces.Iot, error)

func MarshallerFactory

func MarshallerFactory(ctx context.Context, config configuration.Config, iot interfaces.Iot) (interfaces.Marshaller, error)

func TimescaleFactory

func TimescaleFactory(ctx context.Context, config configuration.Config) (interfaces.Timescale, error)

Types

type IdWrapper

type IdWrapper struct {
	Id string `json:"id"`
}

type Iot

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

func NewIot

func NewIot(config configuration.Config, cache *cache.Cache, cacheDevices bool, cacheExpiration time.Duration) *Iot

func (*Iot) GetAspectNode

func (this *Iot) GetAspectNode(token string, id string) (result model.AspectNode, err error)

func (*Iot) GetCharacteristic

func (this *Iot) GetCharacteristic(token string, id string) (result model.Characteristic, err error)

func (*Iot) GetConcept

func (this *Iot) GetConcept(token string, id string) (result model.Concept, err error)

func (*Iot) GetConceptIds

func (this *Iot) GetConceptIds(token string) (ids []string, err error)

func (*Iot) GetDevice

func (this *Iot) GetDevice(token string, id string) (result model.Device, err error)

func (*Iot) GetDeviceGroup

func (this *Iot) GetDeviceGroup(token string, id string) (result model.DeviceGroup, err error)

func (*Iot) GetDeviceType

func (this *Iot) GetDeviceType(token string, id string) (result model.DeviceType, err error)

func (*Iot) GetFunction

func (this *Iot) GetFunction(token string, id string) (result model.Function, err error)

func (*Iot) GetJson

func (this *Iot) GetJson(token string, endpoint string, result interface{}) (err error)

func (*Iot) GetProtocol

func (this *Iot) GetProtocol(token string, id string) (result model.Protocol, err error)

func (*Iot) GetService

func (this *Iot) GetService(token string, device model.Device, id string) (result model.Service, err error)

func (*Iot) ListFunctions

func (this *Iot) ListFunctions(token string) (functionInfos []model.Function, err error)

type Producer

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

func (*Producer) SendCommand

func (this *Producer) SendCommand(msg messages.ProtocolMsg) (err 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 auth.Token, request []interfaces.TimescaleRequest, timeout time.Duration) (result []interfaces.TimescaleResponse, err error)

type TimescaleQuery

type TimescaleQuery = []QueriesRequestElement

type TimescaleQueryResponse

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