workflow

package
v0.0.0-...-2cc43cd Latest Latest
Warning

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

Go to latest
Published: Aug 27, 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 (*GetWorkflowsResponse) GetStopWorkflow

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 (*GetWorkflowsResponse_StartWorkflow) Reset

func (*GetWorkflowsResponse_StartWorkflow) 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 (*GetWorkflowsResponse_StopWorkflow) Reset

func (*GetWorkflowsResponse_StopWorkflow) 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) PublishEvent

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.

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

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

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

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

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

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

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL