conditionalevents

Documentation

Index

• type Devices
• type Events
  • func New(ctx context.Context, config config.Config, devices interfaces.Devices, ...) (result *Events, err error)
  • func (this *Events) CheckEvent(token string, id string) int
  • func (this *Events) Deploy(owner string, deployment deploymentmodel.Deployment) error
  • func (this *Events) GetEventStates(token string, ids []string) (states map[string]bool, err error, code int)
  • func (this *Events) Remove(owner string, deploymentId string) error
  • func (this *Events) UpdateDeviceGroup(owner string, group model.DeviceGroup) error
• type Transformer
  • func NewTransformer(devices Devices, imports interfaces.Imports) *Transformer
  • func (this *Transformer) Transform(owner string, deployment deploymentmodel.Deployment) (result []model.EventDesc, err error)
  • func (this *Transformer) TransformElement(owner string, deploymentId string, element deploymentmodel.Element) (result []model.EventDesc, err error)

Types

type Devices

type Devices interface {
	GetDeviceInfosOfGroup(groupId string) (devices []model.Device, deviceTypeIds []string, err error, code int)
	GetDeviceInfosOfDevices(deviceIds []string) (devices []model.Device, deviceTypeIds []string, err error, code int)
	GetDeviceTypeSelectables(criteria []model.FilterCriteria) (result []model.DeviceTypeSelectable, err error, code int)
	GetService(serviceId string) (result models.Service, err error, code int)
}

type Events

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

func New

func New(ctx context.Context, config config.Config, devices interfaces.Devices, imports interfaces.Imports, m *metrics.Metrics) (result *Events, err error)

func (*Events) CheckEvent

func (this *Events) CheckEvent(token string, id string) int

func (*Events) Deploy

func (this *Events) Deploy(owner string, deployment deploymentmodel.Deployment) error

func (*Events) GetEventStates

func (this *Events) GetEventStates(token string, ids []string) (states map[string]bool, err error, code int)

func (*Events) Remove

func (this *Events) Remove(owner string, deploymentId string) error

func (*Events) UpdateDeviceGroup

func (this *Events) UpdateDeviceGroup(owner string, group model.DeviceGroup) error

type Transformer

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

func NewTransformer

func NewTransformer(devices Devices, imports interfaces.Imports) *Transformer

func (*Transformer) Transform

func (this *Transformer) Transform(owner string, deployment deploymentmodel.Deployment) (result []model.EventDesc, err error)

func (*Transformer) TransformElement

func (this *Transformer) TransformElement(owner string, deploymentId string, element deploymentmodel.Element) (result []model.EventDesc, err error)