cloud

package

v1.0.17 Latest Latest Go to latest Published: Mar 15, 2024 License: Apache-2.0 Imports: 24 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/SENERGY-Platform/device-command

Links

Open Source Insights

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
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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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 ¶ added in v1.0.3

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]

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL