workflow

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Aug 20, 2020 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Overview

Package workflow is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	State_name = map[int32]string{
		0: "PENDING",
		1: "RUNNING",
		2: "FAILED",
		3: "TIMEOUT",
		4: "SUCCESS",
	}
	State_value = map[string]int32{
		"PENDING": 0,
		"RUNNING": 1,
		"FAILED":  2,
		"TIMEOUT": 3,
		"SUCCESS": 4,
	}
)

Enum value maps for State.

View Source 
var (
	ActionState_name = map[int32]string{
		0: "ACTION_PENDING",
		1: "ACTION_IN_PROGRESS",
		2: "ACTION_SUCCESS",
		3: "ACTION_FAILED",
		4: "ACTION_TIMEOUT",
	}
	ActionState_value = map[string]int32{
		"ACTION_PENDING":     0,
		"ACTION_IN_PROGRESS": 1,
		"ACTION_SUCCESS":     2,
		"ACTION_FAILED":      3,
		"ACTION_TIMEOUT":     4,
	}
)

Enum value maps for ActionState.

View Source 
var File_workflow_workflow_proto protoreflect.FileDescriptor

Functions

func RegisterWorkflowSvcHandler 

func RegisterWorkflowSvcHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterWorkflowSvcHandler registers the http handlers for service WorkflowSvc to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterWorkflowSvcHandlerClient 

func RegisterWorkflowSvcHandlerClient(ctx context.Context, mux *runtime.ServeMux, client WorkflowSvcClient) error

RegisterWorkflowSvcHandlerClient registers the http handlers for service WorkflowSvc to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "WorkflowSvcClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "WorkflowSvcClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "WorkflowSvcClient" to call the correct interceptors.

func RegisterWorkflowSvcHandlerFromEndpoint 

func RegisterWorkflowSvcHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterWorkflowSvcHandlerFromEndpoint is same as RegisterWorkflowSvcHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterWorkflowSvcHandlerServer 

func RegisterWorkflowSvcHandlerServer(ctx context.Context, mux *runtime.ServeMux, server WorkflowSvcServer) error

RegisterWorkflowSvcHandlerServer registers the http handlers for service WorkflowSvc to "mux". UnaryRPC :call WorkflowSvcServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

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) Descriptor 

func (ActionState) Descriptor() protoreflect.EnumDescriptor

func (ActionState) Enum 

func (x ActionState) Enum() *ActionState

func (ActionState) EnumDescriptor deprecated 

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

Deprecated: Use ActionState.Descriptor instead.

func (ActionState) Number 

func (x ActionState) Number() protoreflect.EnumNumber

func (ActionState) String 

func (x ActionState) String() string

func (ActionState) Type 

func (ActionState) Type() protoreflect.EnumType

type CreateRequest 

