types

package
v0.13.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 16, 2019 License: Apache-2.0 Imports: 4 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Status_name = map[int32]string{
	0: "Unknown",
	1: "Created",
	2: "InProgress",
	3: "Completed",
	4: "Failed",
}
View Source 
var Status_value = map[string]int32{
	"Unknown":    0,
	"Created":    1,
	"InProgress": 2,
	"Completed":  3,
	"Failed":     4,
}
View Source 
var Workflow_Trigger_Filter_Predicate_name = map[int32]string{
	0: "Unknown",
	1: "EQ",
}
View Source 
var Workflow_Trigger_Filter_Predicate_value = map[string]int32{
	"Unknown": 0,
	"EQ":      1,
}

Functions

This section is empty.

Types

type Event 

type Event struct {
	// Hash is a unique hash to identify event.
	Hash string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	// instanceHash is hash of instance that can proceed an execution.
	InstanceHash string `protobuf:"bytes,2,opt,name=instanceHash,proto3" json:"instanceHash,omitempty"`
	// key is the key of the event.
	Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// data is the data for the event.
	Data                 *_struct.Struct `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

Event represents a single event run in engine.

func (*Event) Descriptor 

func (*Event) Descriptor() ([]byte, []int)

func (*Event) GetData 

func (m *Event) GetData() *_struct.Struct

func (*Event) GetHash 

func (m *Event) GetHash() string

func (*Event) GetInstanceHash 

func (m *Event) GetInstanceHash() string

func (*Event) GetKey 

func (m *Event) GetKey() string

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) String 

func (m *Event) String() string

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event) XXX_Merge 

func (m *Event) XXX_Merge(src proto.Message)

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

func (m *Event) XXX_Unmarshal(b []byte) error

type Execution 

type Execution struct {
	// Hash is a unique hash to identify execution.
	Hash string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	// parentHash is the unique hash of parent execution. if execution is triggered by another one, dependency execution considered as the parent.
	ParentHash string `protobuf:"bytes,2,opt,name=parentHash,proto3" json:"parentHash,omitempty"`
	// eventHash is unique event hash.
	EventHash string `protobuf:"bytes,3,opt,name=eventHash,proto3" json:"eventHash,omitempty"`
	// Status is the current status of execution.
	Status Status `protobuf:"varint,4,opt,name=status,proto3,enum=types.Status" json:"status,omitempty"`
	// instanceHash is hash of the instance that can proceed an execution
	InstanceHash string `protobuf:"bytes,5,opt,name=instanceHash,proto3" json:"instanceHash,omitempty"`
	// taskKey is the key of the task of this execution.
	TaskKey string `protobuf:"bytes,6,opt,name=taskKey,proto3" json:"taskKey,omitempty"`
	// inputs data of the execution.
	Inputs *_struct.Struct `protobuf:"bytes,7,opt,name=inputs,proto3" json:"inputs,omitempty"`
	// outputs are the returned data of successful execution.
	Outputs *_struct.Struct `protobuf:"bytes,8,opt,name=outputs,proto3" json:"outputs,omitempty"`
	// error message of a failed execution.
	Error string `protobuf:"bytes,9,opt,name=error,proto3" json:"error,omitempty"`
	// tags are optionally associated with execution by the user.
	Tags []string `protobuf:"bytes,10,rep,name=tags,proto3" json:"tags,omitempty"`
	// workflowHash is the unique hash of the workflow associated to this execution.
	WorkflowHash string `protobuf:"bytes,11,opt,name=workflowHash,proto3" json:"workflowHash,omitempty"`
	// step of the workflow.
	StepID               string   `protobuf:"bytes,12,opt,name=stepID,proto3" json:"stepID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Execution represents a single execution run in engine.

func (*Execution) Descriptor 

func (*Execution) Descriptor() ([]byte, []int)

func (*Execution) GetError 

func (m *Execution) GetError() string

func (*Execution) GetEventHash 

func (m *Execution) GetEventHash() string

func (*Execution) GetHash 

func (m *Execution) GetHash() string

func (*Execution) GetInputs 

func (m *Execution) GetInputs() *_struct.Struct

func (*Execution) GetInstanceHash 

func (m *Execution) GetInstanceHash() string

func (*Execution) GetOutputs 

func (m *Execution) GetOutputs() *_struct.Struct

func (*Execution) GetParentHash 

func (m *Execution) GetParentHash() string

func (*Execution) GetStatus 

func (m *Execution) GetStatus() Status

func (*Execution) GetStepID added in v0.13.0 

func (m *Execution) GetStepID() string

func (*Execution) GetTags 

func (m *Execution) GetTags() []string

func (*Execution) GetTaskKey 

func (m *Execution) GetTaskKey() string

func (*Execution) GetWorkflowHash added in v0.13.0 

func (m *Execution) GetWorkflowHash() string

func (*Execution) ProtoMessage 

func (*Execution) ProtoMessage()

func (*Execution) Reset 

func (m *Execution) Reset()

func (*Execution) String 

func (m *Execution) String() string

func (*Execution) XXX_DiscardUnknown 

func (m *Execution) XXX_DiscardUnknown()

func (*Execution) XXX_Marshal 

func (m *Execution) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Execution) XXX_Merge 

