types

package
v0.12.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Service_Workflow_Trigger_Filter_Predicate_name = map[int32]string{
	0: "Unknown",
	1: "EQ",
}
View Source 
var Service_Workflow_Trigger_Filter_Predicate_value = map[string]int32{
	"Unknown": 0,
	"EQ":      1,
}
View Source 
var Service_Workflow_Trigger_Type_name = map[int32]string{
	0: "Unknown",
	1: "Event",
	2: "Result",
}
View Source 
var Service_Workflow_Trigger_Type_value = map[string]int32{
	"Unknown": 0,
	"Event":   1,
	"Result":  2,
}
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,
}

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"`
	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) GetTags 

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

func (*Execution) GetTaskKey 

func (m *Execution) GetTaskKey() 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"`
	Workflows            []*Service_Workflow    `protobuf:"bytes,14,rep,name=workflows,proto3" json:"workflows,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) GetWorkflows added in v0.12.0 

func (m *Service) GetWorkflows() []*Service_Workflow

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 Service_Workflow added in v0.12.0 

type Service_Workflow struct {
	Key                  string                    `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Trigger              *Service_Workflow_Trigger `protobuf:"bytes,1,opt,name=trigger,proto3" json:"trigger,omitempty"`
	Task                 *Service_Workflow_Task    `protobuf:"bytes,2,opt,name=task,proto3" json:"task,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 (*Service_Workflow) Descriptor added in v0.12.0 

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

func (*Service_Workflow) GetKey added in v0.12.0 

func (m *Service_Workflow) GetKey() string

func (*Service_Workflow) GetTask added in v0.12.0 

func (m *Service_Workflow) GetTask() *Service_Workflow_Task

func (*Service_Workflow) GetTrigger added in v0.12.0 

func (m *Service_Workflow) GetTrigger() *Service_Workflow_Trigger

func (*Service_Workflow) ProtoMessage added in v0.12.0 

func (*Service_Workflow) ProtoMessage()

func (*Service_Workflow) Reset added in v0.12.0 

func (m *Service_Workflow) Reset()

func (*Service_Workflow) String added in v0.12.0 

func (m *Service_Workflow) String() string

func (*Service_Workflow) XXX_DiscardUnknown added in v0.12.0 

func (m *Service_Workflow) XXX_DiscardUnknown()

func (*Service_Workflow) XXX_Marshal added in v0.12.0 

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

func (*Service_Workflow) XXX_Merge added in v0.12.0 

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

func (*Service_Workflow) XXX_Size added in v0.12.0 

func (m *Service_Workflow) XXX_Size() int

func (*Service_Workflow) XXX_Unmarshal added in v0.12.0 

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

type Service_Workflow_Task added in v0.12.0 

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

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

func (*Service_Workflow_Task) Descriptor added in v0.12.0 

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

func (*Service_Workflow_Task) GetInstanceHash added in v0.12.0 

func (m *Service_Workflow_Task) GetInstanceHash() string

func (*Service_Workflow_Task) GetTaskKey added in v0.12.0 

func (m *Service_Workflow_Task) GetTaskKey() string

func (*Service_Workflow_Task) ProtoMessage added in v0.12.0 

func (*Service_Workflow_Task) ProtoMessage()

func (*Service_Workflow_Task) Reset added in v0.12.0 

func (m *Service_Workflow_Task) Reset()

func (*Service_Workflow_Task) String added in v0.12.0 

func (m *Service_Workflow_Task) String() string

func (*Service_Workflow_Task) XXX_DiscardUnknown added in v0.12.0 

func (m *Service_Workflow_Task) XXX_DiscardUnknown()

func (*Service_Workflow_Task) XXX_Marshal added in v0.12.0 

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

func (*Service_Workflow_Task) XXX_Merge added in v0.12.0 

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

func (*Service_Workflow_Task) XXX_Size added in v0.12.0 

func (m *Service_Workflow_Task) XXX_Size() int

func (*Service_Workflow_Task) XXX_Unmarshal added in v0.12.0 

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

type Service_Workflow_Trigger added in v0.12.0 

type Service_Workflow_Trigger struct {
	Type                 Service_Workflow_Trigger_Type      `protobuf:"varint,1,opt,name=type,proto3,enum=types.Service_Workflow_Trigger_Type" json:"type,omitempty"`
	InstanceHash         string                             `protobuf:"bytes,2,opt,name=instanceHash,proto3" json:"instanceHash,omitempty"`
	Key                  string                             `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Filters              []*Service_Workflow_Trigger_Filter `protobuf:"bytes,4,rep,name=filters,proto3" json:"filters,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
	XXX_unrecognized     []byte                             `json:"-"`
	XXX_sizecache        int32                              `json:"-"`
}

Trigger is the configuration that will trigger a workflow.

func (*Service_Workflow_Trigger) Descriptor added in v0.12.0 

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

func (*Service_Workflow_Trigger) GetFilters added in v0.12.0 

func (m *Service_Workflow_Trigger) GetFilters() []*Service_Workflow_Trigger_Filter

func (*Service_Workflow_Trigger) GetInstanceHash added in v0.12.0 

func (m *Service_Workflow_Trigger) GetInstanceHash() string

func (*Service_Workflow_Trigger) GetKey added in v0.12.0 

func (m *Service_Workflow_Trigger) GetKey() string

func (*Service_Workflow_Trigger) GetType added in v0.12.0 

func (m *Service_Workflow_Trigger) GetType() Service_Workflow_Trigger_Type

func (*Service_Workflow_Trigger) ProtoMessage added in v0.12.0 

func (*Service_Workflow_Trigger) ProtoMessage()

func (*Service_Workflow_Trigger) Reset added in v0.12.0 

func (m *Service_Workflow_Trigger) Reset()

func (*Service_Workflow_Trigger) String added in v0.12.0 

func (m *Service_Workflow_Trigger) String() string

func (*Service_Workflow_Trigger) XXX_DiscardUnknown added in v0.12.0 

func (m *Service_Workflow_Trigger) XXX_DiscardUnknown()

func (*Service_Workflow_Trigger) XXX_Marshal added in v0.12.0 

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

func (*Service_Workflow_Trigger) XXX_Merge added in v0.12.0 

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

func (*Service_Workflow_Trigger) XXX_Size added in v0.12.0 

func (m *Service_Workflow_Trigger) XXX_Size() int

func (*Service_Workflow_Trigger) XXX_Unmarshal added in v0.12.0 

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

type Service_Workflow_Trigger_Filter added in v0.12.0 

type Service_Workflow_Trigger_Filter struct {
	Key                  string                                    `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Predicate            Service_Workflow_Trigger_Filter_Predicate `protobuf:"varint,2,opt,name=predicate,proto3,enum=types.Service_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 (*Service_Workflow_Trigger_Filter) Descriptor added in v0.12.0 

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

func (*Service_Workflow_Trigger_Filter) GetKey added in v0.12.0 

func (m *Service_Workflow_Trigger_Filter) GetKey() string

func (*Service_Workflow_Trigger_Filter) GetPredicate added in v0.12.0 

func (m *Service_Workflow_Trigger_Filter) GetPredicate() Service_Workflow_Trigger_Filter_Predicate

func (*Service_Workflow_Trigger_Filter) GetValue added in v0.12.0 

func (m *Service_Workflow_Trigger_Filter) GetValue() string

func (*Service_Workflow_Trigger_Filter) ProtoMessage added in v0.12.0 

func (*Service_Workflow_Trigger_Filter) ProtoMessage()

func (*Service_Workflow_Trigger_Filter) Reset added in v0.12.0 

func (m *Service_Workflow_Trigger_Filter) Reset()

func (*Service_Workflow_Trigger_Filter) String added in v0.12.0 

func (m *Service_Workflow_Trigger_Filter) String() string

func (*Service_Workflow_Trigger_Filter) XXX_DiscardUnknown added in v0.12.0 

func (m *Service_Workflow_Trigger_Filter) XXX_DiscardUnknown()

func (*Service_Workflow_Trigger_Filter) XXX_Marshal added in v0.12.0 

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

func (*Service_Workflow_Trigger_Filter) XXX_Merge added in v0.12.0 

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

func (*Service_Workflow_Trigger_Filter) XXX_Size added in v0.12.0 

func (m *Service_Workflow_Trigger_Filter) XXX_Size() int

func (*Service_Workflow_Trigger_Filter) XXX_Unmarshal added in v0.12.0 

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

type Service_Workflow_Trigger_Filter_Predicate added in v0.12.0 

type Service_Workflow_Trigger_Filter_Predicate int32

Type of condition available to compare the values. 

const (
	Service_Workflow_Trigger_Filter_Unknown Service_Workflow_Trigger_Filter_Predicate = 0
	Service_Workflow_Trigger_Filter_EQ      Service_Workflow_Trigger_Filter_Predicate = 1
)

func (Service_Workflow_Trigger_Filter_Predicate) EnumDescriptor added in v0.12.0 

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

func (Service_Workflow_Trigger_Filter_Predicate) String added in v0.12.0 

func (x Service_Workflow_Trigger_Filter_Predicate) String() string

type Service_Workflow_Trigger_Type added in v0.12.0 

type Service_Workflow_Trigger_Type int32

Type of trigger available. Event to react to an event. Result to react to a result of an execution. 

const (
	Service_Workflow_Trigger_Unknown Service_Workflow_Trigger_Type = 0
	Service_Workflow_Trigger_Event   Service_Workflow_Trigger_Type = 1
	Service_Workflow_Trigger_Result  Service_Workflow_Trigger_Type = 2
)

func (Service_Workflow_Trigger_Type) EnumDescriptor added in v0.12.0 

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

func (Service_Workflow_Trigger_Type) String added in v0.12.0 

func (x Service_Workflow_Trigger_Type) String() string

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

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.