events

Documentation

Index

• Constants
• Variables
• type ConditionalEvent
• type Device
• type DeviceGroup
• type DeviceInfo
• type Element
• type Events
  • func New(config configuration.Config, devicerepo devicerepo.Interface, ...) *Events
  • func (this *Events) DeleteProcess(token string, deploymentId string) (err error)
  • func (this *Events) DeployProcess(token string, deviceId string, serviceId string) (deploymentId string, err error)
  • func (this *Events) GetProcessInstances(token string) (result []ProcessInstance, err error)
  • func (this *Events) ListCanaryProcessDeployments(token string) (ids []string, err error)
  • func (this *Events) PrepareProcessDeployment(token string) (result PreparedDeployment, err error)
  • func (this *Events) ProcessStartup(token string, info DeviceInfo) error
  • func (this *Events) ProcessTeardown(token string) error
• type PreparedDeployment
• type ProcessInstance
• type Selection
• type SelectionOption
• type Service
• type Wrapper

Constants

const ExpectedCanaryDeploymentName = "canary_event_process"

Variables

var DeploymentModelTemplate string

var ProcessBpmn string

var ProcessSvg string

Types

type ConditionalEvent

type ConditionalEvent struct {
	Script        string            `json:"script"`
	ValueVariable string            `json:"value_variable"`
	Variables     map[string]string `json:"variables"`
	Qos           int               `json:"qos"`
	EventId       string            `json:"event_id"`
	Selection     Selection         `json:"selection"`
}

type Device

type Device struct {
	Id   string `json:"id"`
	Name string `json:"name"`
}

type DeviceGroup

type DeviceGroup struct {
	Id   string `json:"id"`
	Name string `json:"name"`
}

type DeviceInfo

type DeviceInfo = devicemetadata.DeviceInfo

type Element

type Element struct {
	BpmnId           string            `json:"bpmn_id"`
	ConditionalEvent *ConditionalEvent `json:"conditional_event"`
}

type Events

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

func New

func New(config configuration.Config, devicerepo devicerepo.Interface, metrics *metrics.Metrics, guaranteeChangeAfter time.Duration) *Events

func (*Events) DeleteProcess

func (this *Events) DeleteProcess(token string, deploymentId string) (err error)

func (*Events) DeployProcess

func (this *Events) DeployProcess(token string, deviceId string, serviceId string) (deploymentId string, err error)

func (*Events) GetProcessInstances

func (this *Events) GetProcessInstances(token string) (result []ProcessInstance, err error)

func (*Events) ListCanaryProcessDeployments

func (this *Events) ListCanaryProcessDeployments(token string) (ids []string, err error)

func (*Events) PrepareProcessDeployment

func (this *Events) PrepareProcessDeployment(token string) (result PreparedDeployment, err error)

func (*Events) ProcessStartup

func (this *Events) ProcessStartup(token string, info DeviceInfo) error

func (*Events) ProcessTeardown

func (this *Events) ProcessTeardown(token string) error

type PreparedDeployment

type PreparedDeployment struct {
	Id       string    `json:"id"`
	Name     string    `json:"name"`
	Elements []Element `json:"elements"`
}

type ProcessInstance

type ProcessInstance struct {
	Id                    string `json:"id"`
	ProcessDefinitionName string `json:"processDefinitionName"`
	StartTime             string `json:"startTime"`
	EndTime               string `json:"endTime"`
	DurationInMillis      int    `json:"durationInMillis"`
	State                 string `json:"state"`
}

type Selection

type Selection struct {
	SelectionOptions []SelectionOption `json:"selection_options"`
}

type SelectionOption

type SelectionOption struct {
	Device   *Device   `json:"device"`
	Services []Service `json:"services"`
}

type Service

type Service struct {
	Id   string `json:"id"`
	Name string `json:"name"`
}

type Wrapper

type Wrapper struct {
	Id   string `json:"id"`
	Name string `json:"name"`
}