workflow

package
v0.0.0-...-98d7d05 Latest Latest
Warning

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

 Go to latest Published: Mar 26, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ActionState_name = map[int32]string{
	0: "ACTION_PENDING",
	1: "ACTION_IN_PROGRESS",
	2: "ACTION_SUCCESS",
	3: "ACTION_FAILED",
	4: "ACTION_TIMEOUT",
}
View Source 
var ActionState_value = map[string]int32{
	"ACTION_PENDING":     0,
	"ACTION_IN_PROGRESS": 1,
	"ACTION_SUCCESS":     2,
	"ACTION_FAILED":      3,
	"ACTION_TIMEOUT":     4,
}
View Source 
var State_name = map[int32]string{
	0: "PENDING",
	1: "RUNNING",
	2: "FAILED",
	3: "TIMEOUT",
	4: "SUCCESS",
}
View Source 
var State_value = map[string]int32{
	"PENDING": 0,
	"RUNNING": 1,
	"FAILED":  2,
	"TIMEOUT": 3,
	"SUCCESS": 4,
}

Functions

func RegisterWorkflowSvcServer 

func RegisterWorkflowSvcServer(s *grpc.Server, srv WorkflowSvcServer)

Types

type ActionState 

type ActionState int32
const (
	ActionState_ACTION_PENDING     ActionState = 0
	ActionState_ACTION_IN_PROGRESS ActionState = 1
	ActionState_ACTION_SUCCESS     ActionState = 2
	ActionState_ACTION_FAILED      ActionState = 3
	ActionState_ACTION_TIMEOUT     ActionState = 4
)

func (ActionState) EnumDescriptor 

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

func (ActionState) String 

func (x ActionState) String() string

type CreateRequest 

type CreateRequest struct {
	Template             string   `protobuf:"bytes,1,opt,name=template,proto3" json:"template,omitempty"`
	Target               string   `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateRequest) Descriptor 

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

func (*CreateRequest) GetTarget 

func (m *CreateRequest) GetTarget() string

func (*CreateRequest) GetTemplate 

func (m *CreateRequest) GetTemplate() string

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) Reset 

func (m *CreateRequest) Reset()

func (*CreateRequest) String 

func (m *CreateRequest) String() string

func (*CreateRequest) XXX_DiscardUnknown 

func (m *CreateRequest) XXX_DiscardUnknown()

func (*CreateRequest) XXX_Marshal 

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

func (*CreateRequest) XXX_Merge 

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

func (*CreateRequest) XXX_Size 

func (m *CreateRequest) XXX_Size() int

func (*CreateRequest) XXX_Unmarshal 

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

type CreateResponse 

type CreateResponse struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateResponse) Descriptor 

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

func (*CreateResponse) GetId 

func (m *CreateResponse) GetId() string

func (*CreateResponse) ProtoMessage 

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) Reset 

func (m *CreateResponse) Reset()

func (*CreateResponse) String 

func (m *CreateResponse) String() string

func (*CreateResponse) XXX_DiscardUnknown 

func (m *CreateResponse) XXX_DiscardUnknown()

func (*CreateResponse) XXX_Marshal 

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

func (*CreateResponse) XXX_Merge 

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

func (*CreateResponse) XXX_Size 

func (m *CreateResponse) XXX_Size() int

func (*CreateResponse) XXX_Unmarshal 

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

type Empty 

type Empty struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Empty) Descriptor 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

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

func (*Empty) XXX_Merge 

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

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

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

type GetRequest 

type GetRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetId 

func (m *GetRequest) GetId() string

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) String 

func (m *GetRequest) String() string

func (*GetRequest) XXX_DiscardUnknown 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal 

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

func (*GetRequest) XXX_Merge 

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

func (*GetRequest) XXX_Size 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal 

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

type GetWorkflowDataRequest 

type GetWorkflowDataRequest struct {
	WorkflowID           string   `protobuf:"bytes,1,opt,name=workflow_iD,json=workflowID,proto3" json:"workflow_iD,omitempty"`
	Version              int32    `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetWorkflowDataRequest) Descriptor 

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

func (*GetWorkflowDataRequest) GetVersion 

func (m *GetWorkflowDataRequest) GetVersion() int32

