Documentation ¶
Index ¶
- type DataUpdate
- type NatsClient
- func (n *NatsClient) DeviceGatewayUpdate(ctx context.Context, info *events.GatewayUpdateInfo) error
- func (n *NatsClient) DeviceLogLevelUpdate(ctx context.Context, info *events.DataUpdateInfo) error
- func (n *NatsClient) DeviceRemoteConfigUpdate(ctx context.Context, info *events.DataUpdateInfo) error
- func (n *NatsClient) ProductSchemaUpdate(ctx context.Context, info *events.DataUpdateInfo) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DataUpdate ¶
type DataUpdate interface { ProductSchemaUpdate(ctx context.Context, info *events.DataUpdateInfo) error DeviceLogLevelUpdate(ctx context.Context, info *events.DataUpdateInfo) error DeviceGatewayUpdate(ctx context.Context, info *events.GatewayUpdateInfo) error DeviceRemoteConfigUpdate(ctx context.Context, info *events.DataUpdateInfo) error }
func NewDataUpdate ¶
func NewDataUpdate(c conf.EventConf) (DataUpdate, error)
type NatsClient ¶
type NatsClient struct {
// contains filtered or unexported fields
}
func (*NatsClient) DeviceGatewayUpdate ¶ added in v0.3.0
func (n *NatsClient) DeviceGatewayUpdate(ctx context.Context, info *events.GatewayUpdateInfo) error
func (*NatsClient) DeviceLogLevelUpdate ¶
func (n *NatsClient) DeviceLogLevelUpdate(ctx context.Context, info *events.DataUpdateInfo) error
func (*NatsClient) DeviceRemoteConfigUpdate ¶ added in v0.3.0
func (n *NatsClient) DeviceRemoteConfigUpdate(ctx context.Context, info *events.DataUpdateInfo) error
func (*NatsClient) ProductSchemaUpdate ¶
func (n *NatsClient) ProductSchemaUpdate(ctx context.Context, info *events.DataUpdateInfo) error
Click to show internal directories.
Click to hide internal directories.