process

Documentation

Index

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

Constants

const ExpectedCanaryDeploymentName = "canary_process"

Variables

var DeploymentModelTemplate string

var ProcessBpmn string

var ProcessSvg string

Types

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"`
	Task   *Task  `json:"task"`
}

type PreparedDeployment

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

type Process

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

func New

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

func (*Process) DeleteProcess

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

func (*Process) DeployProcess

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

func (*Process) GetProcessInstances

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

func (*Process) ListCanaryProcessDeployments

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

func (*Process) NotifyCommand

func (this *Process) NotifyCommand(topic string, payload []byte)

func (*Process) PrepareProcessDeployment

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

func (*Process) ProcessStartup

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

func (*Process) ProcessTeardown

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

func (*Process) StartProcess

func (this *Process) StartProcess(token string, deploymentId string) (err error)

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 Task

type Task struct {
	Selection Selection `json:"selection"`
}

type Wrapper

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