func (*GetWorkflowDataRequest) GetWorkflowID 

func (m *GetWorkflowDataRequest) GetWorkflowID() string

func (*GetWorkflowDataRequest) ProtoMessage 

func (*GetWorkflowDataRequest) ProtoMessage()

func (*GetWorkflowDataRequest) Reset 

func (m *GetWorkflowDataRequest) Reset()

func (*GetWorkflowDataRequest) String 

func (m *GetWorkflowDataRequest) String() string

func (*GetWorkflowDataRequest) XXX_DiscardUnknown 

func (m *GetWorkflowDataRequest) XXX_DiscardUnknown()

func (*GetWorkflowDataRequest) XXX_Marshal 

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

func (*GetWorkflowDataRequest) XXX_Merge 

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

func (*GetWorkflowDataRequest) XXX_Size 

func (m *GetWorkflowDataRequest) XXX_Size() int

func (*GetWorkflowDataRequest) XXX_Unmarshal 

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

type GetWorkflowDataResponse 

type GetWorkflowDataResponse struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Version              int32    `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetWorkflowDataResponse) Descriptor 

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

func (*GetWorkflowDataResponse) GetData 

func (m *GetWorkflowDataResponse) GetData() []byte

func (*GetWorkflowDataResponse) GetVersion 

func (m *GetWorkflowDataResponse) GetVersion() int32

func (*GetWorkflowDataResponse) ProtoMessage 

func (*GetWorkflowDataResponse) ProtoMessage()

func (*GetWorkflowDataResponse) Reset 

func (m *GetWorkflowDataResponse) Reset()

func (*GetWorkflowDataResponse) String 

func (m *GetWorkflowDataResponse) String() string

func (*GetWorkflowDataResponse) XXX_DiscardUnknown 

func (m *GetWorkflowDataResponse) XXX_DiscardUnknown()

func (*GetWorkflowDataResponse) XXX_Marshal 

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

func (*GetWorkflowDataResponse) XXX_Merge 

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

func (*GetWorkflowDataResponse) XXX_Size 

func (m *GetWorkflowDataResponse) XXX_Size() int

func (*GetWorkflowDataResponse) XXX_Unmarshal 

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

type State 

type State int32
const (
	State_PENDING State = 0
	State_RUNNING State = 1
	State_FAILED  State = 2
	State_TIMEOUT State = 3
	State_SUCCESS State = 4
)

func (State) EnumDescriptor 

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

func (State) String 

func (x State) String() string

type UnimplementedWorkflowSvcServer 

type UnimplementedWorkflowSvcServer struct {
}

UnimplementedWorkflowSvcServer can be embedded to have forward compatible implementations.

func (*UnimplementedWorkflowSvcServer) CreateWorkflow 

func (*UnimplementedWorkflowSvcServer) CreateWorkflow(ctx context.Context, req *CreateRequest) (*CreateResponse, error)

func (*UnimplementedWorkflowSvcServer) DeleteWorkflow 

func (*UnimplementedWorkflowSvcServer) DeleteWorkflow(ctx context.Context, req *GetRequest) (*Empty, error)

func (*UnimplementedWorkflowSvcServer) GetWorkflow 

func (*UnimplementedWorkflowSvcServer) GetWorkflow(ctx context.Context, req *GetRequest) (*Workflow, error)

func (*UnimplementedWorkflowSvcServer) GetWorkflowActions 

func (*UnimplementedWorkflowSvcServer) GetWorkflowActions(ctx context.Context, req *WorkflowActionsRequest) (*WorkflowActionList, error)

func (*UnimplementedWorkflowSvcServer) GetWorkflowContext 

func (*UnimplementedWorkflowSvcServer) GetWorkflowContext(ctx context.Context, req *GetRequest) (*WorkflowContext, error)

func (*UnimplementedWorkflowSvcServer) GetWorkflowContexts 

func (*UnimplementedWorkflowSvcServer) GetWorkflowContexts(ctx context.Context, req *WorkflowContextRequest) (*WorkflowContextList, error)

func (*UnimplementedWorkflowSvcServer) GetWorkflowData 

func (*UnimplementedWorkflowSvcServer) GetWorkflowData(ctx context.Context, req *GetWorkflowDataRequest) (*GetWorkflowDataResponse, error)

func (*UnimplementedWorkflowSvcServer) GetWorkflowDataVersion 

func (*UnimplementedWorkflowSvcServer) GetWorkflowDataVersion(ctx context.Context, req *GetWorkflowDataRequest) (*GetWorkflowDataResponse, error)

func (*UnimplementedWorkflowSvcServer) GetWorkflowMetadata 

func (*UnimplementedWorkflowSvcServer) GetWorkflowMetadata(ctx context.Context, req *GetWorkflowDataRequest) (*GetWorkflowDataResponse, error)

func (*UnimplementedWorkflowSvcServer) ListWorkflows 

func (*UnimplementedWorkflowSvcServer) ListWorkflows(req *Empty, srv WorkflowSvc_ListWorkflowsServer) error

func (*UnimplementedWorkflowSvcServer) ReportActionStatus 

func (*UnimplementedWorkflowSvcServer) ReportActionStatus(ctx context.Context, req *WorkflowActionStatus) (*Empty, error)

func (*UnimplementedWorkflowSvcServer) ShowWorkflowEvents 

func (*UnimplementedWorkflowSvcServer) ShowWorkflowEvents(req *GetRequest, srv WorkflowSvc_ShowWorkflowEventsServer) error

func (*UnimplementedWorkflowSvcServer) UpdateWorkflowData 

func (*UnimplementedWorkflowSvcServer) UpdateWorkflowData(ctx context.Context, req *UpdateWorkflowDataRequest) (*Empty, error)

type UpdateWorkflowDataRequest 

type UpdateWorkflowDataRequest struct {
	WorkflowID           string   `protobuf:"bytes,1,opt,name=workflow_iD,json=workflowID,proto3" json:"workflow_iD,omitempty"`
	Metadata             []byte   `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Data                 []byte   `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateWorkflowDataRequest) Descriptor 

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

func (*UpdateWorkflowDataRequest) GetData 

func (m *UpdateWorkflowDataRequest) GetData() []byte

func (*UpdateWorkflowDataRequest) GetMetadata 

func (m *UpdateWorkflowDataRequest) GetMetadata() []byte

func (*UpdateWorkflowDataRequest) GetWorkflowID 

func (m *UpdateWorkflowDataRequest) GetWorkflowID() string

func (*UpdateWorkflowDataRequest) ProtoMessage 

func (*UpdateWorkflowDataRequest) ProtoMessage()

func (*UpdateWorkflowDataRequest) Reset 

func (m *UpdateWorkflowDataRequest) Reset()

func (*UpdateWorkflowDataRequest) String 

func (m *UpdateWorkflowDataRequest) String() string

func (*UpdateWorkflowDataRequest) XXX_DiscardUnknown 

func (m *UpdateWorkflowDataRequest) XXX_DiscardUnknown()

func (*UpdateWorkflowDataRequest) XXX_Marshal 

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

func (*UpdateWorkflowDataRequest) XXX_Merge 

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

func (*UpdateWorkflowDataRequest) XXX_Size 

func (m *UpdateWorkflowDataRequest) XXX_Size() int

func (*UpdateWorkflowDataRequest) XXX_Unmarshal 

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

type Workflow 

type Workflow struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Template             string               `protobuf:"bytes,2,opt,name=template,proto3" json:"template,omitempty"`
	Target               string               `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	State                State                `protobuf:"varint,4,opt,name=state,proto3,enum=github.com.packethost.tinkerbell.protos.workflow.State" json:"state,omitempty"`
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,5,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
	UpdatedAt            *timestamp.Timestamp `protobuf:"bytes,6,opt,name=updatedAt,proto3" json:"updatedAt,omitempty"`
	DeletedAt            *timestamp.Timestamp `protobuf:"bytes,7,opt,name=deletedAt,proto3" json:"deletedAt,omitempty"`
	Data                 string               `protobuf:"bytes,8,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Workflow) Descriptor 

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

func (*Workflow) GetCreatedAt 

func (m *Workflow) GetCreatedAt() *timestamp.Timestamp

func (*Workflow) GetData 

func (m *Workflow) GetData() string

func (*Workflow) GetDeletedAt 

func (m *Workflow) GetDeletedAt() *timestamp.Timestamp

func (*Workflow) GetId 

func (m *Workflow) GetId() string

func (*Workflow) GetState 

func (m *Workflow) GetState() State

func (*Workflow) GetTarget 

func (m *Workflow) GetTarget() string

func (*Workflow) GetTemplate 

func (m *Workflow) GetTemplate() string

func (*Workflow) GetUpdatedAt 

func (m *Workflow) GetUpdatedAt() *timestamp.Timestamp

func (*Workflow) ProtoMessage 

func (*Workflow) ProtoMessage()

func (*Workflow) Reset 

func (m *Workflow) Reset()

func (*Workflow) String 

func (m *Workflow) String() string

func (*Workflow) XXX_DiscardUnknown 

func (m *Workflow) XXX_DiscardUnknown()

func (*Workflow) XXX_Marshal 

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

func (*Workflow) XXX_Merge 

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

func (*Workflow) XXX_Size 

func (m *Workflow) XXX_Size() int

func (*Workflow) XXX_Unmarshal 

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

type WorkflowAction 

type WorkflowAction struct {
	TaskName             string   `protobuf:"bytes,1,opt,name=task_name,json=taskName,proto3" json:"task_name,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Image                string   `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
	Timeout              int64    `protobuf:"varint,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Command              []string `protobuf:"bytes,5,rep,name=command,proto3" json:"command,omitempty"`
	OnTimeout            []string `protobuf:"bytes,6,rep,name=on_timeout,json=onTimeout,proto3" json:"on_timeout,omitempty"`
	OnFailure            []string `protobuf:"bytes,7,rep,name=on_failure,json=onFailure,proto3" json:"on_failure,omitempty"`
	WorkerId             string   `protobuf:"bytes,8,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	Volumes              []string `protobuf:"bytes,9,rep,name=volumes,proto3" json:"volumes,omitempty"`
	Environment          []string `protobuf:"bytes,10,rep,name=environment,proto3" json:"environment,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WorkflowAction) Descriptor 

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

func (*WorkflowAction) GetCommand 

func (m *WorkflowAction) GetCommand() []string

func (*WorkflowAction) GetEnvironment 

func (m *WorkflowAction) GetEnvironment() []string

func (*WorkflowAction) GetImage 

func (m *WorkflowAction) GetImage() string

func (*WorkflowAction) GetName 

func (m *WorkflowAction) GetName() string

func (*WorkflowAction) GetOnFailure 

func (m *WorkflowAction) GetOnFailure() []string

func (*WorkflowAction) GetOnTimeout 

func (m *WorkflowAction) GetOnTimeout() []string

func (*WorkflowAction) GetTaskName 

func (m *WorkflowAction) GetTaskName() string

func (*WorkflowAction) GetTimeout 

func (m *WorkflowAction) GetTimeout() int64

func (*WorkflowAction) GetVolumes 

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

func (*WorkflowAction) GetWorkerId 

func (m *WorkflowAction) GetWorkerId() string

func (*WorkflowAction) ProtoMessage 

func (*WorkflowAction) ProtoMessage()

func (*WorkflowAction) Reset 

func (m *WorkflowAction) Reset()

func (*WorkflowAction) String 

func (m *WorkflowAction) String() string

func (*WorkflowAction) XXX_DiscardUnknown 

func (m *WorkflowAction) XXX_DiscardUnknown()

func (*WorkflowAction) XXX_Marshal 

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

func (*WorkflowAction) XXX_Merge 

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

func (*WorkflowAction) XXX_Size 

func (m *WorkflowAction) XXX_Size() int

func (*WorkflowAction) XXX_Unmarshal 

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

type WorkflowActionList 

type WorkflowActionList struct {
	ActionList           []*WorkflowAction `protobuf:"bytes,1,rep,name=action_list,json=actionList,proto3" json:"action_list,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*WorkflowActionList) Descriptor 

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

