client

package
v0.0.0-...-37e6509 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 4, 2020 License: MIT Imports: 10 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewDatahubClient

func NewDatahubClient(cfg conf.MqttConfig, serviceId service.ServiceId, nodeId string) (api.DatahubApi, error)

Types

type DatahubClient

type DatahubClient struct {
	*talk.TClient
	NodeId string
}

func (*DatahubClient) DeleteResource

func (dc *DatahubClient) DeleteResource(kind *resource.Kind, id string) error

func (*DatahubClient) GetResource

func (dc *DatahubClient) GetResource(kind *resource.Kind, id string) (*resource.Resource, error)

func (*DatahubClient) ListResources

func (dc *DatahubClient) ListResources(kind *resource.Kind) ([]*resource.Resource, error)

func (*DatahubClient) QueryResources

func (dc *DatahubClient) QueryResources(kind *resource.Kind, idPrefix string) ([]*resource.Resource, error)

func (*DatahubClient) SaveResource

func (dc *DatahubClient) SaveResource(r *resource.Resource) error

func (*DatahubClient) WatchResource

func (dc *DatahubClient) WatchResource(kind *resource.Kind, watcher api.ResourceWatcher, watchSelf bool) error

Jump to

Keyboard shortcuts

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