cloud

Documentation

Index

• Constants
• type DoneNotification
• type Envelope
• type Impl
  • func New(ctx context.Context, wg *sync.WaitGroup, config configuration.Config) (result *Impl, err error)
  • func (this *Impl) GetImportEventDescriptions(importId string) (result []model.EventDesc, err error)
  • func (this *Impl) GetServiceEventDescriptions(deviceId string, serviceId string) (result []model.EventDesc, err error)
  • func (this *Impl) IsImportMessage(message model.ConsumerMessage) bool
  • func (this *Impl) IsServiceMessage(message model.ConsumerMessage) bool
  • func (this *Impl) ParseImportMessage(message model.ConsumerMessage) (importId string, payload Payload, err error)
  • func (this *Impl) ParseServiceMessage(message model.ConsumerMessage) (deviceId string, serviceId string, payload Payload, err error)
  • func (this *Impl) ResetCache()
  • func (this *Impl) SerializeMessage(payload Payload, service models.Service) (result model.SerializedMessage, err error)
• type ImportEnvelope
• type Payload

Constants

const ImportEnvelopeIdField = "import_id"

Types

type DoneNotification

type DoneNotification struct {
	Command string `json:"command"`
	Id      string `json:"id"`
	Handler string `json:"handler"`
}

type Envelope

type Envelope struct {
	DeviceId  string                 `json:"device_id,omitempty"`
	ServiceId string                 `json:"service_id,omitempty"`
	Value     map[string]interface{} `json:"value"`
}

type Impl

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

func New

func New(ctx context.Context, wg *sync.WaitGroup, config configuration.Config) (result *Impl, err error)

func (*Impl) GetImportEventDescriptions

func (this *Impl) GetImportEventDescriptions(importId string) (result []model.EventDesc, err error)

func (*Impl) GetServiceEventDescriptions

func (this *Impl) GetServiceEventDescriptions(deviceId string, serviceId string) (result []model.EventDesc, err error)

func (*Impl) IsImportMessage

func (this *Impl) IsImportMessage(message model.ConsumerMessage) bool

urn_infai_ses_import_7f2620cb-002c-fc54-0c2e-5e840b7b0263

func (*Impl) IsServiceMessage

func (this *Impl) IsServiceMessage(message model.ConsumerMessage) bool

urn_infai_ses_service_557a8519-c801-42c6-a5e0-d6d6450ec9ab

func (*Impl) ParseImportMessage

func (this *Impl) ParseImportMessage(message model.ConsumerMessage) (importId string, payload Payload, err error)

func (*Impl) ParseServiceMessage

func (this *Impl) ParseServiceMessage(message model.ConsumerMessage) (deviceId string, serviceId string, payload Payload, err error)

func (*Impl) ResetCache

func (this *Impl) ResetCache()

func (*Impl) SerializeMessage

func (this *Impl) SerializeMessage(payload Payload, service models.Service) (result model.SerializedMessage, err error)

type ImportEnvelope

type ImportEnvelope = map[string]interface{}

type Payload

type Payload = map[string]interface{}