workflow

package
v0.12.1 Latest Latest
Warning

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

 Go to latest Published: Oct 23, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_internal_proto_workflow_v2_workflow_proto protoreflect.FileDescriptor
View Source 
var WorkflowService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "internal.proto.workflow.v2.WorkflowService",
	HandlerType: (*WorkflowServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PublishEvent",
			Handler:    _WorkflowService_PublishEvent_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetWorkflows",
			Handler:       _WorkflowService_GetWorkflows_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "internal/proto/workflow/v2/workflow.proto",
}

WorkflowService_ServiceDesc is the grpc.ServiceDesc for WorkflowService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterWorkflowServiceServer 

func RegisterWorkflowServiceServer(s grpc.ServiceRegistrar, srv WorkflowServiceServer)

Types

type Event 

type Event struct {

	// A unique identifier for a workflow.
	WorkflowId string `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	// Types that are assignable to Event:
	//
	//	*Event_ActionStarted_
	//	*Event_ActionSucceeded_
	//	*Event_ActionFailed_
	//	*Event_WorkflowRejected_
	Event isEvent_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetActionFailed 

func (x *Event) GetActionFailed() *Event_ActionFailed

func (*Event) GetActionStarted 

func (x *Event) GetActionStarted() *Event_ActionStarted

func (*Event) GetActionSucceeded 

func (x *Event) GetActionSucceeded() *Event_ActionSucceeded

func (*Event) GetEvent 

func (m *Event) GetEvent() isEvent_Event

func (*Event) GetWorkflowId 

func (x *Event) GetWorkflowId() string

func (*Event) GetWorkflowRejected 

func (x *Event) GetWorkflowRejected() *Event_WorkflowRejected

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

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

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type Event_ActionFailed 

type Event_ActionFailed struct {

	// A unique identifier for an action in the context of a workflow.
	ActionId string `protobuf:"bytes,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	// A UpperCamelCase word or phrase concisly describing why an action failed. It is typically
	// provided by the action itself.
	FailureReason *string `protobuf:"bytes,2,opt,name=failure_reason,json=failureReason,proto3,oneof" json:"failure_reason,omitempty"`
	// A free-form human readable string elaborating on the reason for failure. It is typically
	// provided by the action itself.
	FailureMessage *string `protobuf:"bytes,3,opt,name=failure_message,json=failureMessage,proto3,oneof" json:"failure_message,omitempty"`
	// contains filtered or unexported fields
}

func (*Event_ActionFailed) Descriptor deprecated 

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

Deprecated: Use Event_ActionFailed.ProtoReflect.Descriptor instead.

func (*Event_ActionFailed) GetActionId 

func (x *Event_ActionFailed) GetActionId() string

func (*Event_ActionFailed) GetFailureMessage 

func (x *Event_ActionFailed) GetFailureMessage() string

func (*Event_ActionFailed) GetFailureReason 

func (x *Event_ActionFailed) GetFailureReason() string

func (*Event_ActionFailed) ProtoMessage 

func (*Event_ActionFailed) ProtoMessage()

func (*Event_ActionFailed) ProtoReflect 

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

func (*Event_ActionFailed) Reset 

func (x *Event_ActionFailed) Reset()

func (*Event_ActionFailed) String 

func (x *Event_ActionFailed) String() string

type Event_ActionFailed_ 

type Event_ActionFailed_ struct {
	ActionFailed *Event_ActionFailed `protobuf:"bytes,4,opt,name=action_failed,json=actionFailed,proto3,oneof"`
}

type Event_ActionStarted 

type Event_ActionStarted struct {

	// A unique identifier for an action in the context of a workflow.
	ActionId string `protobuf:"bytes,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	// contains filtered or unexported fields
}

func (*Event_ActionStarted) Descriptor deprecated 

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

Deprecated: Use Event_ActionStarted.ProtoReflect.Descriptor instead.

func (*Event_ActionStarted) GetActionId 

func (x *Event_ActionStarted) GetActionId() string

func (*Event_ActionStarted) ProtoMessage 

func (*Event_ActionStarted) ProtoMessage()

func (*Event_ActionStarted) ProtoReflect 

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

func (*Event_ActionStarted) Reset 

func (x *Event_ActionStarted) Reset()

func (*Event_ActionStarted) String 

func (x *Event_ActionStarted) String() string

type Event_ActionStarted_ 

type Event_ActionStarted_ struct {
	ActionStarted *Event_ActionStarted `protobuf:"bytes,2,opt,name=action_started,json=actionStarted,proto3,oneof"`
}

type Event_ActionSucceeded 

type Event_ActionSucceeded struct {

	// A unique identifier for an action in the context of a workflow.
	ActionId string `protobuf:"bytes,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	// contains filtered or unexported fields
}

