workflow

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Jan 4, 2021 License: Apache-2.0 Imports: 18 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: "STATE_PENDING",
		1: "STATE_RUNNING",
		2: "STATE_FAILED",
		3: "STATE_TIMEOUT",
		4: "STATE_SUCCESS",
	}
	State_value = map[string]int32{
		"STATE_PENDING": 0,
		"STATE_RUNNING": 1,
		"STATE_FAILED":  2,
		"STATE_TIMEOUT": 3,
		"STATE_SUCCESS": 4,
	}
)

Enum value maps for State.

View Source 
var File_workflow_workflow_proto protoreflect.FileDescriptor

Functions

func RegisterWorkflowServiceHandler added in v0.2.0 

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

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

func RegisterWorkflowServiceHandlerClient added in v0.2.0 

func RegisterWorkflowServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client WorkflowServiceClient) error

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

func RegisterWorkflowServiceHandlerFromEndpoint added in v0.2.0 

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

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

func RegisterWorkflowServiceHandlerServer added in v0.2.0 

func RegisterWorkflowServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server WorkflowServiceServer) error

RegisterWorkflowServiceHandlerServer registers the http handlers for service WorkflowService to "mux". UnaryRPC :call WorkflowServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterWorkflowServiceHandlerFromEndpoint instead.

func RegisterWorkflowServiceServer added in v0.2.0 

func RegisterWorkflowServiceServer(s *grpc.Server, srv WorkflowServiceServer)

Types

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

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_STATE_PENDING State = 0
	State_STATE_RUNNING State = 1
	State_STATE_FAILED  State = 2
	State_STATE_TIMEOUT State = 3
	State_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 UnimplementedWorkflowServiceServer added in v0.2.0 

type UnimplementedWorkflowServiceServer struct {
}

UnimplementedWorkflowServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedWorkflowServiceServer) CreateWorkflow added in v0.2.0 

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

func (*UnimplementedWorkflowServiceServer) DeleteWorkflow added in v0.2.0 

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

func (*UnimplementedWorkflowServiceServer) GetWorkflow added in v0.2.0 

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

func (*UnimplementedWorkflowServiceServer) GetWorkflowActions added in v0.2.0 

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

func (*UnimplementedWorkflowServiceServer) GetWorkflowContext added in v0.2.0 

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

func (*UnimplementedWorkflowServiceServer) GetWorkflowContextList added in v0.2.0 

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

func (*UnimplementedWorkflowServiceServer) GetWorkflowContexts added in v0.2.0 

func (*UnimplementedWorkflowServiceServer) GetWorkflowContexts(*WorkflowContextRequest, WorkflowService_GetWorkflowContextsServer) error

func (*UnimplementedWorkflowServiceServer) GetWorkflowData added in v0.2.0 

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

func (*UnimplementedWorkflowServiceServer) GetWorkflowDataVersion added in v0.2.0 

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

func (*UnimplementedWorkflowServiceServer) GetWorkflowMetadata added in v0.2.0 

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

func (*UnimplementedWorkflowServiceServer) ListWorkflows added in v0.2.0 

func (*UnimplementedWorkflowServiceServer) ListWorkflows(*Empty, WorkflowService_ListWorkflowsServer) error

func (*UnimplementedWorkflowServiceServer) ReportActionStatus added in v0.2.0 

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

func (*UnimplementedWorkflowServiceServer) ShowWorkflowEvents added in v0.2.0 

func (*UnimplementedWorkflowServiceServer) ShowWorkflowEvents(*GetRequest, WorkflowService_ShowWorkflowEventsServer) error

func (*UnimplementedWorkflowServiceServer) UpdateWorkflowData added in v0.2.0 

func (*UnimplementedWorkflowServiceServer) 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 added in v0.2.0 

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 *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	DeletedAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=deleted_at,json=deletedAt,proto3" json:"deleted_at,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() *timestamppb.Timestamp

func (*Workflow) GetData 

func (x *Workflow) GetData() string

func (*Workflow) GetDeletedAt 

func (x *Workflow) GetDeletedAt() *timestamppb.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() *timestamppb.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 State                  `` /* 152-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    *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,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() State

func (*WorkflowActionStatus) GetCreatedAt 

func (x *WorkflowActionStatus) GetCreatedAt() *timestamppb.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   State  `` /* 172-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() State

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 WorkflowServiceClient added in v0.2.0 

type WorkflowServiceClient 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) (WorkflowService_ListWorkflowsClient, error)
	GetWorkflowContext(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*WorkflowContext, error)
	ShowWorkflowEvents(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (WorkflowService_ShowWorkflowEventsClient, error)
	GetWorkflowContextList(ctx context.Context, in *WorkflowContextRequest, opts ...grpc.CallOption) (*WorkflowContextList, error)
	GetWorkflowContexts(ctx context.Context, in *WorkflowContextRequest, opts ...grpc.CallOption) (WorkflowService_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)
}

WorkflowServiceClient is the client API for WorkflowService service.

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

func NewWorkflowServiceClient added in v0.2.0 

func NewWorkflowServiceClient(cc grpc.ClientConnInterface) WorkflowServiceClient

type WorkflowServiceServer added in v0.2.0 

type WorkflowServiceServer interface {
	CreateWorkflow(context.Context, *CreateRequest) (*CreateResponse, error)
	GetWorkflow(context.Context, *GetRequest) (*Workflow, error)
	DeleteWorkflow(context.Context, *GetRequest) (*Empty, error)
	ListWorkflows(*Empty, WorkflowService_ListWorkflowsServer) error
	GetWorkflowContext(context.Context, *GetRequest) (*WorkflowContext, error)
	ShowWorkflowEvents(*GetRequest, WorkflowService_ShowWorkflowEventsServer) error
	GetWorkflowContextList(context.Context, *WorkflowContextRequest) (*WorkflowContextList, error)
	GetWorkflowContexts(*WorkflowContextRequest, WorkflowService_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)
}

WorkflowServiceServer is the server API for WorkflowService service.

type WorkflowService_GetWorkflowContextsClient added in v0.2.0 

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

type WorkflowService_GetWorkflowContextsServer added in v0.2.0 

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

type WorkflowService_ListWorkflowsClient added in v0.2.0 

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

type WorkflowService_ListWorkflowsServer added in v0.2.0 

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

type WorkflowService_ShowWorkflowEventsClient added in v0.2.0 

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

type WorkflowService_ShowWorkflowEventsServer added in v0.2.0 

type WorkflowService_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.