func (m *Execution) XXX_Merge(src proto.Message)

func (*Execution) XXX_Size 

func (m *Execution) XXX_Size() int

func (*Execution) XXX_Unmarshal 

func (m *Execution) XXX_Unmarshal(b []byte) error

type Instance 

type Instance struct {
	Hash                 string   `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	ServiceHash          string   `protobuf:"bytes,2,opt,name=serviceHash,proto3" json:"serviceHash,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Instance represents service's instance.

func (*Instance) Descriptor 

func (*Instance) Descriptor() ([]byte, []int)

func (*Instance) GetHash 

func (m *Instance) GetHash() string

func (*Instance) GetServiceHash 

func (m *Instance) GetServiceHash() string

func (*Instance) ProtoMessage 

func (*Instance) ProtoMessage()

func (*Instance) Reset 

func (m *Instance) Reset()

func (*Instance) String 

func (m *Instance) String() string

func (*Instance) XXX_DiscardUnknown 

func (m *Instance) XXX_DiscardUnknown()

func (*Instance) XXX_Marshal 

func (m *Instance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Instance) XXX_Merge 

func (m *Instance) XXX_Merge(src proto.Message)

func (*Instance) XXX_Size 

func (m *Instance) XXX_Size() int

func (*Instance) XXX_Unmarshal 

func (m *Instance) XXX_Unmarshal(b []byte) error

type Service 

type Service struct {
	Hash                 string                 `protobuf:"bytes,10,opt,name=hash,proto3" json:"hash,omitempty"`
	Sid                  string                 `protobuf:"bytes,12,opt,name=sid,proto3" json:"sid,omitempty"`
	Name                 string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description          string                 `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Configuration        *Service_Configuration `protobuf:"bytes,8,opt,name=configuration,proto3" json:"configuration,omitempty"`
	Tasks                []*Service_Task        `protobuf:"bytes,5,rep,name=tasks,proto3" json:"tasks,omitempty"`
	Events               []*Service_Event       `protobuf:"bytes,6,rep,name=events,proto3" json:"events,omitempty"`
	Dependencies         []*Service_Dependency  `protobuf:"bytes,7,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	Repository           string                 `protobuf:"bytes,9,opt,name=repository,proto3" json:"repository,omitempty"`
	Source               string                 `protobuf:"bytes,13,opt,name=source,proto3" json:"source,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

Service represents the service's type.

func (*Service) Descriptor 

func (*Service) Descriptor() ([]byte, []int)

func (*Service) GetConfiguration 

func (m *Service) GetConfiguration() *Service_Configuration

func (*Service) GetDependencies 

func (m *Service) GetDependencies() []*Service_Dependency

func (*Service) GetDescription 

func (m *Service) GetDescription() string

func (*Service) GetEvents 

func (m *Service) GetEvents() []*Service_Event

func (*Service) GetHash 

func (m *Service) GetHash() string

func (*Service) GetName 

func (m *Service) GetName() string

func (*Service) GetRepository 

func (m *Service) GetRepository() string

func (*Service) GetSid 

func (m *Service) GetSid() string

func (*Service) GetSource 

func (m *Service) GetSource() string

func (*Service) GetTasks 

func (m *Service) GetTasks() []*Service_Task

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) Reset 

func (m *Service) Reset()

func (*Service) String 

func (m *Service) String() string

func (*Service) XXX_DiscardUnknown 

func (m *Service) XXX_DiscardUnknown()

func (*Service) XXX_Marshal 

func (m *Service) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Service) XXX_Merge 

func (m *Service) XXX_Merge(src proto.Message)

func (*Service) XXX_Size 

func (m *Service) XXX_Size() int

func (*Service) XXX_Unmarshal 

func (m *Service) XXX_Unmarshal(b []byte) error

type Service_Configuration 

type Service_Configuration struct {
	Volumes              []string `protobuf:"bytes,1,rep,name=volumes,proto3" json:"volumes,omitempty"`
	VolumesFrom          []string `protobuf:"bytes,2,rep,name=volumesFrom,proto3" json:"volumesFrom,omitempty"`
	Ports                []string `protobuf:"bytes,3,rep,name=ports,proto3" json:"ports,omitempty"`
	Args                 []string `protobuf:"bytes,4,rep,name=args,proto3" json:"args,omitempty"`
	Command              string   `protobuf:"bytes,5,opt,name=command,proto3" json:"command,omitempty"`
	Env                  []string `protobuf:"bytes,6,rep,name=env,proto3" json:"env,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A configuration is the configuration of the main container of the service's instance.

func (*Service_Configuration) Descriptor 

func (*Service_Configuration) Descriptor() ([]byte, []int)

func (*Service_Configuration) GetArgs 

func (m *Service_Configuration) GetArgs() []string

func (*Service_Configuration) GetCommand 

func (m *Service_Configuration) GetCommand() string

func (*Service_Configuration) GetEnv 

func (m *Service_Configuration) GetEnv() []string

func (*Service_Configuration) GetPorts 

func (m *Service_Configuration) GetPorts() []string

func (*Service_Configuration) GetVolumes 

func (m *Service_Configuration) GetVolumes() []string

func (*Service_Configuration) GetVolumesFrom 

func (m *Service_Configuration) GetVolumesFrom() []string

func (*Service_Configuration) ProtoMessage 

func (*Service_Configuration) ProtoMessage()

func (*Service_Configuration) Reset 

func (m *Service_Configuration) Reset()

func (*Service_Configuration) String 

func (m *Service_Configuration) String() string

func (*Service_Configuration) XXX_DiscardUnknown 

func (m *Service_Configuration) XXX_DiscardUnknown()

func (*Service_Configuration) XXX_Marshal 

func (m *Service_Configuration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Service_Configuration) XXX_Merge 

func (m *Service_Configuration) XXX_Merge(src proto.Message)

func (*Service_Configuration) XXX_Size 

func (m *Service_Configuration) XXX_Size() int

func (*Service_Configuration) XXX_Unmarshal 

func (m *Service_Configuration) XXX_Unmarshal(b []byte) error

type Service_Dependency 

type Service_Dependency struct {
	Key                  string   `protobuf:"bytes,8,opt,name=key,proto3" json:"key,omitempty"`
	Image                string   `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"`
	Volumes              []string `protobuf:"bytes,2,rep,name=volumes,proto3" json:"volumes,omitempty"`
	VolumesFrom          []string `protobuf:"bytes,3,rep,name=volumesFrom,proto3" json:"volumesFrom,omitempty"`
	Ports                []string `protobuf:"bytes,4,rep,name=ports,proto3" json:"ports,omitempty"`
	Args                 []string `protobuf:"bytes,6,rep,name=args,proto3" json:"args,omitempty"`
	Command              string   `protobuf:"bytes,5,opt,name=command,proto3" json:"command,omitempty"`
	Env                  []string `protobuf:"bytes,9,rep,name=env,proto3" json:"env,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A dependency is a configuration of an other container that runs separately from the service.

func (*Service_Dependency) Descriptor 

func (*Service_Dependency) Descriptor() ([]byte, []int)

func (*Service_Dependency) GetArgs 

func (m *Service_Dependency) GetArgs() []string

func (*Service_Dependency) GetCommand 

func (m *Service_Dependency) GetCommand() string

func (*Service_Dependency) GetEnv 

func (m *Service_Dependency) GetEnv() []string

func (*Service_Dependency) GetImage 

func (m *Service_Dependency) GetImage() string

func (*Service_Dependency) GetKey 

func (m *Service_Dependency) GetKey() string

func (*Service_Dependency) GetPorts 

func (m *Service_Dependency) GetPorts() []string

func (*Service_Dependency) GetVolumes 

func (m *Service_Dependency) GetVolumes() []string

func (*Service_Dependency) GetVolumesFrom 

func (m *Service_Dependency) GetVolumesFrom() []string

func (*Service_Dependency) ProtoMessage 

func (*Service_Dependency) ProtoMessage()

func (*Service_Dependency) Reset 

func (m *Service_Dependency) Reset()

func (*Service_Dependency) String 

func (m *Service_Dependency) String() string

func (*Service_Dependency) XXX_DiscardUnknown 

func (m *Service_Dependency) XXX_DiscardUnknown()

func (*Service_Dependency) XXX_Marshal 

func (m *Service_Dependency) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Service_Dependency) XXX_Merge 

func (m *Service_Dependency) XXX_Merge(src proto.Message)

func (*Service_Dependency) XXX_Size 

func (m *Service_Dependency) XXX_Size() int

func (*Service_Dependency) XXX_Unmarshal 

func (m *Service_Dependency) XXX_Unmarshal(b []byte) error

type Service_Event 

type Service_Event struct {
	Key                  string               `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	Name                 string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description          string               `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Data                 []*Service_Parameter `protobuf:"bytes,3,rep,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Events are emitted by the service whenever the service wants.

func (*Service_Event) Descriptor 

func (*Service_Event) Descriptor() ([]byte, []int)

func (*Service_Event) GetData 

func (m *Service_Event) GetData() []*Service_Parameter

func (*Service_Event) GetDescription 

func (m *Service_Event) GetDescription() string

func (*Service_Event) GetKey 

func (m *Service_Event) GetKey() string

func (*Service_Event) GetName 

func (m *Service_Event) GetName() string

func (*Service_Event) ProtoMessage 

func (*Service_Event) ProtoMessage()

func (*Service_Event) Reset 

func (m *Service_Event) Reset()

func (*Service_Event) String 

func (m *Service_Event) String() string

func (*Service_Event) XXX_DiscardUnknown 

func (m *Service_Event) XXX_DiscardUnknown()

func (*Service_Event) XXX_Marshal 

func (m *Service_Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Service_Event) XXX_Merge 

func (m *Service_Event) XXX_Merge(src proto.Message)

func (*Service_Event) XXX_Size 

func (m *Service_Event) XXX_Size() int

func (*Service_Event) XXX_Unmarshal 

func (m *Service_Event) XXX_Unmarshal(b []byte) error

type Service_Parameter 

type Service_Parameter struct {
	Key                  string               `protobuf:"bytes,8,opt,name=key,proto3" json:"key,omitempty"`
	Name                 string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description          string               `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Type                 string               `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Optional             bool                 `protobuf:"varint,4,opt,name=optional,proto3" json:"optional,omitempty"`
	Repeated             bool                 `protobuf:"varint,9,opt,name=repeated,proto3" json:"repeated,omitempty"`
	Object               []*Service_Parameter `protobuf:"bytes,10,rep,name=object,proto3" json:"object,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Parameter describes the task's inputs, the task's outputs, and the event's data.

func (*Service_Parameter) Descriptor 

func (*Service_Parameter) Descriptor() ([]byte, []int)

func (*Service_Parameter) GetDescription 

func (m *Service_Parameter) GetDescription() string

func (*Service_Parameter) GetKey 

func (m *Service_Parameter) GetKey() string

func (*Service_Parameter) GetName 

func (m *Service_Parameter) GetName() string

func (*Service_Parameter) GetObject 

func (m *Service_Parameter) GetObject() []*Service_Parameter

func (*Service_Parameter) GetOptional 

func (m *Service_Parameter) GetOptional() bool

func (*Service_Parameter) GetRepeated 

func (m *Service_Parameter) GetRepeated() bool

func (*Service_Parameter) GetType 

func (m *Service_Parameter) GetType() string

func (*Service_Parameter) ProtoMessage 

func (*Service_Parameter) ProtoMessage()

func (*Service_Parameter) Reset 

func (m *Service_Parameter) Reset()

func (*Service_Parameter) String 

func (m *Service_Parameter) String() string

func (*Service_Parameter) XXX_DiscardUnknown 

func (m *Service_Parameter) XXX_DiscardUnknown()

func (*Service_Parameter) XXX_Marshal 

func (m *Service_Parameter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Service_Parameter) XXX_Merge 

func (m *Service_Parameter) XXX_Merge(src proto.Message)

func (*Service_Parameter) XXX_Size 

func (m *Service_Parameter) XXX_Size() int

func (*Service_Parameter) XXX_Unmarshal 

func (m *Service_Parameter) XXX_Unmarshal(b []byte) error

type Service_Task 

type Service_Task struct {
	Key                  string               `protobuf:"bytes,8,opt,name=key,proto3" json:"key,omitempty"`
	Name                 string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description          string               `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Inputs               []*Service_Parameter `protobuf:"bytes,6,rep,name=inputs,proto3" json:"inputs,omitempty"`
	Outputs              []*Service_Parameter `protobuf:"bytes,7,rep,name=outputs,proto3" json:"outputs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Task is a function that requires inputs and returns output.

func (*Service_Task) Descriptor 

func (*Service_Task) Descriptor() ([]byte, []int)

func (*Service_Task) GetDescription 

func (m *Service_Task) GetDescription() string

func (*Service_Task) GetInputs 

func (m *Service_Task) GetInputs() []*Service_Parameter

func (*Service_Task) GetKey 

func (m *Service_Task) GetKey() string

func (*Service_Task) GetName 

func (m *Service_Task) GetName() string

func (*Service_Task) GetOutputs 

func (m *Service_Task) GetOutputs() []*Service_Parameter

func (*Service_Task) ProtoMessage 

func (*Service_Task) ProtoMessage()

func (*Service_Task) Reset 

func (m *Service_Task) Reset()

func (*Service_Task) String 

func (m *Service_Task) String() string

func (*Service_Task) XXX_DiscardUnknown 

func (m *Service_Task) XXX_DiscardUnknown()

func (*Service_Task) XXX_Marshal 

func (m *Service_Task) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Service_Task) XXX_Merge 

func (m *Service_Task) XXX_Merge(src proto.Message)

func (*Service_Task) XXX_Size 

func (m *Service_Task) XXX_Size() int

func (*Service_Task) XXX_Unmarshal 

func (m *Service_Task) XXX_Unmarshal(b []byte) error

type Status 

type Status int32

Status represents the status of a single execution. Note that a valid execution must have only one status flag at time. 

const (
	// Unknown status represents any status unknown to execution.
	Status_Unknown Status = 0
	// Created is an initial status after execution creation.
	Status_Created Status = 1
	// InProgress informs that processing of execution has been started.
	Status_InProgress Status = 2
	// Completed is a success status after execution was processed.
	Status_Completed Status = 3
	// Failed is an error status after execution was processed.
	Status_Failed Status = 4
)

func (Status) EnumDescriptor 

func (Status) EnumDescriptor() ([]byte, []int)

func (Status) String 

func (x Status) String() string

type Workflow added in v0.13.0 

type Workflow struct {
	Hash                 string            `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	Key                  string            `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Trigger              *Workflow_Trigger `protobuf:"bytes,3,opt,name=trigger,proto3" json:"trigger,omitempty"`
	Nodes                []*Workflow_Node  `protobuf:"bytes,4,rep,name=nodes,proto3" json:"nodes,omitempty"`
	Edges                []*Workflow_Edge  `protobuf:"bytes,5,rep,name=edges,proto3" json:"edges,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

A workflow is a configuration to trigger a specific task when certains conditions of a trigger are valid.

func (*Workflow) Descriptor added in v0.13.0 

func (*Workflow) Descriptor() ([]byte, []int)

func (*Workflow) GetEdges added in v0.13.0 

func (m *Workflow) GetEdges() []*Workflow_Edge

func (*Workflow) GetHash added in v0.13.0 

func (m *Workflow) GetHash() string

func (*Workflow) GetKey added in v0.13.0 

func (m *Workflow) GetKey() string

func (*Workflow) GetNodes added in v0.13.0 

func (m *Workflow) GetNodes() []*Workflow_Node

func (*Workflow) GetTrigger added in v0.13.0 

func (m *Workflow) GetTrigger() *Workflow_Trigger

func (*Workflow) ProtoMessage added in v0.13.0 

func (*Workflow) ProtoMessage()

func (*Workflow) Reset added in v0.13.0 

func (m *Workflow) Reset()

func (*Workflow) String added in v0.13.0 

func (m *Workflow) String() string

func (*Workflow) XXX_DiscardUnknown added in v0.13.0 

func (m *Workflow) XXX_DiscardUnknown()

func (*Workflow) XXX_Marshal added in v0.13.0 

func (m *Workflow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Workflow) XXX_Merge added in v0.13.0 

func (m *Workflow) XXX_Merge(src proto.Message)

func (*Workflow) XXX_Size added in v0.13.0 

func (m *Workflow) XXX_Size() int

func (*Workflow) XXX_Unmarshal added in v0.13.0 

func (m *Workflow) XXX_Unmarshal(b []byte) error

type Workflow_Edge added in v0.13.0 

type Workflow_Edge struct {
	Src                  string   `protobuf:"bytes,1,opt,name=src,proto3" json:"src,omitempty"`
	Dst                  string   `protobuf:"bytes,2,opt,name=dst,proto3" json:"dst,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Workflow_Edge) Descriptor added in v0.13.0 

func (*Workflow_Edge) Descriptor() ([]byte, []int)

func (*Workflow_Edge) GetDst added in v0.13.0 

func (m *Workflow_Edge) GetDst() string

func (*Workflow_Edge) GetSrc added in v0.13.0 

func (m *Workflow_Edge) GetSrc() string

func (*Workflow_Edge) ProtoMessage added in v0.13.0 

func (*Workflow_Edge) ProtoMessage()

func (*Workflow_Edge) Reset added in v0.13.0 

func (m *Workflow_Edge) Reset()

func (*Workflow_Edge) String added in v0.13.0 

func (m *Workflow_Edge) String() string

func (*Workflow_Edge) XXX_DiscardUnknown added in v0.13.0 

func (m *Workflow_Edge) XXX_DiscardUnknown()

func (*Workflow_Edge) XXX_Marshal added in v0.13.0 

func (m *Workflow_Edge) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Workflow_Edge) XXX_Merge added in v0.13.0 

func (m *Workflow_Edge) XXX_Merge(src proto.Message)

func (*Workflow_Edge) XXX_Size added in v0.13.0 

func (m *Workflow_Edge) XXX_Size() int

func (*Workflow_Edge) XXX_Unmarshal added in v0.13.0 

func (m *Workflow_Edge) XXX_Unmarshal(b []byte) error

type Workflow_Node added in v0.13.0 

type Workflow_Node struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	InstanceHash         string   `protobuf:"bytes,2,opt,name=instanceHash,proto3" json:"instanceHash,omitempty"`
	TaskKey              string   `protobuf:"bytes,3,opt,name=taskKey,proto3" json:"taskKey,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Definition of the node to execute when the workflow is triggered.

func (*Workflow_Node) Descriptor added in v0.13.0 

func (*Workflow_Node) Descriptor() ([]byte, []int)

func (*Workflow_Node) GetInstanceHash added in v0.13.0 

func (m *Workflow_Node) GetInstanceHash() string

func (*Workflow_Node) GetKey added in v0.13.0 

func (m *Workflow_Node) GetKey() string

func (*Workflow_Node) GetTaskKey added in v0.13.0 

func (m *Workflow_Node) GetTaskKey() string

func (*Workflow_Node) ProtoMessage added in v0.13.0 

func (*Workflow_Node) ProtoMessage()

func (*Workflow_Node) Reset added in v0.13.0 

func (m *Workflow_Node) Reset()

func (*Workflow_Node) String added in v0.13.0 

func (m *Workflow_Node) String() string

func (*Workflow_Node) XXX_DiscardUnknown added in v0.13.0 

func (m *Workflow_Node) XXX_DiscardUnknown()

func (*Workflow_Node) XXX_Marshal added in v0.13.0 

func (m *Workflow_Node) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Workflow_Node) XXX_Merge added in v0.13.0 

func (m *Workflow_Node) XXX_Merge(src proto.Message)

func (*Workflow_Node) XXX_Size added in v0.13.0 

func (m *Workflow_Node) XXX_Size() int

func (*Workflow_Node) XXX_Unmarshal added in v0.13.0 

func (m *Workflow_Node) XXX_Unmarshal(b []byte) error

type Workflow_Trigger added in v0.13.0 

type Workflow_Trigger struct {
	InstanceHash string `protobuf:"bytes,1,opt,name=instanceHash,proto3" json:"instanceHash,omitempty"`
	// Types that are valid to be assigned to Key:
	//	*Workflow_Trigger_TaskKey
	//	*Workflow_Trigger_EventKey
	Key                  isWorkflow_Trigger_Key     `protobuf_oneof:"key"`
	Filters              []*Workflow_Trigger_Filter `protobuf:"bytes,4,rep,name=filters,proto3" json:"filters,omitempty"`
	NodeKey              string                     `protobuf:"bytes,5,opt,name=nodeKey,proto3" json:"nodeKey,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

Trigger is the configuration that will trigger a workflow.

func (*Workflow_Trigger) Descriptor added in v0.13.0 

func (*Workflow_Trigger) Descriptor() ([]byte, []int)

func (*Workflow_Trigger) GetEventKey added in v0.13.0 

func (m *Workflow_Trigger) GetEventKey() string

func (*Workflow_Trigger) GetFilters added in v0.13.0 

func (m *Workflow_Trigger) GetFilters() []*Workflow_Trigger_Filter

func (*Workflow_Trigger) GetInstanceHash added in v0.13.0 

func (m *Workflow_Trigger) GetInstanceHash() string

func (*Workflow_Trigger) GetKey added in v0.13.0 

func (m *Workflow_Trigger) GetKey() isWorkflow_Trigger_Key

func (*Workflow_Trigger) GetNodeKey added in v0.13.0 

func (m *Workflow_Trigger) GetNodeKey() string

func (*Workflow_Trigger) GetTaskKey added in v0.13.0 

func (m *Workflow_Trigger) GetTaskKey() string

func (*Workflow_Trigger) ProtoMessage added in v0.13.0 

func (*Workflow_Trigger) ProtoMessage()

func (*Workflow_Trigger) Reset added in v0.13.0 

func (m *Workflow_Trigger) Reset()

func (*Workflow_Trigger) String added in v0.13.0 

func (m *Workflow_Trigger) String() string

func (*Workflow_Trigger) XXX_DiscardUnknown added in v0.13.0 

func (m *Workflow_Trigger) XXX_DiscardUnknown()

func (*Workflow_Trigger) XXX_Marshal added in v0.13.0 

func (m *Workflow_Trigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Workflow_Trigger) XXX_Merge added in v0.13.0 

func (m *Workflow_Trigger) XXX_Merge(src proto.Message)

func (*Workflow_Trigger) XXX_OneofWrappers added in v0.13.0 

func (*Workflow_Trigger) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Workflow_Trigger) XXX_Size added in v0.13.0 

func (m *Workflow_Trigger) XXX_Size() int

func (*Workflow_Trigger) XXX_Unmarshal added in v0.13.0 

func (m *Workflow_Trigger) XXX_Unmarshal(b []byte) error

type Workflow_Trigger_EventKey added in v0.13.0 

type Workflow_Trigger_EventKey struct {
	EventKey string `protobuf:"bytes,3,opt,name=eventKey,proto3,oneof"`
}

type Workflow_Trigger_Filter added in v0.13.0 

type Workflow_Trigger_Filter struct {
	Key                  string                            `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Predicate            Workflow_Trigger_Filter_Predicate `protobuf:"varint,2,opt,name=predicate,proto3,enum=types.Workflow_Trigger_Filter_Predicate" json:"predicate,omitempty"`
	Value                string                            `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

Filter is applied on the data of the event/result.

func (*Workflow_Trigger_Filter) Descriptor added in v0.13.0 

func (*Workflow_Trigger_Filter) Descriptor() ([]byte, []int)

func (*Workflow_Trigger_Filter) GetKey added in v0.13.0 

func (m *Workflow_Trigger_Filter) GetKey() string

func (*Workflow_Trigger_Filter) GetPredicate added in v0.13.0 

func (m *Workflow_Trigger_Filter) GetPredicate() Workflow_Trigger_Filter_Predicate

func (*Workflow_Trigger_Filter) GetValue added in v0.13.0 

func (m *Workflow_Trigger_Filter) GetValue() string

func (*Workflow_Trigger_Filter) ProtoMessage added in v0.13.0 

func (*Workflow_Trigger_Filter) ProtoMessage()

func (*Workflow_Trigger_Filter) Reset added in v0.13.0 

func (m *Workflow_Trigger_Filter) Reset()

func (*Workflow_Trigger_Filter) String added in v0.13.0 

func (m *Workflow_Trigger_Filter) String() string

func (*Workflow_Trigger_Filter) XXX_DiscardUnknown added in v0.13.0 

func (m *Workflow_Trigger_Filter) XXX_DiscardUnknown()

func (*Workflow_Trigger_Filter) XXX_Marshal added in v0.13.0 

func (m *Workflow_Trigger_Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Workflow_Trigger_Filter) XXX_Merge added in v0.13.0 

func (m *Workflow_Trigger_Filter) XXX_Merge(src proto.Message)

func (*Workflow_Trigger_Filter) XXX_Size added in v0.13.0 

func (m *Workflow_Trigger_Filter) XXX_Size() int

func (*Workflow_Trigger_Filter) XXX_Unmarshal added in v0.13.0 

func (m *Workflow_Trigger_Filter) XXX_Unmarshal(b []byte) error

type Workflow_Trigger_Filter_Predicate added in v0.13.0 

type Workflow_Trigger_Filter_Predicate int32

Type of condition available to compare the values. 

const (
	Workflow_Trigger_Filter_Unknown Workflow_Trigger_Filter_Predicate = 0
	Workflow_Trigger_Filter_EQ      Workflow_Trigger_Filter_Predicate = 1
)

func (Workflow_Trigger_Filter_Predicate) EnumDescriptor added in v0.13.0 

func (Workflow_Trigger_Filter_Predicate) EnumDescriptor() ([]byte, []int)

func (Workflow_Trigger_Filter_Predicate) String added in v0.13.0 

func (x Workflow_Trigger_Filter_Predicate) String() string

type Workflow_Trigger_TaskKey added in v0.13.0 

type Workflow_Trigger_TaskKey struct {
	TaskKey string `protobuf:"bytes,2,opt,name=taskKey,proto3,oneof"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.