func (*Event_ActionSucceeded) Descriptor deprecated 

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

Deprecated: Use Event_ActionSucceeded.ProtoReflect.Descriptor instead.

func (*Event_ActionSucceeded) GetActionId 

func (x *Event_ActionSucceeded) GetActionId() string

func (*Event_ActionSucceeded) ProtoMessage 

func (*Event_ActionSucceeded) ProtoMessage()

func (*Event_ActionSucceeded) ProtoReflect 

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

func (*Event_ActionSucceeded) Reset 

func (x *Event_ActionSucceeded) Reset()

func (*Event_ActionSucceeded) String 

func (x *Event_ActionSucceeded) String() string

type Event_ActionSucceeded_ 

type Event_ActionSucceeded_ struct {
	ActionSucceeded *Event_ActionSucceeded `protobuf:"bytes,3,opt,name=action_succeeded,json=actionSucceeded,proto3,oneof"`
}

type Event_WorkflowRejected 

type Event_WorkflowRejected struct {

	// A message describing why the workflow was rejected.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Event_WorkflowRejected) Descriptor deprecated 

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

Deprecated: Use Event_WorkflowRejected.ProtoReflect.Descriptor instead.

func (*Event_WorkflowRejected) GetMessage 

func (x *Event_WorkflowRejected) GetMessage() string

func (*Event_WorkflowRejected) ProtoMessage 

func (*Event_WorkflowRejected) ProtoMessage()

func (*Event_WorkflowRejected) ProtoReflect 

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

func (*Event_WorkflowRejected) Reset 

func (x *Event_WorkflowRejected) Reset()

func (*Event_WorkflowRejected) String 

func (x *Event_WorkflowRejected) String() string

type Event_WorkflowRejected_ 

type Event_WorkflowRejected_ struct {
	WorkflowRejected *Event_WorkflowRejected `protobuf:"bytes,5,opt,name=workflow_rejected,json=workflowRejected,proto3,oneof"`
}

type GetWorkflowsRequest 

type GetWorkflowsRequest struct {
	AgentId string `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowsRequest) Descriptor deprecated 

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

Deprecated: Use GetWorkflowsRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowsRequest) GetAgentId 

func (x *GetWorkflowsRequest) GetAgentId() string

func (*GetWorkflowsRequest) ProtoMessage 

func (*GetWorkflowsRequest) ProtoMessage()

func (*GetWorkflowsRequest) ProtoReflect 

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

func (*GetWorkflowsRequest) Reset 

func (x *GetWorkflowsRequest) Reset()

func (*GetWorkflowsRequest) String 

func (x *GetWorkflowsRequest) String() string

type GetWorkflowsResponse 

type GetWorkflowsResponse struct {

	// Types that are assignable to Cmd:
	//
	//	*GetWorkflowsResponse_StartWorkflow_
	//	*GetWorkflowsResponse_StopWorkflow_
	Cmd isGetWorkflowsResponse_Cmd `protobuf_oneof:"cmd"`
	// contains filtered or unexported fields
}

func (*GetWorkflowsResponse) Descriptor deprecated 

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

Deprecated: Use GetWorkflowsResponse.ProtoReflect.Descriptor instead.

func (*GetWorkflowsResponse) GetCmd 

func (m *GetWorkflowsResponse) GetCmd() isGetWorkflowsResponse_Cmd

func (*GetWorkflowsResponse) GetStartWorkflow 

func (x *GetWorkflowsResponse) GetStartWorkflow() *GetWorkflowsResponse_StartWorkflow

func (*GetWorkflowsResponse) GetStopWorkflow 

func (x *GetWorkflowsResponse) GetStopWorkflow() *GetWorkflowsResponse_StopWorkflow

func (*GetWorkflowsResponse) ProtoMessage 

func (*GetWorkflowsResponse) ProtoMessage()

func (*GetWorkflowsResponse) ProtoReflect 

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

func (*GetWorkflowsResponse) Reset 

func (x *GetWorkflowsResponse) Reset()

func (*GetWorkflowsResponse) String 

func (x *GetWorkflowsResponse) String() string

type GetWorkflowsResponse_StartWorkflow 

type GetWorkflowsResponse_StartWorkflow struct {
	Workflow *Workflow `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowsResponse_StartWorkflow) Descriptor deprecated 

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

Deprecated: Use GetWorkflowsResponse_StartWorkflow.ProtoReflect.Descriptor instead.

func (*GetWorkflowsResponse_StartWorkflow) GetWorkflow 

func (x *GetWorkflowsResponse_StartWorkflow) GetWorkflow() *Workflow

func (*GetWorkflowsResponse_StartWorkflow) ProtoMessage 

func (*GetWorkflowsResponse_StartWorkflow) ProtoMessage()

func (*GetWorkflowsResponse_StartWorkflow) ProtoReflect 

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

func (*GetWorkflowsResponse_StartWorkflow) Reset 

func (x *GetWorkflowsResponse_StartWorkflow) Reset()

func (*GetWorkflowsResponse_StartWorkflow) String 

func (x *GetWorkflowsResponse_StartWorkflow) String() string

type GetWorkflowsResponse_StartWorkflow_ 

type GetWorkflowsResponse_StartWorkflow_ struct {
	StartWorkflow *GetWorkflowsResponse_StartWorkflow `protobuf:"bytes,1,opt,name=start_workflow,json=startWorkflow,proto3,oneof"`
}

type GetWorkflowsResponse_StopWorkflow 

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

func (*GetWorkflowsResponse_StopWorkflow) Descriptor deprecated 

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

Deprecated: Use GetWorkflowsResponse_StopWorkflow.ProtoReflect.Descriptor instead.

func (*GetWorkflowsResponse_StopWorkflow) GetWorkflowId 

func (x *GetWorkflowsResponse_StopWorkflow) GetWorkflowId() string

func (*GetWorkflowsResponse_StopWorkflow) ProtoMessage 

func (*GetWorkflowsResponse_StopWorkflow) ProtoMessage()

func (*GetWorkflowsResponse_StopWorkflow) ProtoReflect 

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

func (*GetWorkflowsResponse_StopWorkflow) Reset 

func (x *GetWorkflowsResponse_StopWorkflow) Reset()

func (*GetWorkflowsResponse_StopWorkflow) String 

func (x *GetWorkflowsResponse_StopWorkflow) String() string

type GetWorkflowsResponse_StopWorkflow_ 

type GetWorkflowsResponse_StopWorkflow_ struct {
	StopWorkflow *GetWorkflowsResponse_StopWorkflow `protobuf:"bytes,2,opt,name=stop_workflow,json=stopWorkflow,proto3,oneof"`
}

type PublishEventRequest 

type PublishEventRequest struct {
	Event *Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishEventRequest) Descriptor deprecated 

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

Deprecated: Use PublishEventRequest.ProtoReflect.Descriptor instead.

func (*PublishEventRequest) GetEvent 

func (x *PublishEventRequest) GetEvent() *Event

func (*PublishEventRequest) ProtoMessage 

func (*PublishEventRequest) ProtoMessage()

func (*PublishEventRequest) ProtoReflect 

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

func (*PublishEventRequest) Reset 

func (x *PublishEventRequest) Reset()

func (*PublishEventRequest) String 

func (x *PublishEventRequest) String() string

type PublishEventResponse 

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

func (*PublishEventResponse) Descriptor deprecated 

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

Deprecated: Use PublishEventResponse.ProtoReflect.Descriptor instead.

func (*PublishEventResponse) ProtoMessage 

func (*PublishEventResponse) ProtoMessage()

func (*PublishEventResponse) ProtoReflect 

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

func (*PublishEventResponse) Reset 

func (x *PublishEventResponse) Reset()

func (*PublishEventResponse) String 

func (x *PublishEventResponse) String() string

type UnimplementedWorkflowServiceServer 

type UnimplementedWorkflowServiceServer struct{}

UnimplementedWorkflowServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedWorkflowServiceServer) GetWorkflows 