func (*WorkflowActionList) GetActionList 

func (m *WorkflowActionList) GetActionList() []*WorkflowAction

func (*WorkflowActionList) ProtoMessage 

func (*WorkflowActionList) ProtoMessage()

func (*WorkflowActionList) Reset 

func (m *WorkflowActionList) Reset()

func (*WorkflowActionList) String 

func (m *WorkflowActionList) String() string

func (*WorkflowActionList) XXX_DiscardUnknown 

func (m *WorkflowActionList) XXX_DiscardUnknown()

func (*WorkflowActionList) XXX_Marshal 

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

func (*WorkflowActionList) XXX_Merge 

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

func (*WorkflowActionList) XXX_Size 

func (m *WorkflowActionList) XXX_Size() int

func (*WorkflowActionList) XXX_Unmarshal 

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

type WorkflowActionStatus 

type WorkflowActionStatus struct {
	WorkflowId           string               `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	TaskName             string               `protobuf:"bytes,2,opt,name=task_name,json=taskName,proto3" json:"task_name,omitempty"`
	ActionName           string               `protobuf:"bytes,3,opt,name=action_name,json=actionName,proto3" json:"action_name,omitempty"`
	ActionStatus         ActionState          `` /* 164-byte string literal not displayed */
	Seconds              int64                `protobuf:"varint,5,opt,name=seconds,proto3" json:"seconds,omitempty"`
	Message              string               `protobuf:"bytes,6,opt,name=message,proto3" json:"message,omitempty"`
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,7,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
	WorkerId             string               `protobuf:"bytes,8,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*WorkflowActionStatus) Descriptor 

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

func (*WorkflowActionStatus) GetActionName 

func (m *WorkflowActionStatus) GetActionName() string

func (*WorkflowActionStatus) GetActionStatus 

func (m *WorkflowActionStatus) GetActionStatus() ActionState

func (*WorkflowActionStatus) GetCreatedAt 

func (m *WorkflowActionStatus) GetCreatedAt() *timestamp.Timestamp

func (*WorkflowActionStatus) GetMessage 

func (m *WorkflowActionStatus) GetMessage() string

func (*WorkflowActionStatus) GetSeconds 

func (m *WorkflowActionStatus) GetSeconds() int64

func (*WorkflowActionStatus) GetTaskName 

func (m *WorkflowActionStatus) GetTaskName() string

func (*WorkflowActionStatus) GetWorkerId 

func (m *WorkflowActionStatus) GetWorkerId() string

func (*WorkflowActionStatus) GetWorkflowId 

func (m *WorkflowActionStatus) GetWorkflowId() string

func (*WorkflowActionStatus) ProtoMessage 

func (*WorkflowActionStatus) ProtoMessage()

func (*WorkflowActionStatus) Reset 

func (m *WorkflowActionStatus) Reset()

func (*WorkflowActionStatus) String 

func (m *WorkflowActionStatus) String() string

func (*WorkflowActionStatus) XXX_DiscardUnknown 

func (m *WorkflowActionStatus) XXX_DiscardUnknown()

func (*WorkflowActionStatus) XXX_Marshal 

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

func (*WorkflowActionStatus) XXX_Merge 

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

func (*WorkflowActionStatus) XXX_Size 

func (m *WorkflowActionStatus) XXX_Size() int

func (*WorkflowActionStatus) XXX_Unmarshal 

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

type WorkflowActionsRequest 

type WorkflowActionsRequest struct {
	WorkflowId           string   `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WorkflowActionsRequest) Descriptor 

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

func (*WorkflowActionsRequest) GetWorkflowId 

func (m *WorkflowActionsRequest) GetWorkflowId() string

func (*WorkflowActionsRequest) ProtoMessage 

func (*WorkflowActionsRequest) ProtoMessage()

func (*WorkflowActionsRequest) Reset 

func (m *WorkflowActionsRequest) Reset()

func (*WorkflowActionsRequest) String 

func (m *WorkflowActionsRequest) String() string

func (*WorkflowActionsRequest) XXX_DiscardUnknown 

func (m *WorkflowActionsRequest) XXX_DiscardUnknown()

func (*WorkflowActionsRequest) XXX_Marshal 

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

func (*WorkflowActionsRequest) XXX_Merge 

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

func (*WorkflowActionsRequest) XXX_Size 

func (m *WorkflowActionsRequest) XXX_Size() int

func (*WorkflowActionsRequest) XXX_Unmarshal 

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

type WorkflowContext 

type WorkflowContext struct {
	WorkflowId           string      `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	CurrentWorker        string      `protobuf:"bytes,2,opt,name=current_worker,json=currentWorker,proto3" json:"current_worker,omitempty"`
	CurrentTask          string      `protobuf:"bytes,3,opt,name=current_task,json=currentTask,proto3" json:"current_task,omitempty"`
	CurrentAction        string      `protobuf:"bytes,4,opt,name=current_action,json=currentAction,proto3" json:"current_action,omitempty"`
	CurrentActionIndex   int64       `protobuf:"varint,5,opt,name=current_action_index,json=currentActionIndex,proto3" json:"current_action_index,omitempty"`
	CurrentActionState   ActionState `` /* 184-byte string literal not displayed */
	TotalNumberOfActions int64       `` /* 126-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*WorkflowContext) Descriptor 

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

func (*WorkflowContext) GetCurrentAction 

func (m *WorkflowContext) GetCurrentAction() string

func (*WorkflowContext) GetCurrentActionIndex 

func (m *WorkflowContext) GetCurrentActionIndex() int64

func (*WorkflowContext) GetCurrentActionState 

func (m *WorkflowContext) GetCurrentActionState() ActionState

func (*WorkflowContext) GetCurrentTask 

func (m *WorkflowContext) GetCurrentTask() string

func (*WorkflowContext) GetCurrentWorker 

func (m *WorkflowContext) GetCurrentWorker() string

func (*WorkflowContext) GetTotalNumberOfActions 

func (m *WorkflowContext) GetTotalNumberOfActions() int64

func (*WorkflowContext) GetWorkflowId 

func (m *WorkflowContext) GetWorkflowId() string

func (*WorkflowContext) ProtoMessage 

func (*WorkflowContext) ProtoMessage()

func (*WorkflowContext) Reset 

func (m *WorkflowContext) Reset()

func (*WorkflowContext) String 

func (m *WorkflowContext) String() string

func (*WorkflowContext) XXX_DiscardUnknown 

func (m *WorkflowContext) XXX_DiscardUnknown()

func (*WorkflowContext) XXX_Marshal 

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

func (*WorkflowContext) XXX_Merge 

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

func (*WorkflowContext) XXX_Size 

func (m *WorkflowContext) XXX_Size() int

func (*WorkflowContext) XXX_Unmarshal 

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

type WorkflowContextList 

type WorkflowContextList struct {
	WorkflowContexts     []*WorkflowContext `protobuf:"bytes,1,rep,name=workflow_contexts,json=workflowContexts,proto3" json:"workflow_contexts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*WorkflowContextList) Descriptor 

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

func (*WorkflowContextList) GetWorkflowContexts 

func (m *WorkflowContextList) GetWorkflowContexts() []*WorkflowContext

func (*WorkflowContextList) ProtoMessage 

func (*WorkflowContextList) ProtoMessage()

func (*WorkflowContextList) Reset 

func (m *WorkflowContextList) Reset()

func (*WorkflowContextList) String 

func (m *WorkflowContextList) String() string

func (*WorkflowContextList) XXX_DiscardUnknown 

func (m *WorkflowContextList) XXX_DiscardUnknown()

func (*WorkflowContextList) XXX_Marshal 

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

func (*WorkflowContextList) XXX_Merge 

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

func (*WorkflowContextList) XXX_Size 

func (m *WorkflowContextList) XXX_Size() int

func (*WorkflowContextList) XXX_Unmarshal 

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

type WorkflowContextRequest 

type WorkflowContextRequest struct {
	WorkerId             string   `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WorkflowContextRequest) Descriptor 

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

func (*WorkflowContextRequest) GetWorkerId 

func (m *WorkflowContextRequest) GetWorkerId() string

func (*WorkflowContextRequest) ProtoMessage 

func (*WorkflowContextRequest) ProtoMessage()

func (*WorkflowContextRequest) Reset 

func (m *WorkflowContextRequest) Reset()

func (*WorkflowContextRequest) String 

func (m *WorkflowContextRequest) String() string

func (*WorkflowContextRequest) XXX_DiscardUnknown 

func (m *WorkflowContextRequest) XXX_DiscardUnknown()

func (*WorkflowContextRequest) XXX_Marshal 

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

func (*WorkflowContextRequest) XXX_Merge 

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

func (*WorkflowContextRequest) XXX_Size 

func (m *WorkflowContextRequest) XXX_Size() int

func (*WorkflowContextRequest) XXX_Unmarshal 

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

type WorkflowSvcClient 

type WorkflowSvcClient interface {
	CreateWorkflow(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	GetWorkflow(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*Workflow, error)
	DeleteWorkflow(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*Empty, error)
	ListWorkflows(ctx context.Context, in *Empty, opts ...grpc.CallOption) (WorkflowSvc_ListWorkflowsClient, error)
	GetWorkflowContext(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*WorkflowContext, error)
	ShowWorkflowEvents(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (WorkflowSvc_ShowWorkflowEventsClient, error)
	GetWorkflowContexts(ctx context.Context, in *WorkflowContextRequest, opts ...grpc.CallOption) (*WorkflowContextList, error)
	GetWorkflowActions(ctx context.Context, in *WorkflowActionsRequest, opts ...grpc.CallOption) (*WorkflowActionList, error)
	ReportActionStatus(ctx context.Context, in *WorkflowActionStatus, opts ...grpc.CallOption) (*Empty, error)
	GetWorkflowData(ctx context.Context, in *GetWorkflowDataRequest, opts ...grpc.CallOption) (*GetWorkflowDataResponse, error)
	GetWorkflowMetadata(ctx context.Context, in *GetWorkflowDataRequest, opts ...grpc.CallOption) (*GetWorkflowDataResponse, error)
	GetWorkflowDataVersion(ctx context.Context, in *GetWorkflowDataRequest, opts ...grpc.CallOption) (*GetWorkflowDataResponse, error)
	UpdateWorkflowData(ctx context.Context, in *UpdateWorkflowDataRequest, opts ...grpc.CallOption) (*Empty, error)
}

WorkflowSvcClient is the client API for WorkflowSvc service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewWorkflowSvcClient 

func NewWorkflowSvcClient(cc *grpc.ClientConn) WorkflowSvcClient

type WorkflowSvcServer 

type WorkflowSvcServer interface {
	CreateWorkflow(context.Context, *CreateRequest) (*CreateResponse, error)
	GetWorkflow(context.Context, *GetRequest) (*Workflow, error)
	DeleteWorkflow(context.Context, *GetRequest) (*Empty, error)
	ListWorkflows(*Empty, WorkflowSvc_ListWorkflowsServer) error
	GetWorkflowContext(context.Context, *GetRequest) (*WorkflowContext, error)
	ShowWorkflowEvents(*GetRequest, WorkflowSvc_ShowWorkflowEventsServer) error
	GetWorkflowContexts(context.Context, *WorkflowContextRequest) (*WorkflowContextList, error)
	GetWorkflowActions(context.Context, *WorkflowActionsRequest) (*WorkflowActionList, error)
	ReportActionStatus(context.Context, *WorkflowActionStatus) (*Empty, error)
	GetWorkflowData(context.Context, *GetWorkflowDataRequest) (*GetWorkflowDataResponse, error)
	GetWorkflowMetadata(context.Context, *GetWorkflowDataRequest) (*GetWorkflowDataResponse, error)
	GetWorkflowDataVersion(context.Context, *GetWorkflowDataRequest) (*GetWorkflowDataResponse, error)
	UpdateWorkflowData(context.Context, *UpdateWorkflowDataRequest) (*Empty, error)
}

WorkflowSvcServer is the server API for WorkflowSvc service.

type WorkflowSvc_ListWorkflowsClient 

type WorkflowSvc_ListWorkflowsClient interface {
	Recv() (*Workflow, error)
	grpc.ClientStream
}

type WorkflowSvc_ListWorkflowsServer 

type WorkflowSvc_ListWorkflowsServer interface {
	Send(*Workflow) error
	grpc.ServerStream
}

type WorkflowSvc_ShowWorkflowEventsClient 

type WorkflowSvc_ShowWorkflowEventsClient interface {
	Recv() (*WorkflowActionStatus, error)
	grpc.ClientStream
}

type WorkflowSvc_ShowWorkflowEventsServer 

type WorkflowSvc_ShowWorkflowEventsServer interface {
	Send(*WorkflowActionStatus) error
	grpc.ServerStream
}

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.