type CreateRequest struct {
	Template string `protobuf:"bytes,1,opt,name=template,proto3" json:"template,omitempty"`
	Hardware string `protobuf:"bytes,2,opt,name=hardware,proto3" json:"hardware,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateRequest) Descriptor deprecated 

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

Deprecated: Use CreateRequest.ProtoReflect.Descriptor instead.

func (*CreateRequest) GetHardware 

func (x *CreateRequest) GetHardware() string

func (*CreateRequest) GetTemplate 

func (x *CreateRequest) GetTemplate() string

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) ProtoReflect 

func (x *CreateRequest) ProtoReflect() protoreflect.Message

func (*CreateRequest) Reset 

func (x *CreateRequest) Reset()

func (*CreateRequest) String 

func (x *CreateRequest) String() string

type CreateResponse 

type CreateResponse struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateResponse) Descriptor deprecated 

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

Deprecated: Use CreateResponse.ProtoReflect.Descriptor instead.

func (*CreateResponse) GetId 

func (x *CreateResponse) GetId() string

func (*CreateResponse) ProtoMessage 

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) ProtoReflect 

func (x *CreateResponse) ProtoReflect() protoreflect.Message

func (*CreateResponse) Reset 

func (x *CreateResponse) Reset()

func (*CreateResponse) String 

func (x *CreateResponse) String() string

type Empty 

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

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

func (x *Empty) ProtoReflect() protoreflect.Message

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type GetRequest 

type GetRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRequest) Descriptor deprecated 

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetId 

func (x *GetRequest) GetId() string

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

func (x *GetRequest) ProtoReflect() protoreflect.Message

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) String 

func (x *GetRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*GetWorkflowDataRequest) Descriptor deprecated 

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

Deprecated: Use GetWorkflowDataRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowDataRequest) GetVersion 

func (x *GetWorkflowDataRequest) GetVersion() int32

func (*GetWorkflowDataRequest) GetWorkflowID 

func (x *GetWorkflowDataRequest) GetWorkflowID() string

func (*GetWorkflowDataRequest) ProtoMessage 

func (*GetWorkflowDataRequest) ProtoMessage()

func (*GetWorkflowDataRequest) ProtoReflect 

func (x *GetWorkflowDataRequest) ProtoReflect() protoreflect.Message

func (*GetWorkflowDataRequest) Reset 

func (x *GetWorkflowDataRequest) Reset()

func (*GetWorkflowDataRequest) String 

func (x *GetWorkflowDataRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*GetWorkflowDataResponse) Descriptor deprecated 

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

Deprecated: Use GetWorkflowDataResponse.ProtoReflect.Descriptor instead.

func (*GetWorkflowDataResponse) GetData 

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

func (*GetWorkflowDataResponse) GetVersion 

func (x *GetWorkflowDataResponse) GetVersion() int32

func (*GetWorkflowDataResponse) ProtoMessage 

func (*GetWorkflowDataResponse) ProtoMessage()

func (*GetWorkflowDataResponse) ProtoReflect 

func (x *GetWorkflowDataResponse) ProtoReflect() protoreflect.Message

func (*GetWorkflowDataResponse) Reset 

func (x *GetWorkflowDataResponse) Reset()

func (*GetWorkflowDataResponse) String 

func (x *GetWorkflowDataResponse) String() string

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) Descriptor 

func (State) Descriptor() protoreflect.EnumDescriptor

func (State) Enum 

func (x State) Enum() *State

func (State) EnumDescriptor deprecated 

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

Deprecated: Use State.Descriptor instead.

func (State) Number 

func (x State) Number() protoreflect.EnumNumber

func (State) String 

func (x State) String() string

func (State) Type 

func (State) Type() protoreflect.EnumType

type UnimplementedWorkflowSvcServer 

type UnimplementedWorkflowSvcServer struct {
}

UnimplementedWorkflowSvcServer can be embedded to have forward compatible implementations.

func (*UnimplementedWorkflowSvcServer) CreateWorkflow 

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

func (*UnimplementedWorkflowSvcServer) DeleteWorkflow 

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

func (*UnimplementedWorkflowSvcServer) GetWorkflow 

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

func (*UnimplementedWorkflowSvcServer) GetWorkflowActions 

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

func (*UnimplementedWorkflowSvcServer) GetWorkflowContext 

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

func (*UnimplementedWorkflowSvcServer) GetWorkflowContextList 

func (*UnimplementedWorkflowSvcServer) GetWorkflowContextList(context.Context, *WorkflowContextRequest) (*WorkflowContextList, error)

func (*UnimplementedWorkflowSvcServer) GetWorkflowContexts 

func (*UnimplementedWorkflowSvcServer) GetWorkflowContexts(*WorkflowContextRequest, WorkflowSvc_GetWorkflowContextsServer) error

func (*UnimplementedWorkflowSvcServer) GetWorkflowData 

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

func (*UnimplementedWorkflowSvcServer) GetWorkflowDataVersion 

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

func (*UnimplementedWorkflowSvcServer) GetWorkflowMetadata 

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

func (*UnimplementedWorkflowSvcServer) ListWorkflows 

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

func (*UnimplementedWorkflowSvcServer) ReportActionStatus 

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

func (*UnimplementedWorkflowSvcServer) ShowWorkflowEvents 

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

func (*UnimplementedWorkflowSvcServer) UpdateWorkflowData 

func (*UnimplementedWorkflowSvcServer) UpdateWorkflowData(context.Context, *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"`
	// contains filtered or unexported fields
}

func (*UpdateWorkflowDataRequest) Descriptor deprecated 

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

Deprecated: Use UpdateWorkflowDataRequest.ProtoReflect.Descriptor instead.

func (*UpdateWorkflowDataRequest) GetData 

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

func (*UpdateWorkflowDataRequest) GetMetadata 

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

func (*UpdateWorkflowDataRequest) GetWorkflowID 

func (x *UpdateWorkflowDataRequest) GetWorkflowID() string

func (*UpdateWorkflowDataRequest) ProtoMessage 

func (*UpdateWorkflowDataRequest) ProtoMessage()

func (*UpdateWorkflowDataRequest) ProtoReflect 

func (x *UpdateWorkflowDataRequest) ProtoReflect() protoreflect.Message

func (*UpdateWorkflowDataRequest) Reset 

func (x *UpdateWorkflowDataRequest) Reset()

func (*UpdateWorkflowDataRequest) String 

func (x *UpdateWorkflowDataRequest) String() string

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"`
	Hardware  string               `protobuf:"bytes,3,opt,name=hardware,proto3" json:"hardware,omitempty"`
	State     State                `protobuf:"varint,4,opt,name=state,proto3,enum=github.com.tinkerbell.tink.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"`
	// contains filtered or unexported fields
}