func (UnimplementedWorkflowServiceServer) GetWorkflows(*GetWorkflowsRequest, WorkflowService_GetWorkflowsServer) error

func (UnimplementedWorkflowServiceServer) PublishEvent 

func (UnimplementedWorkflowServiceServer) PublishEvent(context.Context, *PublishEventRequest) (*PublishEventResponse, error)

type UnsafeWorkflowServiceServer 

type UnsafeWorkflowServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeWorkflowServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to WorkflowServiceServer will result in compilation errors.

type Workflow 

type Workflow struct {

	// A unique identifier for a workflow.
	WorkflowId string `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	// The actions that make up the workflow.
	Actions []*Workflow_Action `protobuf:"bytes,2,rep,name=actions,proto3" json:"actions,omitempty"`
	// contains filtered or unexported fields
}

func (*Workflow) Descriptor deprecated 

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

Deprecated: Use Workflow.ProtoReflect.Descriptor instead.

func (*Workflow) GetActions 

func (x *Workflow) GetActions() []*Workflow_Action

func (*Workflow) GetWorkflowId 

func (x *Workflow) GetWorkflowId() string

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 WorkflowServiceClient 

type WorkflowServiceClient interface {
	// GetWorkflows creates a stream that will receive workflows intended for the agent identified
	// by the GetWorkflowsRequest.agent_id.
	GetWorkflows(ctx context.Context, in *GetWorkflowsRequest, opts ...grpc.CallOption) (WorkflowService_GetWorkflowsClient, error)
	// PublishEvent publishes a workflow event.
	PublishEvent(ctx context.Context, in *PublishEventRequest, opts ...grpc.CallOption) (*PublishEventResponse, error)
}

WorkflowServiceClient is the client API for WorkflowService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewWorkflowServiceClient 

func NewWorkflowServiceClient(cc grpc.ClientConnInterface) WorkflowServiceClient

type WorkflowServiceClientMock 

type WorkflowServiceClientMock struct {
	// GetWorkflowsFunc mocks the GetWorkflows method.
	GetWorkflowsFunc func(ctx context.Context, in *GetWorkflowsRequest, opts ...grpc.CallOption) (WorkflowService_GetWorkflowsClient, error)

	// PublishEventFunc mocks the PublishEvent method.
	PublishEventFunc func(ctx context.Context, in *PublishEventRequest, opts ...grpc.CallOption) (*PublishEventResponse, error)
	// contains filtered or unexported fields
}

WorkflowServiceClientMock is a mock implementation of WorkflowServiceClient. 

func TestSomethingThatUsesWorkflowServiceClient(t *testing.T) {

	// make and configure a mocked WorkflowServiceClient
	mockedWorkflowServiceClient := &WorkflowServiceClientMock{
		GetWorkflowsFunc: func(ctx context.Context, in *GetWorkflowsRequest, opts ...grpc.CallOption) (WorkflowService_GetWorkflowsClient, error) {
			panic("mock out the GetWorkflows method")
		},
		PublishEventFunc: func(ctx context.Context, in *PublishEventRequest, opts ...grpc.CallOption) (*PublishEventResponse, error) {
			panic("mock out the PublishEvent method")
		},
	}

	// use mockedWorkflowServiceClient in code that requires WorkflowServiceClient
	// and then make assertions.

}

func (*WorkflowServiceClientMock) GetWorkflows 

func (mock *WorkflowServiceClientMock) GetWorkflows(ctx context.Context, in *GetWorkflowsRequest, opts ...grpc.CallOption) (WorkflowService_GetWorkflowsClient, error)

GetWorkflows calls GetWorkflowsFunc.

func (*WorkflowServiceClientMock) GetWorkflowsCalls 

func (mock *WorkflowServiceClientMock) GetWorkflowsCalls() []struct {
	Ctx  context.Context
	In   *GetWorkflowsRequest
	Opts []grpc.CallOption
}

GetWorkflowsCalls gets all the calls that were made to GetWorkflows. Check the length with: 

len(mockedWorkflowServiceClient.GetWorkflowsCalls())

func (*WorkflowServiceClientMock) PublishEvent 

func (mock *WorkflowServiceClientMock) PublishEvent(ctx context.Context, in *PublishEventRequest, opts ...grpc.CallOption) (*PublishEventResponse, error)

PublishEvent calls PublishEventFunc.

func (*WorkflowServiceClientMock) PublishEventCalls 

func (mock *WorkflowServiceClientMock) PublishEventCalls() []struct {
	Ctx  context.Context
	In   *PublishEventRequest
	Opts []grpc.CallOption
}

PublishEventCalls gets all the calls that were made to PublishEvent. Check the length with: 

len(mockedWorkflowServiceClient.PublishEventCalls())

type WorkflowServiceServer 

type WorkflowServiceServer interface {
	// GetWorkflows creates a stream that will receive workflows intended for the agent identified
	// by the GetWorkflowsRequest.agent_id.
	GetWorkflows(*GetWorkflowsRequest, WorkflowService_GetWorkflowsServer) error
	// PublishEvent publishes a workflow event.
	PublishEvent(context.Context, *PublishEventRequest) (*PublishEventResponse, error)
}

WorkflowServiceServer is the server API for WorkflowService service. All implementations should embed UnimplementedWorkflowServiceServer for forward compatibility

type WorkflowService_GetWorkflowsClient 

type WorkflowService_GetWorkflowsClient interface {
	Recv() (*GetWorkflowsResponse, error)
	grpc.ClientStream
}

type WorkflowService_GetWorkflowsClientMock 

type WorkflowService_GetWorkflowsClientMock struct {
	// CloseSendFunc mocks the CloseSend method.
	CloseSendFunc func() error

	// ContextFunc mocks the Context method.
	ContextFunc func() context.Context

	// HeaderFunc mocks the Header method.
	HeaderFunc func() (metadata.MD, error)

	// RecvFunc mocks the Recv method.
	RecvFunc func() (*GetWorkflowsResponse, error)

	// RecvMsgFunc mocks the RecvMsg method.
	RecvMsgFunc func(m interface{}) error

	// SendMsgFunc mocks the SendMsg method.
	SendMsgFunc func(m interface{}) error

	// TrailerFunc mocks the Trailer method.
	TrailerFunc func() metadata.MD
	// contains filtered or unexported fields
}

WorkflowService_GetWorkflowsClientMock is a mock implementation of WorkflowService_GetWorkflowsClient. 

func TestSomethingThatUsesWorkflowService_GetWorkflowsClient(t *testing.T) {

	// make and configure a mocked WorkflowService_GetWorkflowsClient
	mockedWorkflowService_GetWorkflowsClient := &WorkflowService_GetWorkflowsClientMock{
		CloseSendFunc: func() error {
			panic("mock out the CloseSend method")
		},
		ContextFunc: func() context.Context {
			panic("mock out the Context method")
		},
		HeaderFunc: func() (metadata.MD, error) {
			panic("mock out the Header method")
		},
		RecvFunc: func() (*GetWorkflowsResponse, error) {
			panic("mock out the Recv method")
		},
		RecvMsgFunc: func(m interface{}) error {
			panic("mock out the RecvMsg method")
		},
		SendMsgFunc: func(m interface{}) error {
			panic("mock out the SendMsg method")
		},
		TrailerFunc: func() metadata.MD {
			panic("mock out the Trailer method")
		},
	}

	// use mockedWorkflowService_GetWorkflowsClient in code that requires WorkflowService_GetWorkflowsClient
	// and then make assertions.

}

func (*WorkflowService_GetWorkflowsClientMock) CloseSend 

func (mock *WorkflowService_GetWorkflowsClientMock) CloseSend() error

CloseSend calls CloseSendFunc.

func (*WorkflowService_GetWorkflowsClientMock) CloseSendCalls 

func (mock *WorkflowService_GetWorkflowsClientMock) CloseSendCalls() []struct {
}

CloseSendCalls gets all the calls that were made to CloseSend. Check the length with: 

len(mockedWorkflowService_GetWorkflowsClient.CloseSendCalls())

func (*WorkflowService_GetWorkflowsClientMock) Context 

func (mock *WorkflowService_GetWorkflowsClientMock) Context() context.Context

Context calls ContextFunc.

func (*WorkflowService_GetWorkflowsClientMock) ContextCalls 

func (mock *WorkflowService_GetWorkflowsClientMock) ContextCalls() []struct {
}

ContextCalls gets all the calls that were made to Context. Check the length with: 

len(mockedWorkflowService_GetWorkflowsClient.ContextCalls())

func (*WorkflowService_GetWorkflowsClientMock) Header 

func (mock *WorkflowService_GetWorkflowsClientMock) Header() (metadata.MD, error)

Header calls HeaderFunc.

func (*WorkflowService_GetWorkflowsClientMock) HeaderCalls 

func (mock *WorkflowService_GetWorkflowsClientMock) HeaderCalls() []struct {
}

HeaderCalls gets all the calls that were made to Header. Check the length with: 

len(mockedWorkflowService_GetWorkflowsClient.HeaderCalls())

func (*WorkflowService_GetWorkflowsClientMock) Recv 

func (mock *WorkflowService_GetWorkflowsClientMock) Recv() (*GetWorkflowsResponse, error)

Recv calls RecvFunc.

func (*WorkflowService_GetWorkflowsClientMock) RecvCalls 

func (mock *WorkflowService_GetWorkflowsClientMock) RecvCalls() []struct {
}

RecvCalls gets all the calls that were made to Recv. Check the length with: 

len(mockedWorkflowService_GetWorkflowsClient.RecvCalls())

func (*WorkflowService_GetWorkflowsClientMock) RecvMsg 

func (mock *WorkflowService_GetWorkflowsClientMock) RecvMsg(m interface{}) error

RecvMsg calls RecvMsgFunc.

func (*WorkflowService_GetWorkflowsClientMock) RecvMsgCalls 

func (mock *WorkflowService_GetWorkflowsClientMock) RecvMsgCalls() []struct {
	M interface{}
}

RecvMsgCalls gets all the calls that were made to RecvMsg. Check the length with: 

len(mockedWorkflowService_GetWorkflowsClient.RecvMsgCalls())

func (*WorkflowService_GetWorkflowsClientMock) SendMsg 

func (mock *WorkflowService_GetWorkflowsClientMock) SendMsg(m interface{}) error

SendMsg calls SendMsgFunc.

func (*WorkflowService_GetWorkflowsClientMock) SendMsgCalls 

func (mock *WorkflowService_GetWorkflowsClientMock) SendMsgCalls() []struct {
	M interface{}
}

SendMsgCalls gets all the calls that were made to SendMsg. Check the length with: 

len(mockedWorkflowService_GetWorkflowsClient.SendMsgCalls())

func (*WorkflowService_GetWorkflowsClientMock) Trailer 

func (mock *WorkflowService_GetWorkflowsClientMock) Trailer() metadata.MD

Trailer calls TrailerFunc.

func (*WorkflowService_GetWorkflowsClientMock) TrailerCalls 

func (mock *WorkflowService_GetWorkflowsClientMock) TrailerCalls() []struct {
}

TrailerCalls gets all the calls that were made to Trailer. Check the length with: 

len(mockedWorkflowService_GetWorkflowsClient.TrailerCalls())

type WorkflowService_GetWorkflowsServer 

type WorkflowService_GetWorkflowsServer interface {
	Send(*GetWorkflowsResponse) error
	grpc.ServerStream
}

type Workflow_Action 

type Workflow_Action struct {

	// A unique identifier for an action in the context of a workflow.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The name of the action. This can be used to identify actions in logging.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// The image to run.
	Image string `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
	// The command to execute when launching the image. When using Docker as the action runtime
	// it is used as the entrypoint.
	Cmd *string `protobuf:"bytes,4,opt,name=cmd,proto3,oneof" json:"cmd,omitempty"`
	// Arguments to pass to the container.
	Args []string `protobuf:"bytes,5,rep,name=args,proto3" json:"args,omitempty"`
	// Environment variables to configure when launching the container.
	Env map[string]string `` /* 147-byte string literal not displayed */
	// Volumes to mount when launching the container.
	Volumes []string `protobuf:"bytes,7,rep,name=volumes,proto3" json:"volumes,omitempty"`
	// The network namespace to launch the container in.
	NetworkNamespace *string `protobuf:"bytes,8,opt,name=network_namespace,json=networkNamespace,proto3,oneof" json:"network_namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*Workflow_Action) Descriptor deprecated 

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

Deprecated: Use Workflow_Action.ProtoReflect.Descriptor instead.

func (*Workflow_Action) GetArgs 

func (x *Workflow_Action) GetArgs() []string

func (*Workflow_Action) GetCmd 

func (x *Workflow_Action) GetCmd() string

func (*Workflow_Action) GetEnv 

func (x *Workflow_Action) GetEnv() map[string]string

func (*Workflow_Action) GetId 

func (x *Workflow_Action) GetId() string

func (*Workflow_Action) GetImage 

func (x *Workflow_Action) GetImage() string

func (*Workflow_Action) GetName 

func (x *Workflow_Action) GetName() string

func (*Workflow_Action) GetNetworkNamespace 

func (x *Workflow_Action) GetNetworkNamespace() string

func (*Workflow_Action) GetVolumes 

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

func (*Workflow_Action) ProtoMessage 

func (*Workflow_Action) ProtoMessage()

func (*Workflow_Action) ProtoReflect 

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

func (*Workflow_Action) Reset 

func (x *Workflow_Action) Reset()

func (*Workflow_Action) String 

func (x *Workflow_Action) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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