utils

Documentation

Index

• Constants
• func GetDeviceMetadataEventSubject(owner, deviceID, eventType string) []string
• func GetDeviceSubject(owner, deviceID string) []string
• func GetPublishSubject(owner string, event eventbus.Event) []string
• func GetResourceEventSubject(owner string, resourceID *commands.ResourceId, eventType string) []string
• func Marshal(v interface{}) ([]byte, error)
• func TimeNowMs() uint64
• func Unmarshal(b []byte, v interface{}) error
• func WithDeviceID(deviceID string) func(values map[string]string)
• func WithResourceId(resourceID string) func(values map[string]string)
• type ProtobufMarshaler
• type ProtobufUnmarshaler

Constants

const (
	DeviceIDKey   = "deviceId"
	ResourceIDKey = "resourceId"
)

const (
	Devices                                            = "devices"
	PlgdOwnersOwnerDevices                             = isEvents.PlgdOwnersOwner + "." + Devices
	PlgdOwnersOwnerDevicesDevice                       = PlgdOwnersOwnerDevices + ".{" + DeviceIDKey + "}"
	PlgdOwnersOwnerDevicesDeviceResourceLinks          = PlgdOwnersOwnerDevicesDevice + ".resource-links"
	PlgdOwnersOwnerDevicesDeviceResourceLinksEvent     = PlgdOwnersOwnerDevicesDeviceResourceLinks + ".{" + isEvents.EventTypeKey + "}"
	PlgdOwnersOwnerDevicesDeviceMetadata               = PlgdOwnersOwnerDevicesDevice + ".metadata"
	PlgdOwnersOwnerDevicesDeviceMetadataEvent          = PlgdOwnersOwnerDevicesDeviceMetadata + ".{" + isEvents.EventTypeKey + "}"
	PlgdOwnersOwnerDevicesDeviceResources              = PlgdOwnersOwnerDevicesDevice + ".resources"
	PlgdOwnersOwnerDevicesDeviceResourcesResource      = PlgdOwnersOwnerDevicesDeviceResources + ".{" + ResourceIDKey + "}"
	PlgdOwnersOwnerDevicesDeviceResourcesResourceEvent = PlgdOwnersOwnerDevicesDeviceResourcesResource + ".{" + isEvents.EventTypeKey + "}"
)

Functions

func GetDeviceMetadataEventSubject

func GetDeviceMetadataEventSubject(owner, deviceID, eventType string) []string

func GetDeviceSubject

func GetDeviceSubject(owner, deviceID string) []string

func GetPublishSubject

func GetPublishSubject(owner string, event eventbus.Event) []string

func GetResourceEventSubject

func GetResourceEventSubject(owner string, resourceID *commands.ResourceId, eventType string) []string

func Marshal

func Marshal(v interface{}) ([]byte, error)

func TimeNowMs

func TimeNowMs() uint64

func Unmarshal

func Unmarshal(b []byte, v interface{}) error

func WithDeviceID

func WithDeviceID(deviceID string) func(values map[string]string)

func WithResourceId

func WithResourceId(resourceID string) func(values map[string]string)

Types

type ProtobufMarshaler

type ProtobufMarshaler interface {
	Marshal() ([]byte, error)
}

type ProtobufUnmarshaler

type ProtobufUnmarshaler interface {
	Unmarshal([]byte) error
}