func (*Workflow) Descriptor deprecated 

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

Deprecated: Use Workflow.ProtoReflect.Descriptor instead.

func (*Workflow) GetCreatedAt 

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

func (*Workflow) GetData 

func (x *Workflow) GetData() string

func (*Workflow) GetDeletedAt 

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

func (*Workflow) GetHardware 

func (x *Workflow) GetHardware() string

func (*Workflow) GetId 

func (x *Workflow) GetId() string

func (*Workflow) GetState 

func (x *Workflow) GetState() State

func (*Workflow) GetTemplate 

func (x *Workflow) GetTemplate() string

func (*Workflow) GetUpdatedAt 

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

func (*Workflow) ProtoMessage 

func (*Workflow) ProtoMessage()

func (*Workflow) ProtoReflect 

func (x *Workflow) ProtoReflect() protoreflect.Message

func (*Workflow) Reset 

func (x *Workflow) Reset()

func (*Workflow) String 

func (x *Workflow) String() string

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"`
	// contains filtered or unexported fields
}

func (*WorkflowAction) Descriptor deprecated 

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

Deprecated: Use WorkflowAction.ProtoReflect.Descriptor instead.

func (*WorkflowAction) GetCommand 

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

func (*WorkflowAction) GetEnvironment 

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

func (*WorkflowAction) GetImage 

func (x *WorkflowAction) GetImage() string

func (*WorkflowAction) GetName 

func (x *WorkflowAction) GetName() string

func (*WorkflowAction) GetOnFailure 

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

func (*WorkflowAction) GetOnTimeout 

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

func (*WorkflowAction) GetTaskName 

func (x *WorkflowAction) GetTaskName() string

func (*WorkflowAction) GetTimeout 

func (x *WorkflowAction) GetTimeout() int64

func (*WorkflowAction) GetVolumes 

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

func (*WorkflowAction) GetWorkerId 

func (x *WorkflowAction) GetWorkerId() string

func (*WorkflowAction) ProtoMessage 

func (*WorkflowAction) ProtoMessage()

func (*WorkflowAction) ProtoReflect 

func (x *WorkflowAction) ProtoReflect() protoreflect.Message

func (*WorkflowAction) Reset 

func (x *WorkflowAction) Reset()

func (*WorkflowAction) String 

func (x *WorkflowAction) String() string

type WorkflowActionList 

type WorkflowActionList struct {
	ActionList []*WorkflowAction `protobuf:"bytes,1,rep,name=action_list,json=actionList,proto3" json:"action_list,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowActionList) Descriptor deprecated 

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

Deprecated: Use WorkflowActionList.ProtoReflect.Descriptor instead.

func (*WorkflowActionList) GetActionList 

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

func (*WorkflowActionList) ProtoMessage 

func (*WorkflowActionList) ProtoMessage()

func (*WorkflowActionList) ProtoReflect 

func (x *WorkflowActionList) ProtoReflect() protoreflect.Message

func (*WorkflowActionList) Reset 

func (x *WorkflowActionList) Reset()

func (*WorkflowActionList) String 

func (x *WorkflowActionList) String() string

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          `` /* 158-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"`
	// contains filtered or unexported fields
}

func (*WorkflowActionStatus) Descriptor deprecated 

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

Deprecated: Use WorkflowActionStatus.ProtoReflect.Descriptor instead.

func (*WorkflowActionStatus) GetActionName 

func (x *WorkflowActionStatus) GetActionName() string

func (*WorkflowActionStatus) GetActionStatus 

func (x *WorkflowActionStatus) GetActionStatus() ActionState

func (*WorkflowActionStatus) GetCreatedAt 

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

func (*WorkflowActionStatus) GetMessage 

func (x *WorkflowActionStatus) GetMessage() string

func (*WorkflowActionStatus) GetSeconds 

func (x *WorkflowActionStatus) GetSeconds() int64

func (*WorkflowActionStatus) GetTaskName 

func (x *WorkflowActionStatus) GetTaskName() string

func (*WorkflowActionStatus) GetWorkerId 

func (x *WorkflowActionStatus) GetWorkerId() string

func (*WorkflowActionStatus) GetWorkflowId 

func (x *WorkflowActionStatus) GetWorkflowId() string

func (*WorkflowActionStatus) ProtoMessage 

func (*WorkflowActionStatus) ProtoMessage()

func (*WorkflowActionStatus) ProtoReflect 

func (x *WorkflowActionStatus) ProtoReflect() protoreflect.Message

func (*WorkflowActionStatus) Reset 

func (x *WorkflowActionStatus) Reset()

func (*WorkflowActionStatus) String 

func (x *WorkflowActionStatus) String() string

type WorkflowActionsRequest 

