messages

Documentation

Index

• Constants
• type Deployment
• type DeploymentCommand
• type Diagram
• type DoneNotification
• type Incident
• type IncidentHandling
• type KafkaIncidentsCommand
• type OnIncident
• type VersionWrapper

Constants

const CurrentVersion int64 = 3

Types

type Deployment

type Deployment struct {
	Version          int64             `json:"version"`
	Id               string            `json:"id"`
	Name             string            `json:"name"`
	Diagram          Diagram           `json:"diagram"`
	IncidentHandling *IncidentHandling `json:"incident_handling,omitempty"`
}

type DeploymentCommand

type DeploymentCommand struct {
	Command    string      `json:"command"`
	Id         string      `json:"id"`
	Owner      string      `json:"owner"`
	Deployment *Deployment `json:"deployment"`
	Source     string      `json:"source,omitempty"`
	Version    int64       `json:"version"`
}

type Diagram

type Diagram struct {
	XmlDeployed string `json:"xml_deployed"`
	Svg         string `json:"svg"`
}

type DoneNotification

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

type Incident

type Incident struct {
	Id                  string    `json:"id" bson:"id"`
	MsgVersion          int64     `json:"msg_version,omitempty" bson:"msg_version,omitempty"` //from version 3 onward will be set in KafkaIncidentsCommand and be copied to this field
	ExternalTaskId      string    `json:"external_task_id" bson:"external_task_id"`
	ProcessInstanceId   string    `json:"process_instance_id" bson:"process_instance_id"`
	ProcessDefinitionId string    `json:"process_definition_id" bson:"process_definition_id"`
	WorkerId            string    `json:"worker_id" bson:"worker_id"`
	ErrorMessage        string    `json:"error_message" bson:"error_message"`
	Time                time.Time `json:"time" bson:"time"`
	TenantId            string    `json:"tenant_id" bson:"tenant_id"`
	DeploymentName      string    `json:"deployment_name" bson:"deployment_name"`
}

type IncidentHandling

type IncidentHandling struct {
	Restart              bool `json:"restart"`
	Notify               bool `json:"notify"`
	RestartIsValidOption bool `json:"restart_is_valid_option"`
}

type KafkaIncidentsCommand

type KafkaIncidentsCommand struct {
	Command             string      `json:"command"`
	MsgVersion          int64       `json:"msg_version"`
	Incident            *Incident   `json:"incident,omitempty"`
	Handler             *OnIncident `json:"handler,omitempty"`
	ProcessDefinitionId string      `json:"process_definition_id,omitempty"`
	ProcessInstanceId   string      `json:"process_instance_id,omitempty"`
}

type OnIncident

type OnIncident struct {
	ProcessDefinitionId string `json:"process_definition_id" bson:"process_definition_id"`
	Restart             bool   `json:"restart" bson:"restart"`
	Notify              bool   `json:"notify" bson:"notify"`
}

type VersionWrapper

type VersionWrapper struct {
	Command string `json:"command"`
	Id      string `json:"id"`
	Version int64  `json:"version"`
	Owner   string `json:"owner"`
}