cloud

package

v1.0.39 Latest Latest Go to latest Published: Sep 3, 2025 License: Apache-2.0 Imports: 24 Imported by: 2

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
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
- func NewIotWithDeviceRepoClient(config configuration.Config, cache *cache.Cache, cacheDevices bool, ...) *Iot
type LastMessageResponse
type Producer
- func (this *Producer) SendCommand(msg messages.ProtocolMsg) (err error)
type Timescale
- func NewTimescale(timescaleWrapperUrl string) *Timescale
- func (this *Timescale) GetLastMessage(token auth.Token, device models.Device, service models.Service, ...) (result map[string]interface{}, err error)

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

func NewIotWithDeviceRepoClient(config configuration.Config, cache *cache.Cache, cacheDevices bool, cacheExpiration time.Duration, client client.Interface, overwriteAuthTokens bool) *Iot

func (*Iot) GetAspectNode ¶

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

func (*Iot) GetCharacteristic ¶

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

func (*Iot) GetConcept ¶

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

func (*Iot) GetConceptIds ¶

func (this *Iot) GetConceptIds() (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(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() (functionInfos []model.Function, err error)

type LastMessageResponse ¶ added in v1.0.30

type LastMessageResponse struct {
	Time  string                 `json:"time"`
	Value map[string]interface{} `json:"value"`
}

type Producer ¶

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

func (*Producer) SendCommand ¶

func (this *Producer) SendCommand(msg messages.ProtocolMsg) (err error)

type Timescale ¶

type Timescale struct {
	TimescaleWrapperUrl string
}

func NewTimescale ¶

func NewTimescale(timescaleWrapperUrl string) *Timescale

func (*Timescale) GetLastMessage ¶ added in v1.0.30

func (this *Timescale) GetLastMessage(token auth.Token, device models.Device, service models.Service, protocol model.Protocol, timeout time.Duration) (result map[string]interface{}, err error)

Source Files ¶

View all Source files

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