type WorkflowActionsRequest struct {
	WorkflowId string `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowActionsRequest) Descriptor deprecated 

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

Deprecated: Use WorkflowActionsRequest.ProtoReflect.Descriptor instead.

func (*WorkflowActionsRequest) GetWorkflowId 

func (x *WorkflowActionsRequest) GetWorkflowId() string

func (*WorkflowActionsRequest) ProtoMessage 

func (*WorkflowActionsRequest) ProtoMessage()

func (*WorkflowActionsRequest) ProtoReflect 

func (x *WorkflowActionsRequest) ProtoReflect() protoreflect.Message

func (*WorkflowActionsRequest) Reset 

func (x *WorkflowActionsRequest) Reset()

func (*WorkflowActionsRequest) String 

func (x *WorkflowActionsRequest) String() string

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 `` /* 178-byte string literal not displayed */
	TotalNumberOfActions int64       `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*WorkflowContext) Descriptor deprecated 

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

Deprecated: Use WorkflowContext.ProtoReflect.Descriptor instead.

func (*WorkflowContext) GetCurrentAction 

func (x *WorkflowContext) GetCurrentAction() string

func (*WorkflowContext) GetCurrentActionIndex 

func (x *WorkflowContext) GetCurrentActionIndex() int64

func (*WorkflowContext) GetCurrentActionState 

func (x *WorkflowContext) GetCurrentActionState() ActionState

func (*WorkflowContext) GetCurrentTask 

func (x *WorkflowContext) GetCurrentTask() string

func (*WorkflowContext) GetCurrentWorker 

func (x *WorkflowContext) GetCurrentWorker() string

func (*WorkflowContext) GetTotalNumberOfActions 

func (x *WorkflowContext) GetTotalNumberOfActions() int64

func (*WorkflowContext) GetWorkflowId 

func (x *WorkflowContext) GetWorkflowId() string

func (*WorkflowContext) ProtoMessage 

func (*WorkflowContext) ProtoMessage()

func (*WorkflowContext) ProtoReflect 

func (x *WorkflowContext) ProtoReflect() protoreflect.Message

func (*WorkflowContext) Reset 

func (x *WorkflowContext) Reset()

func (*WorkflowContext) String 

func (x *WorkflowContext) String() string

type WorkflowContextList 

type WorkflowContextList struct {
	WorkflowContexts []*WorkflowContext `protobuf:"bytes,1,rep,name=workflow_contexts,json=workflowContexts,proto3" json:"workflow_contexts,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowContextList) Descriptor deprecated 

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

Deprecated: Use WorkflowContextList.ProtoReflect.Descriptor instead.

func (*WorkflowContextList) GetWorkflowContexts 

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

func (*WorkflowContextList) ProtoMessage 

func (*WorkflowContextList) ProtoMessage()

func (*WorkflowContextList) ProtoReflect 

func (x *WorkflowContextList) ProtoReflect() protoreflect.Message

func (*WorkflowContextList) Reset 

func (x *WorkflowContextList) Reset()

func (*WorkflowContextList) String 

func (x *WorkflowContextList) String() string

type WorkflowContextRequest 

type WorkflowContextRequest struct {
	WorkerId string `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowContextRequest) Descriptor deprecated 

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

Deprecated: Use WorkflowContextRequest.ProtoReflect.Descriptor instead.

func (*WorkflowContextRequest) GetWorkerId 

func (x *WorkflowContextRequest) GetWorkerId() string

func (*WorkflowContextRequest) ProtoMessage 

func (*WorkflowContextRequest) ProtoMessage()

func (*WorkflowContextRequest) ProtoReflect 

func (x *WorkflowContextRequest) ProtoReflect() protoreflect.Message

func (*WorkflowContextRequest) Reset 

func (x *WorkflowContextRequest) Reset()

func (*WorkflowContextRequest) String 

func (x *WorkflowContextRequest) String() string

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)
	GetWorkflowContextList(ctx context.Context, in *WorkflowContextRequest, opts ...grpc.CallOption) (*WorkflowContextList, error)
	GetWorkflowContexts(ctx context.Context, in *WorkflowContextRequest, opts ...grpc.CallOption) (WorkflowSvc_GetWorkflowContextsClient, 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.ClientConnInterface) 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
	GetWorkflowContextList(context.Context, *WorkflowContextRequest) (*WorkflowContextList, error)
	GetWorkflowContexts(*WorkflowContextRequest, WorkflowSvc_GetWorkflowContextsServer) 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_GetWorkflowContextsClient 

type WorkflowSvc_GetWorkflowContextsClient interface {
	Recv() (*WorkflowContext, error)
	grpc.ClientStream
}

type WorkflowSvc_GetWorkflowContextsServer 

type WorkflowSvc_GetWorkflowContextsServer interface {
	Send(*WorkflowContext) error
	grpc.ServerStream
}

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.