workflow

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
}

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
}

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

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
}

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

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
}

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

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
}

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

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

type GetWorkflowsResponse struct {

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

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

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

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
}

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

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

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

type UnimplementedWorkflowServiceServer struct{}

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

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
}

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

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
}

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

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

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
}

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

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
}