Documentation ¶
Index ¶
- func NewDatahubClient(cfg conf.MqttConfig, serviceId service.ServiceId, nodeId string) (api.DatahubApi, error)
- type DatahubClient
- func (dc *DatahubClient) DeleteResource(kind *resource.Kind, id string) error
- func (dc *DatahubClient) GetResource(kind *resource.Kind, id string) (*resource.Resource, error)
- func (dc *DatahubClient) ListResources(kind *resource.Kind) ([]*resource.Resource, error)
- func (dc *DatahubClient) QueryResources(kind *resource.Kind, idPrefix string) ([]*resource.Resource, error)
- func (dc *DatahubClient) SaveResource(r *resource.Resource) error
- func (dc *DatahubClient) WatchResource(kind *resource.Kind, watcher api.ResourceWatcher, watchSelf bool) error
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 ¶
func (*DatahubClient) DeleteResource ¶
func (dc *DatahubClient) DeleteResource(kind *resource.Kind, id string) error
func (*DatahubClient) GetResource ¶
func (*DatahubClient) ListResources ¶
func (*DatahubClient) QueryResources ¶
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
Click to show internal directories.
Click to hide internal directories.