Help us shape the future of Go! Take the 2026 Go Developer Survey

workflow

package
v4.0.13 Latest Latest
Warning

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

 Go to latest Published: Oct 9, 2026 License: Apache-2.0 Imports: 21 Imported by: 4

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 (
	ErrInvalidLengthWorkflow        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowWorkflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupWorkflow = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterWorkflowServiceHandler 

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 

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 

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 

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 

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

Types

type LogEntry 

type LogEntry struct {
	Content              string   `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	PodName              string   `protobuf:"bytes,2,opt,name=podName,proto3" json:"podName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogEntry) Descriptor 

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

func (*LogEntry) GetContent 

func (m *LogEntry) GetContent() string

func (*LogEntry) GetPodName 

func (m *LogEntry) GetPodName() string

func (*LogEntry) Marshal 

func (m *LogEntry) Marshal() (dAtA []byte, err error)

func (*LogEntry) MarshalTo 

func (m *LogEntry) MarshalTo(dAtA []byte) (int, error)

func (*LogEntry) MarshalToSizedBuffer 

func (m *LogEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LogEntry) ProtoMessage 

func (*LogEntry) ProtoMessage()

func (*LogEntry) Reset 

func (m *LogEntry) Reset()

func (*LogEntry) Size 

func (m *LogEntry) Size() (n int)

func (*LogEntry) String 

func (m *LogEntry) String() string

func (*LogEntry) Unmarshal 

func (m *LogEntry) Unmarshal(dAtA []byte) error

func (*LogEntry) XXX_DiscardUnknown 

func (m *LogEntry) XXX_DiscardUnknown()

func (*LogEntry) XXX_Marshal 

func (m *LogEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogEntry) XXX_Merge 

func (m *LogEntry) XXX_Merge(src proto.Message)

func (*LogEntry) XXX_Size 

func (m *LogEntry) XXX_Size() int

func (*LogEntry) XXX_Unmarshal 

func (m *LogEntry) XXX_Unmarshal(b []byte) error

type UnimplementedWorkflowServiceServer 

type UnimplementedWorkflowServiceServer struct {
}

UnimplementedWorkflowServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedWorkflowServiceServer) CreateWorkflow 

func (*UnimplementedWorkflowServiceServer) CreateWorkflow(ctx context.Context, req *WorkflowCreateRequest) (*v1alpha1.Workflow, error)

func (*UnimplementedWorkflowServiceServer) DeleteWorkflow 

func (*UnimplementedWorkflowServiceServer) DeleteWorkflow(ctx context.Context, req *WorkflowDeleteRequest) (*WorkflowDeleteResponse, error)

func (*UnimplementedWorkflowServiceServer) GetWorkflow 

func (*UnimplementedWorkflowServiceServer) GetWorkflow(ctx context.Context, req *WorkflowGetRequest) (*v1alpha1.Workflow, error)

func (*UnimplementedWorkflowServiceServer) LintWorkflow 

func (*UnimplementedWorkflowServiceServer) LintWorkflow(ctx context.Context, req *WorkflowLintRequest) (*v1alpha1.Workflow, error)

func (*UnimplementedWorkflowServiceServer) ListWorkflows 

func (*UnimplementedWorkflowServiceServer) ListWorkflows(ctx context.Context, req *WorkflowListRequest) (*v1alpha1.WorkflowList, error)

func (*UnimplementedWorkflowServiceServer) PodLogs 

func (*UnimplementedWorkflowServiceServer) PodLogs(req *WorkflowLogRequest, srv WorkflowService_PodLogsServer) error

func (*UnimplementedWorkflowServiceServer) ResubmitWorkflow 

func (*UnimplementedWorkflowServiceServer) ResubmitWorkflow(ctx context.Context, req *WorkflowResubmitRequest) (*v1alpha1.Workflow, error)

func (*UnimplementedWorkflowServiceServer) ResumeWorkflow 

func (*UnimplementedWorkflowServiceServer) ResumeWorkflow(ctx context.Context, req *WorkflowResumeRequest) (*v1alpha1.Workflow, error)

func (*UnimplementedWorkflowServiceServer) RetryWorkflow 

func (*UnimplementedWorkflowServiceServer) RetryWorkflow(ctx context.Context, req *WorkflowRetryRequest) (*v1alpha1.Workflow, error)

func (*UnimplementedWorkflowServiceServer) SetWorkflow 

func (*UnimplementedWorkflowServiceServer) SetWorkflow(ctx context.Context, req *WorkflowSetRequest) (*v1alpha1.Workflow, error)

func (*UnimplementedWorkflowServiceServer) StopWorkflow 

func (*UnimplementedWorkflowServiceServer) StopWorkflow(ctx context.Context, req *WorkflowStopRequest) (*v1alpha1.Workflow, error)

func (*UnimplementedWorkflowServiceServer) SubmitWorkflow 

func (*UnimplementedWorkflowServiceServer) SubmitWorkflow(ctx context.Context, req *WorkflowSubmitRequest) (*v1alpha1.Workflow, error)

func (*UnimplementedWorkflowServiceServer) SuspendWorkflow 

func (*UnimplementedWorkflowServiceServer) SuspendWorkflow(ctx context.Context, req *WorkflowSuspendRequest) (*v1alpha1.Workflow, error)

func (*UnimplementedWorkflowServiceServer) TerminateWorkflow 

func (*UnimplementedWorkflowServiceServer) TerminateWorkflow(ctx context.Context, req *WorkflowTerminateRequest) (*v1alpha1.Workflow, error)

func (*UnimplementedWorkflowServiceServer) WatchEvents 

func (*UnimplementedWorkflowServiceServer) WatchEvents(req *WatchEventsRequest, srv WorkflowService_WatchEventsServer) error

func (*UnimplementedWorkflowServiceServer) WatchWorkflows 

func (*UnimplementedWorkflowServiceServer) WatchWorkflows(req *WatchWorkflowsRequest, srv WorkflowService_WatchWorkflowsServer) error

func (*UnimplementedWorkflowServiceServer) WorkflowLogs 

func (*UnimplementedWorkflowServiceServer) WorkflowLogs(req *WorkflowLogRequest, srv WorkflowService_WorkflowLogsServer) error

type WatchEventsRequest 

type WatchEventsRequest struct {
	Namespace            string          `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ListOptions          *v1.ListOptions `protobuf:"bytes,2,opt,name=listOptions,proto3" json:"listOptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*WatchEventsRequest) Descriptor 

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

func (*WatchEventsRequest) GetListOptions 

func (m *WatchEventsRequest) GetListOptions() *v1.ListOptions

func (*WatchEventsRequest) GetNamespace 

func (m *WatchEventsRequest) GetNamespace() string

func (*WatchEventsRequest) Marshal 

func (m *WatchEventsRequest) Marshal() (dAtA []byte, err error)

func (*WatchEventsRequest) MarshalTo 

func (m *WatchEventsRequest) MarshalTo(dAtA []byte) (int, error)

func (*WatchEventsRequest) MarshalToSizedBuffer 

func (m *WatchEventsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WatchEventsRequest) ProtoMessage 

func (*WatchEventsRequest) ProtoMessage()

func (*WatchEventsRequest) Reset 

func (m *WatchEventsRequest) Reset()

func (*WatchEventsRequest) Size 

func (m *WatchEventsRequest) Size() (n int)

func (*WatchEventsRequest) String 

func (m *WatchEventsRequest) String() string

func (*WatchEventsRequest) Unmarshal 

func (m *WatchEventsRequest) Unmarshal(dAtA []byte) error

func (*WatchEventsRequest) XXX_DiscardUnknown 

func (m *WatchEventsRequest) XXX_DiscardUnknown()

func (*WatchEventsRequest) XXX_Marshal 

func (m *WatchEventsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WatchEventsRequest) XXX_Merge 

func (m *WatchEventsRequest) XXX_Merge(src proto.Message)

func (*WatchEventsRequest) XXX_Size 

func (m *WatchEventsRequest) XXX_Size() int

func (*WatchEventsRequest) XXX_Unmarshal 

func (m *WatchEventsRequest) XXX_Unmarshal(b []byte) error

type WatchWorkflowsRequest 

type WatchWorkflowsRequest struct {
	Namespace            string          `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ListOptions          *v1.ListOptions `protobuf:"bytes,2,opt,name=listOptions,proto3" json:"listOptions,omitempty"`
	Fields               string          `protobuf:"bytes,3,opt,name=fields,proto3" json:"fields,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*WatchWorkflowsRequest) Descriptor 

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

func (*WatchWorkflowsRequest) GetFields 

func (m *WatchWorkflowsRequest) GetFields() string

func (*WatchWorkflowsRequest) GetListOptions 

func (m *WatchWorkflowsRequest) GetListOptions() *v1.ListOptions

func (*WatchWorkflowsRequest) GetNamespace 

func (m *WatchWorkflowsRequest) GetNamespace() string

func (*WatchWorkflowsRequest) Marshal 

func (m *WatchWorkflowsRequest) Marshal() (dAtA []byte, err error)

func (*WatchWorkflowsRequest) MarshalTo 

func (m *WatchWorkflowsRequest) MarshalTo(dAtA []byte) (int, error)

func (*WatchWorkflowsRequest) MarshalToSizedBuffer 

func (m *WatchWorkflowsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WatchWorkflowsRequest) ProtoMessage 

func (*WatchWorkflowsRequest) ProtoMessage()

func (*WatchWorkflowsRequest) Reset 

func (m *WatchWorkflowsRequest) Reset()

func (*WatchWorkflowsRequest) Size 

func (m *WatchWorkflowsRequest) Size() (n int)

func (*WatchWorkflowsRequest) String 

func (m *WatchWorkflowsRequest) String() string

func (*WatchWorkflowsRequest) Unmarshal 

func (m *WatchWorkflowsRequest) Unmarshal(dAtA []byte) error

func (*WatchWorkflowsRequest) XXX_DiscardUnknown 

func (m *WatchWorkflowsRequest) XXX_DiscardUnknown()

func (*WatchWorkflowsRequest) XXX_Marshal 

func (m *WatchWorkflowsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WatchWorkflowsRequest) XXX_Merge 

func (m *WatchWorkflowsRequest) XXX_Merge(src proto.Message)

func (*WatchWorkflowsRequest) XXX_Size 

func (m *WatchWorkflowsRequest) XXX_Size() int

func (*WatchWorkflowsRequest) XXX_Unmarshal 

func (m *WatchWorkflowsRequest) XXX_Unmarshal(b []byte) error

type WorkflowCreateRequest 

type WorkflowCreateRequest struct {
	Namespace string             `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Workflow  *v1alpha1.Workflow `protobuf:"bytes,2,opt,name=workflow,proto3" json:"workflow,omitempty"`
	// This field is no longer used.
	InstanceID           string            `protobuf:"bytes,3,opt,name=instanceID,proto3" json:"instanceID,omitempty"` // Deprecated: Do not use.
	ServerDryRun         bool              `protobuf:"varint,4,opt,name=serverDryRun,proto3" json:"serverDryRun,omitempty"`
	CreateOptions        *v1.CreateOptions `protobuf:"bytes,5,opt,name=createOptions,proto3" json:"createOptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*WorkflowCreateRequest) Descriptor 

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

func (*WorkflowCreateRequest) GetCreateOptions 

func (m *WorkflowCreateRequest) GetCreateOptions() *v1.CreateOptions

func (*WorkflowCreateRequest) GetInstanceID deprecated 

func (m *WorkflowCreateRequest) GetInstanceID() string

Deprecated: Do not use.

func (*WorkflowCreateRequest) GetNamespace 

func (m *WorkflowCreateRequest) GetNamespace() string

func (*WorkflowCreateRequest) GetServerDryRun 

func (m *WorkflowCreateRequest) GetServerDryRun() bool

func (*WorkflowCreateRequest) GetWorkflow 

func (m *WorkflowCreateRequest) GetWorkflow() *v1alpha1.Workflow

func (*WorkflowCreateRequest) Marshal 

func (m *WorkflowCreateRequest) Marshal() (dAtA []byte, err error)

func (*WorkflowCreateRequest) MarshalTo 

func (m *WorkflowCreateRequest) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowCreateRequest) MarshalToSizedBuffer 

func (m *WorkflowCreateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowCreateRequest) ProtoMessage 

func (*WorkflowCreateRequest) ProtoMessage()

func (*WorkflowCreateRequest) Reset 

func (m *WorkflowCreateRequest) Reset()

func (*WorkflowCreateRequest) Size 

func (m *WorkflowCreateRequest) Size() (n int)

func (*WorkflowCreateRequest) String 

func (m *WorkflowCreateRequest) String() string

func (*WorkflowCreateRequest) Unmarshal 

func (m *WorkflowCreateRequest) Unmarshal(dAtA []byte) error

func (*WorkflowCreateRequest) XXX_DiscardUnknown 

func (m *WorkflowCreateRequest) XXX_DiscardUnknown()

func (*WorkflowCreateRequest) XXX_Marshal 

func (m *WorkflowCreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowCreateRequest) XXX_Merge 

func (m *WorkflowCreateRequest) XXX_Merge(src proto.Message)

func (*WorkflowCreateRequest) XXX_Size 

func (m *WorkflowCreateRequest) XXX_Size() int

func (*WorkflowCreateRequest) XXX_Unmarshal 

func (m *WorkflowCreateRequest) XXX_Unmarshal(b []byte) error

type WorkflowDeleteRequest 

type WorkflowDeleteRequest struct {
	Name                 string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            string            `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	DeleteOptions        *v1.DeleteOptions `protobuf:"bytes,3,opt,name=deleteOptions,proto3" json:"deleteOptions,omitempty"`
	Force                bool              `protobuf:"varint,4,opt,name=force,proto3" json:"force,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*WorkflowDeleteRequest) Descriptor 

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

func (*WorkflowDeleteRequest) GetDeleteOptions 

func (m *WorkflowDeleteRequest) GetDeleteOptions() *v1.DeleteOptions

func (*WorkflowDeleteRequest) GetForce 

func (m *WorkflowDeleteRequest) GetForce() bool

func (*WorkflowDeleteRequest) GetName 

func (m *WorkflowDeleteRequest) GetName() string

func (*WorkflowDeleteRequest) GetNamespace 

func (m *WorkflowDeleteRequest) GetNamespace() string

func (*WorkflowDeleteRequest) Marshal 

func (m *WorkflowDeleteRequest) Marshal() (dAtA []byte, err error)

func (*WorkflowDeleteRequest) MarshalTo 

func (m *WorkflowDeleteRequest) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowDeleteRequest) MarshalToSizedBuffer 

func (m *WorkflowDeleteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowDeleteRequest) ProtoMessage 

func (*WorkflowDeleteRequest) ProtoMessage()

func (*WorkflowDeleteRequest) Reset 

func (m *WorkflowDeleteRequest) Reset()

func (*WorkflowDeleteRequest) Size 

func (m *WorkflowDeleteRequest) Size() (n int)

func (*WorkflowDeleteRequest) String 

func (m *WorkflowDeleteRequest) String() string

func (*WorkflowDeleteRequest) Unmarshal 

func (m *WorkflowDeleteRequest) Unmarshal(dAtA []byte) error

func (*WorkflowDeleteRequest) XXX_DiscardUnknown 

func (m *WorkflowDeleteRequest) XXX_DiscardUnknown()

func (*WorkflowDeleteRequest) XXX_Marshal 

func (m *WorkflowDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowDeleteRequest) XXX_Merge 

func (m *WorkflowDeleteRequest) XXX_Merge(src proto.Message)

func (*WorkflowDeleteRequest) XXX_Size 

func (m *WorkflowDeleteRequest) XXX_Size() int

func (*WorkflowDeleteRequest) XXX_Unmarshal 

func (m *WorkflowDeleteRequest) XXX_Unmarshal(b []byte) error

type WorkflowDeleteResponse 

type WorkflowDeleteResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WorkflowDeleteResponse) Descriptor 

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

func (*WorkflowDeleteResponse) Marshal 

func (m *WorkflowDeleteResponse) Marshal() (dAtA []byte, err error)

func (*WorkflowDeleteResponse) MarshalTo 

func (m *WorkflowDeleteResponse) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowDeleteResponse) MarshalToSizedBuffer 

func (m *WorkflowDeleteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowDeleteResponse) ProtoMessage 

func (*WorkflowDeleteResponse) ProtoMessage()

func (*WorkflowDeleteResponse) Reset 

func (m *WorkflowDeleteResponse) Reset()

func (*WorkflowDeleteResponse) Size 

func (m *WorkflowDeleteResponse) Size() (n int)

func (*WorkflowDeleteResponse) String 

func (m *WorkflowDeleteResponse) String() string

func (*WorkflowDeleteResponse) Unmarshal 

func (m *WorkflowDeleteResponse) Unmarshal(dAtA []byte) error

func (*WorkflowDeleteResponse) XXX_DiscardUnknown 

func (m *WorkflowDeleteResponse) XXX_DiscardUnknown()

func (*WorkflowDeleteResponse) XXX_Marshal 

func (m *WorkflowDeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowDeleteResponse) XXX_Merge 

func (m *WorkflowDeleteResponse) XXX_Merge(src proto.Message)

func (*WorkflowDeleteResponse) XXX_Size 

func (m *WorkflowDeleteResponse) XXX_Size() int

func (*WorkflowDeleteResponse) XXX_Unmarshal 

func (m *WorkflowDeleteResponse) XXX_Unmarshal(b []byte) error

type WorkflowGetRequest 

type WorkflowGetRequest struct {
	Name       string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace  string         `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	GetOptions *v1.GetOptions `protobuf:"bytes,3,opt,name=getOptions,proto3" json:"getOptions,omitempty"`
	// Fields to be included or excluded in the response. e.g. "spec,status.phase", "-status.nodes"
	Fields string `protobuf:"bytes,4,opt,name=fields,proto3" json:"fields,omitempty"`
	// Optional UID to retrieve a specific workflow (useful for archived workflows with the same name)
	Uid                  string   `protobuf:"bytes,5,opt,name=uid,proto3" json:"uid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WorkflowGetRequest) Descriptor 

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

func (*WorkflowGetRequest) GetFields 

func (m *WorkflowGetRequest) GetFields() string

func (*WorkflowGetRequest) GetGetOptions 

func (m *WorkflowGetRequest) GetGetOptions() *v1.GetOptions

func (*WorkflowGetRequest) GetName 

func (m *WorkflowGetRequest) GetName() string

func (*WorkflowGetRequest) GetNamespace 

func (m *WorkflowGetRequest) GetNamespace() string

func (*WorkflowGetRequest) GetUid 

func (m *WorkflowGetRequest) GetUid() string

func (*WorkflowGetRequest) Marshal 

func (m *WorkflowGetRequest) Marshal() (dAtA []byte, err error)

func (*WorkflowGetRequest) MarshalTo 

func (m *WorkflowGetRequest) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowGetRequest) MarshalToSizedBuffer 

func (m *WorkflowGetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowGetRequest) ProtoMessage 

func (*WorkflowGetRequest) ProtoMessage()

func (*WorkflowGetRequest) Reset 

func (m *WorkflowGetRequest) Reset()

func (*WorkflowGetRequest) Size 

func (m *WorkflowGetRequest) Size() (n int)

func (*WorkflowGetRequest) String 

func (m *WorkflowGetRequest) String() string

func (*WorkflowGetRequest) Unmarshal 

func (m *WorkflowGetRequest) Unmarshal(dAtA []byte) error

func (*WorkflowGetRequest) XXX_DiscardUnknown 

func (m *WorkflowGetRequest) XXX_DiscardUnknown()

func (*WorkflowGetRequest) XXX_Marshal 

func (m *WorkflowGetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowGetRequest) XXX_Merge 

func (m *WorkflowGetRequest) XXX_Merge(src proto.Message)

func (*WorkflowGetRequest) XXX_Size 

func (m *WorkflowGetRequest) XXX_Size() int

func (*WorkflowGetRequest) XXX_Unmarshal 

func (m *WorkflowGetRequest) XXX_Unmarshal(b []byte) error

type WorkflowLintRequest 

type WorkflowLintRequest struct {
	Namespace            string             `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Workflow             *v1alpha1.Workflow `protobuf:"bytes,2,opt,name=workflow,proto3" json:"workflow,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*WorkflowLintRequest) Descriptor 

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

func (*WorkflowLintRequest) GetNamespace 

func (m *WorkflowLintRequest) GetNamespace() string

func (*WorkflowLintRequest) GetWorkflow 

func (m *WorkflowLintRequest) GetWorkflow() *v1alpha1.Workflow

func (*WorkflowLintRequest) Marshal 

func (m *WorkflowLintRequest) Marshal() (dAtA []byte, err error)

func (*WorkflowLintRequest) MarshalTo 

func (m *WorkflowLintRequest) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowLintRequest) MarshalToSizedBuffer 

func (m *WorkflowLintRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowLintRequest) ProtoMessage 

func (*WorkflowLintRequest) ProtoMessage()

func (*WorkflowLintRequest) Reset 

func (m *WorkflowLintRequest) Reset()

func (*WorkflowLintRequest) Size 

func (m *WorkflowLintRequest) Size() (n int)

func (*WorkflowLintRequest) String 

func (m *WorkflowLintRequest) String() string

func (*WorkflowLintRequest) Unmarshal 

func (m *WorkflowLintRequest) Unmarshal(dAtA []byte) error

func (*WorkflowLintRequest) XXX_DiscardUnknown 

func (m *WorkflowLintRequest) XXX_DiscardUnknown()

func (*WorkflowLintRequest) XXX_Marshal 

func (m *WorkflowLintRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowLintRequest) XXX_Merge 

func (m *WorkflowLintRequest) XXX_Merge(src proto.Message)

func (*WorkflowLintRequest) XXX_Size 

func (m *WorkflowLintRequest) XXX_Size() int

func (*WorkflowLintRequest) XXX_Unmarshal 

func (m *WorkflowLintRequest) XXX_Unmarshal(b []byte) error

type WorkflowListRequest 

type WorkflowListRequest struct {
	Namespace   string          `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ListOptions *v1.ListOptions `protobuf:"bytes,2,opt,name=listOptions,proto3" json:"listOptions,omitempty"`
	// Fields to be included or excluded in the response. e.g. "items.spec,items.status.phase", "-items.status.nodes"
	Fields string `protobuf:"bytes,3,opt,name=fields,proto3" json:"fields,omitempty"`
	// Filter type used for name filtering. Exact | Contains | Prefix. Default to Exact
	NameFilter           string   `protobuf:"bytes,4,opt,name=nameFilter,proto3" json:"nameFilter,omitempty"`
	CreatedAfter         string   `protobuf:"bytes,5,opt,name=createdAfter,proto3" json:"createdAfter,omitempty"`
	FinishedBefore       string   `protobuf:"bytes,6,opt,name=finishedBefore,proto3" json:"finishedBefore,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WorkflowListRequest) Descriptor 

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

func (*WorkflowListRequest) GetCreatedAfter 

func (m *WorkflowListRequest) GetCreatedAfter() string

func (*WorkflowListRequest) GetFields 

func (m *WorkflowListRequest) GetFields() string

func (*WorkflowListRequest) GetFinishedBefore 

func (m *WorkflowListRequest) GetFinishedBefore() string

func (*WorkflowListRequest) GetListOptions 

func (m *WorkflowListRequest) GetListOptions() *v1.ListOptions

func (*WorkflowListRequest) GetNameFilter 

func (m *WorkflowListRequest) GetNameFilter() string

func (*WorkflowListRequest) GetNamespace 

func (m *WorkflowListRequest) GetNamespace() string

func (*WorkflowListRequest) Marshal 

func (m *WorkflowListRequest) Marshal() (dAtA []byte, err error)

func (*WorkflowListRequest) MarshalTo 

func (m *WorkflowListRequest) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowListRequest) MarshalToSizedBuffer 

func (m *WorkflowListRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowListRequest) ProtoMessage 

func (*WorkflowListRequest) ProtoMessage()

func (*WorkflowListRequest) Reset 

func (m *WorkflowListRequest) Reset()

func (*WorkflowListRequest) Size 

func (m *WorkflowListRequest) Size() (n int)

func (*WorkflowListRequest) String 

func (m *WorkflowListRequest) String() string

func (*WorkflowListRequest) Unmarshal 

func (m *WorkflowListRequest) Unmarshal(dAtA []byte) error

func (*WorkflowListRequest) XXX_DiscardUnknown 

func (m *WorkflowListRequest) XXX_DiscardUnknown()

func (*WorkflowListRequest) XXX_Marshal 

func (m *WorkflowListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowListRequest) XXX_Merge 

func (m *WorkflowListRequest) XXX_Merge(src proto.Message)

func (*WorkflowListRequest) XXX_Size 

func (m *WorkflowListRequest) XXX_Size() int

func (*WorkflowListRequest) XXX_Unmarshal 

func (m *WorkflowListRequest) XXX_Unmarshal(b []byte) error

type WorkflowLogRequest 

type WorkflowLogRequest struct {
	Name                 string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            string             `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	PodName              string             `protobuf:"bytes,3,opt,name=podName,proto3" json:"podName,omitempty"`
	LogOptions           *v11.PodLogOptions `protobuf:"bytes,4,opt,name=logOptions,proto3" json:"logOptions,omitempty"`
	Grep                 string             `protobuf:"bytes,5,opt,name=grep,proto3" json:"grep,omitempty"`
	Selector             string             `protobuf:"bytes,6,opt,name=selector,proto3" json:"selector,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*WorkflowLogRequest) Descriptor 

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

func (*WorkflowLogRequest) GetGrep 

func (m *WorkflowLogRequest) GetGrep() string

func (*WorkflowLogRequest) GetLogOptions 

func (m *WorkflowLogRequest) GetLogOptions() *v11.PodLogOptions

func (*WorkflowLogRequest) GetName 

func (m *WorkflowLogRequest) GetName() string

func (*WorkflowLogRequest) GetNamespace 

func (m *WorkflowLogRequest) GetNamespace() string

func (*WorkflowLogRequest) GetPodName 

func (m *WorkflowLogRequest) GetPodName() string

func (*WorkflowLogRequest) GetSelector 

func (m *WorkflowLogRequest) GetSelector() string

func (*WorkflowLogRequest) Marshal 

func (m *WorkflowLogRequest) Marshal() (dAtA []byte, err error)

func (*WorkflowLogRequest) MarshalTo 

func (m *WorkflowLogRequest) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowLogRequest) MarshalToSizedBuffer 

func (m *WorkflowLogRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowLogRequest) ProtoMessage 

func (*WorkflowLogRequest) ProtoMessage()

func (*WorkflowLogRequest) Reset 

func (m *WorkflowLogRequest) Reset()

func (*WorkflowLogRequest) Size 

func (m *WorkflowLogRequest) Size() (n int)

func (*WorkflowLogRequest) String 

func (m *WorkflowLogRequest) String() string

func (*WorkflowLogRequest) Unmarshal 

func (m *WorkflowLogRequest) Unmarshal(dAtA []byte) error

func (*WorkflowLogRequest) XXX_DiscardUnknown 

func (m *WorkflowLogRequest) XXX_DiscardUnknown()

func (*WorkflowLogRequest) XXX_Marshal 

func (m *WorkflowLogRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowLogRequest) XXX_Merge 

func (m *WorkflowLogRequest) XXX_Merge(src proto.Message)

func (*WorkflowLogRequest) XXX_Size 

func (m *WorkflowLogRequest) XXX_Size() int

func (*WorkflowLogRequest) XXX_Unmarshal 

func (m *WorkflowLogRequest) XXX_Unmarshal(b []byte) error

type WorkflowResubmitRequest 

type WorkflowResubmitRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Memoized             bool     `protobuf:"varint,3,opt,name=memoized,proto3" json:"memoized,omitempty"`
	Parameters           []string `protobuf:"bytes,5,rep,name=parameters,proto3" json:"parameters,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WorkflowResubmitRequest) Descriptor 

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

func (*WorkflowResubmitRequest) GetMemoized 

func (m *WorkflowResubmitRequest) GetMemoized() bool

func (*WorkflowResubmitRequest) GetName 

func (m *WorkflowResubmitRequest) GetName() string

func (*WorkflowResubmitRequest) GetNamespace 

func (m *WorkflowResubmitRequest) GetNamespace() string

func (*WorkflowResubmitRequest) GetParameters 

func (m *WorkflowResubmitRequest) GetParameters() []string

func (*WorkflowResubmitRequest) Marshal 

func (m *WorkflowResubmitRequest) Marshal() (dAtA []byte, err error)

func (*WorkflowResubmitRequest) MarshalTo 

func (m *WorkflowResubmitRequest) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowResubmitRequest) MarshalToSizedBuffer 

func (m *WorkflowResubmitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowResubmitRequest) ProtoMessage 

func (*WorkflowResubmitRequest) ProtoMessage()

func (*WorkflowResubmitRequest) Reset 

func (m *WorkflowResubmitRequest) Reset()

func (*WorkflowResubmitRequest) Size 

func (m *WorkflowResubmitRequest) Size() (n int)

func (*WorkflowResubmitRequest) String 

func (m *WorkflowResubmitRequest) String() string

func (*WorkflowResubmitRequest) Unmarshal 

func (m *WorkflowResubmitRequest) Unmarshal(dAtA []byte) error

func (*WorkflowResubmitRequest) XXX_DiscardUnknown 

func (m *WorkflowResubmitRequest) XXX_DiscardUnknown()

func (*WorkflowResubmitRequest) XXX_Marshal 

func (m *WorkflowResubmitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowResubmitRequest) XXX_Merge 

func (m *WorkflowResubmitRequest) XXX_Merge(src proto.Message)

func (*WorkflowResubmitRequest) XXX_Size 

func (m *WorkflowResubmitRequest) XXX_Size() int

func (*WorkflowResubmitRequest) XXX_Unmarshal 

func (m *WorkflowResubmitRequest) XXX_Unmarshal(b []byte) error

type WorkflowResumeRequest 

type WorkflowResumeRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	NodeFieldSelector    string   `protobuf:"bytes,3,opt,name=nodeFieldSelector,proto3" json:"nodeFieldSelector,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WorkflowResumeRequest) Descriptor 

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

func (*WorkflowResumeRequest) GetName 

func (m *WorkflowResumeRequest) GetName() string

func (*WorkflowResumeRequest) GetNamespace 

func (m *WorkflowResumeRequest) GetNamespace() string

func (*WorkflowResumeRequest) GetNodeFieldSelector 

func (m *WorkflowResumeRequest) GetNodeFieldSelector() string

func (*WorkflowResumeRequest) Marshal 

func (m *WorkflowResumeRequest) Marshal() (dAtA []byte, err error)

func (*WorkflowResumeRequest) MarshalTo 

func (m *WorkflowResumeRequest) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowResumeRequest) MarshalToSizedBuffer 

func (m *WorkflowResumeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowResumeRequest) ProtoMessage 

func (*WorkflowResumeRequest) ProtoMessage()

func (*WorkflowResumeRequest) Reset 

func (m *WorkflowResumeRequest) Reset()

func (*WorkflowResumeRequest) Size 

func (m *WorkflowResumeRequest) Size() (n int)

func (*WorkflowResumeRequest) String 

func (m *WorkflowResumeRequest) String() string

func (*WorkflowResumeRequest) Unmarshal 

func (m *WorkflowResumeRequest) Unmarshal(dAtA []byte) error

func (*WorkflowResumeRequest) XXX_DiscardUnknown 

func (m *WorkflowResumeRequest) XXX_DiscardUnknown()

func (*WorkflowResumeRequest) XXX_Marshal 

func (m *WorkflowResumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowResumeRequest) XXX_Merge 

func (m *WorkflowResumeRequest) XXX_Merge(src proto.Message)

func (*WorkflowResumeRequest) XXX_Size 

func (m *WorkflowResumeRequest) XXX_Size() int

func (*WorkflowResumeRequest) XXX_Unmarshal 

func (m *WorkflowResumeRequest) XXX_Unmarshal(b []byte) error

type WorkflowRetryRequest 

type WorkflowRetryRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	RestartSuccessful    bool     `protobuf:"varint,3,opt,name=restartSuccessful,proto3" json:"restartSuccessful,omitempty"`
	NodeFieldSelector    string   `protobuf:"bytes,4,opt,name=nodeFieldSelector,proto3" json:"nodeFieldSelector,omitempty"`
	Parameters           []string `protobuf:"bytes,5,rep,name=parameters,proto3" json:"parameters,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WorkflowRetryRequest) Descriptor 

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

func (*WorkflowRetryRequest) GetName 

func (m *WorkflowRetryRequest) GetName() string

func (*WorkflowRetryRequest) GetNamespace 

func (m *WorkflowRetryRequest) GetNamespace() string

func (*WorkflowRetryRequest) GetNodeFieldSelector 

func (m *WorkflowRetryRequest) GetNodeFieldSelector() string

func (*WorkflowRetryRequest) GetParameters 

func (m *WorkflowRetryRequest) GetParameters() []string

func (*WorkflowRetryRequest) GetRestartSuccessful 

func (m *WorkflowRetryRequest) GetRestartSuccessful() bool

func (*WorkflowRetryRequest) Marshal 

func (m *WorkflowRetryRequest) Marshal() (dAtA []byte, err error)

func (*WorkflowRetryRequest) MarshalTo 

func (m *WorkflowRetryRequest) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowRetryRequest) MarshalToSizedBuffer 

func (m *WorkflowRetryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowRetryRequest) ProtoMessage 

func (*WorkflowRetryRequest) ProtoMessage()

func (*WorkflowRetryRequest) Reset 

func (m *WorkflowRetryRequest) Reset()

func (*WorkflowRetryRequest) Size 

func (m *WorkflowRetryRequest) Size() (n int)

func (*WorkflowRetryRequest) String 

func (m *WorkflowRetryRequest) String() string

func (*WorkflowRetryRequest) Unmarshal 

func (m *WorkflowRetryRequest) Unmarshal(dAtA []byte) error

func (*WorkflowRetryRequest) XXX_DiscardUnknown 

func (m *WorkflowRetryRequest) XXX_DiscardUnknown()

func (*WorkflowRetryRequest) XXX_Marshal 

func (m *WorkflowRetryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowRetryRequest) XXX_Merge 

func (m *WorkflowRetryRequest) XXX_Merge(src proto.Message)

func (*WorkflowRetryRequest) XXX_Size 

func (m *WorkflowRetryRequest) XXX_Size() int

func (*WorkflowRetryRequest) XXX_Unmarshal 

func (m *WorkflowRetryRequest) XXX_Unmarshal(b []byte) error

type WorkflowServiceClient 

type WorkflowServiceClient interface {
	CreateWorkflow(ctx context.Context, in *WorkflowCreateRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error)
	GetWorkflow(ctx context.Context, in *WorkflowGetRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error)
	ListWorkflows(ctx context.Context, in *WorkflowListRequest, opts ...grpc.CallOption) (*v1alpha1.WorkflowList, error)
	WatchWorkflows(ctx context.Context, in *WatchWorkflowsRequest, opts ...grpc.CallOption) (WorkflowService_WatchWorkflowsClient, error)
	WatchEvents(ctx context.Context, in *WatchEventsRequest, opts ...grpc.CallOption) (WorkflowService_WatchEventsClient, error)
	DeleteWorkflow(ctx context.Context, in *WorkflowDeleteRequest, opts ...grpc.CallOption) (*WorkflowDeleteResponse, error)
	RetryWorkflow(ctx context.Context, in *WorkflowRetryRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error)
	ResubmitWorkflow(ctx context.Context, in *WorkflowResubmitRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error)
	ResumeWorkflow(ctx context.Context, in *WorkflowResumeRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error)
	SuspendWorkflow(ctx context.Context, in *WorkflowSuspendRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error)
	TerminateWorkflow(ctx context.Context, in *WorkflowTerminateRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error)
	StopWorkflow(ctx context.Context, in *WorkflowStopRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error)
	SetWorkflow(ctx context.Context, in *WorkflowSetRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error)
	LintWorkflow(ctx context.Context, in *WorkflowLintRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error)
	// DEPRECATED: Cannot work via HTTP if podName is an empty string. Use WorkflowLogs.
	PodLogs(ctx context.Context, in *WorkflowLogRequest, opts ...grpc.CallOption) (WorkflowService_PodLogsClient, error)
	WorkflowLogs(ctx context.Context, in *WorkflowLogRequest, opts ...grpc.CallOption) (WorkflowService_WorkflowLogsClient, error)
	SubmitWorkflow(ctx context.Context, in *WorkflowSubmitRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, 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 

func NewWorkflowServiceClient(cc *grpc.ClientConn) WorkflowServiceClient

type WorkflowServiceServer 

type WorkflowServiceServer interface {
	CreateWorkflow(context.Context, *WorkflowCreateRequest) (*v1alpha1.Workflow, error)
	GetWorkflow(context.Context, *WorkflowGetRequest) (*v1alpha1.Workflow, error)
	ListWorkflows(context.Context, *WorkflowListRequest) (*v1alpha1.WorkflowList, error)
	WatchWorkflows(*WatchWorkflowsRequest, WorkflowService_WatchWorkflowsServer) error
	WatchEvents(*WatchEventsRequest, WorkflowService_WatchEventsServer) error
	DeleteWorkflow(context.Context, *WorkflowDeleteRequest) (*WorkflowDeleteResponse, error)
	RetryWorkflow(context.Context, *WorkflowRetryRequest) (*v1alpha1.Workflow, error)
	ResubmitWorkflow(context.Context, *WorkflowResubmitRequest) (*v1alpha1.Workflow, error)
	ResumeWorkflow(context.Context, *WorkflowResumeRequest) (*v1alpha1.Workflow, error)
	SuspendWorkflow(context.Context, *WorkflowSuspendRequest) (*v1alpha1.Workflow, error)
	TerminateWorkflow(context.Context, *WorkflowTerminateRequest) (*v1alpha1.Workflow, error)
	StopWorkflow(context.Context, *WorkflowStopRequest) (*v1alpha1.Workflow, error)
	SetWorkflow(context.Context, *WorkflowSetRequest) (*v1alpha1.Workflow, error)
	LintWorkflow(context.Context, *WorkflowLintRequest) (*v1alpha1.Workflow, error)
	// DEPRECATED: Cannot work via HTTP if podName is an empty string. Use WorkflowLogs.
	PodLogs(*WorkflowLogRequest, WorkflowService_PodLogsServer) error
	WorkflowLogs(*WorkflowLogRequest, WorkflowService_WorkflowLogsServer) error
	SubmitWorkflow(context.Context, *WorkflowSubmitRequest) (*v1alpha1.Workflow, error)
}

WorkflowServiceServer is the server API for WorkflowService service.

type WorkflowService_PodLogsClient 

type WorkflowService_PodLogsClient interface {
	Recv() (*LogEntry, error)
	grpc.ClientStream
}

type WorkflowService_PodLogsServer 

type WorkflowService_PodLogsServer interface {
	Send(*LogEntry) error
	grpc.ServerStream
}

type WorkflowService_WatchEventsClient 

type WorkflowService_WatchEventsClient interface {
	Recv() (*v11.Event, error)
	grpc.ClientStream
}

type WorkflowService_WatchEventsServer 

type WorkflowService_WatchEventsServer interface {
	Send(*v11.Event) error
	grpc.ServerStream
}

type WorkflowService_WatchWorkflowsClient 

type WorkflowService_WatchWorkflowsClient interface {
	Recv() (*WorkflowWatchEvent, error)
	grpc.ClientStream
}

type WorkflowService_WatchWorkflowsServer 

type WorkflowService_WatchWorkflowsServer interface {
	Send(*WorkflowWatchEvent) error
	grpc.ServerStream
}

type WorkflowService_WorkflowLogsClient 

type WorkflowService_WorkflowLogsClient interface {
	Recv() (*LogEntry, error)
	grpc.ClientStream
}

type WorkflowService_WorkflowLogsServer 

type WorkflowService_WorkflowLogsServer interface {
	Send(*LogEntry) error
	grpc.ServerStream
}

type WorkflowSetRequest 

type WorkflowSetRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	NodeFieldSelector    string   `protobuf:"bytes,3,opt,name=nodeFieldSelector,proto3" json:"nodeFieldSelector,omitempty"`
	Message              string   `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	Phase                string   `protobuf:"bytes,5,opt,name=phase,proto3" json:"phase,omitempty"`
	OutputParameters     string   `protobuf:"bytes,6,opt,name=outputParameters,proto3" json:"outputParameters,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WorkflowSetRequest) Descriptor 

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

func (*WorkflowSetRequest) GetMessage 

func (m *WorkflowSetRequest) GetMessage() string

func (*WorkflowSetRequest) GetName 

func (m *WorkflowSetRequest) GetName() string

func (*WorkflowSetRequest) GetNamespace 

func (m *WorkflowSetRequest) GetNamespace() string

func (*WorkflowSetRequest) GetNodeFieldSelector 

func (m *WorkflowSetRequest) GetNodeFieldSelector() string

func (*WorkflowSetRequest) GetOutputParameters 

func (m *WorkflowSetRequest) GetOutputParameters() string

func (*WorkflowSetRequest) GetPhase 

func (m *WorkflowSetRequest) GetPhase() string

func (*WorkflowSetRequest) Marshal 

func (m *WorkflowSetRequest) Marshal() (dAtA []byte, err error)

func (*WorkflowSetRequest) MarshalTo 

func (m *WorkflowSetRequest) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowSetRequest) MarshalToSizedBuffer 

func (m *WorkflowSetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowSetRequest) ProtoMessage 

func (*WorkflowSetRequest) ProtoMessage()

func (*WorkflowSetRequest) Reset 

func (m *WorkflowSetRequest) Reset()

func (*WorkflowSetRequest) Size 

func (m *WorkflowSetRequest) Size() (n int)

func (*WorkflowSetRequest) String 

func (m *WorkflowSetRequest) String() string

func (*WorkflowSetRequest) Unmarshal 

func (m *WorkflowSetRequest) Unmarshal(dAtA []byte) error

func (*WorkflowSetRequest) XXX_DiscardUnknown 

func (m *WorkflowSetRequest) XXX_DiscardUnknown()

func (*WorkflowSetRequest) XXX_Marshal 

func (m *WorkflowSetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowSetRequest) XXX_Merge 

func (m *WorkflowSetRequest) XXX_Merge(src proto.Message)

func (*WorkflowSetRequest) XXX_Size 

func (m *WorkflowSetRequest) XXX_Size() int

func (*WorkflowSetRequest) XXX_Unmarshal 

func (m *WorkflowSetRequest) XXX_Unmarshal(b []byte) error

type WorkflowStopRequest 

type WorkflowStopRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	NodeFieldSelector    string   `protobuf:"bytes,3,opt,name=nodeFieldSelector,proto3" json:"nodeFieldSelector,omitempty"`
	Message              string   `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WorkflowStopRequest) Descriptor 

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

func (*WorkflowStopRequest) GetMessage 

func (m *WorkflowStopRequest) GetMessage() string

func (*WorkflowStopRequest) GetName 

func (m *WorkflowStopRequest) GetName() string

func (*WorkflowStopRequest) GetNamespace 

func (m *WorkflowStopRequest) GetNamespace() string

func (*WorkflowStopRequest) GetNodeFieldSelector 

func (m *WorkflowStopRequest) GetNodeFieldSelector() string

func (*WorkflowStopRequest) Marshal 

func (m *WorkflowStopRequest) Marshal() (dAtA []byte, err error)

func (*WorkflowStopRequest) MarshalTo 

func (m *WorkflowStopRequest) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowStopRequest) MarshalToSizedBuffer 

func (m *WorkflowStopRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowStopRequest) ProtoMessage 

func (*WorkflowStopRequest) ProtoMessage()

func (*WorkflowStopRequest) Reset 

func (m *WorkflowStopRequest) Reset()

func (*WorkflowStopRequest) Size 

func (m *WorkflowStopRequest) Size() (n int)

func (*WorkflowStopRequest) String 

func (m *WorkflowStopRequest) String() string

func (*WorkflowStopRequest) Unmarshal 

func (m *WorkflowStopRequest) Unmarshal(dAtA []byte) error

func (*WorkflowStopRequest) XXX_DiscardUnknown 

func (m *WorkflowStopRequest) XXX_DiscardUnknown()

func (*WorkflowStopRequest) XXX_Marshal 

func (m *WorkflowStopRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowStopRequest) XXX_Merge 

func (m *WorkflowStopRequest) XXX_Merge(src proto.Message)

func (*WorkflowStopRequest) XXX_Size 

func (m *WorkflowStopRequest) XXX_Size() int

func (*WorkflowStopRequest) XXX_Unmarshal 

func (m *WorkflowStopRequest) XXX_Unmarshal(b []byte) error

type WorkflowSubmitRequest 

type WorkflowSubmitRequest struct {
	Namespace            string               `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ResourceKind         string               `protobuf:"bytes,2,opt,name=resourceKind,proto3" json:"resourceKind,omitempty"`
	ResourceName         string               `protobuf:"bytes,3,opt,name=resourceName,proto3" json:"resourceName,omitempty"`
	SubmitOptions        *v1alpha1.SubmitOpts `protobuf:"bytes,4,opt,name=submitOptions,proto3" json:"submitOptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*WorkflowSubmitRequest) Descriptor 

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

func (*WorkflowSubmitRequest) GetNamespace 

func (m *WorkflowSubmitRequest) GetNamespace() string

func (*WorkflowSubmitRequest) GetResourceKind 

func (m *WorkflowSubmitRequest) GetResourceKind() string

func (*WorkflowSubmitRequest) GetResourceName 

func (m *WorkflowSubmitRequest) GetResourceName() string

func (*WorkflowSubmitRequest) GetSubmitOptions 

func (m *WorkflowSubmitRequest) GetSubmitOptions() *v1alpha1.SubmitOpts

func (*WorkflowSubmitRequest) Marshal 

func (m *WorkflowSubmitRequest) Marshal() (dAtA []byte, err error)

func (*WorkflowSubmitRequest) MarshalTo 

func (m *WorkflowSubmitRequest) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowSubmitRequest) MarshalToSizedBuffer 

func (m *WorkflowSubmitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowSubmitRequest) ProtoMessage 

func (*WorkflowSubmitRequest) ProtoMessage()

func (*WorkflowSubmitRequest) Reset 

func (m *WorkflowSubmitRequest) Reset()

func (*WorkflowSubmitRequest) Size 

func (m *WorkflowSubmitRequest) Size() (n int)

func (*WorkflowSubmitRequest) String 

func (m *WorkflowSubmitRequest) String() string

func (*WorkflowSubmitRequest) Unmarshal 

func (m *WorkflowSubmitRequest) Unmarshal(dAtA []byte) error

func (*WorkflowSubmitRequest) XXX_DiscardUnknown 

func (m *WorkflowSubmitRequest) XXX_DiscardUnknown()

func (*WorkflowSubmitRequest) XXX_Marshal 

func (m *WorkflowSubmitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowSubmitRequest) XXX_Merge 

func (m *WorkflowSubmitRequest) XXX_Merge(src proto.Message)

func (*WorkflowSubmitRequest) XXX_Size 

func (m *WorkflowSubmitRequest) XXX_Size() int

func (*WorkflowSubmitRequest) XXX_Unmarshal 

func (m *WorkflowSubmitRequest) XXX_Unmarshal(b []byte) error

type WorkflowSuspendRequest 

type WorkflowSuspendRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WorkflowSuspendRequest) Descriptor 

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

func (*WorkflowSuspendRequest) GetName 

func (m *WorkflowSuspendRequest) GetName() string

func (*WorkflowSuspendRequest) GetNamespace 

func (m *WorkflowSuspendRequest) GetNamespace() string

func (*WorkflowSuspendRequest) Marshal 

func (m *WorkflowSuspendRequest) Marshal() (dAtA []byte, err error)

func (*WorkflowSuspendRequest) MarshalTo 

func (m *WorkflowSuspendRequest) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowSuspendRequest) MarshalToSizedBuffer 

func (m *WorkflowSuspendRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowSuspendRequest) ProtoMessage 

func (*WorkflowSuspendRequest) ProtoMessage()

func (*WorkflowSuspendRequest) Reset 

func (m *WorkflowSuspendRequest) Reset()

func (*WorkflowSuspendRequest) Size 

func (m *WorkflowSuspendRequest) Size() (n int)

func (*WorkflowSuspendRequest) String 

func (m *WorkflowSuspendRequest) String() string

func (*WorkflowSuspendRequest) Unmarshal 

func (m *WorkflowSuspendRequest) Unmarshal(dAtA []byte) error

func (*WorkflowSuspendRequest) XXX_DiscardUnknown 

func (m *WorkflowSuspendRequest) XXX_DiscardUnknown()

func (*WorkflowSuspendRequest) XXX_Marshal 

func (m *WorkflowSuspendRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowSuspendRequest) XXX_Merge 

func (m *WorkflowSuspendRequest) XXX_Merge(src proto.Message)

func (*WorkflowSuspendRequest) XXX_Size 

func (m *WorkflowSuspendRequest) XXX_Size() int

func (*WorkflowSuspendRequest) XXX_Unmarshal 

func (m *WorkflowSuspendRequest) XXX_Unmarshal(b []byte) error

type WorkflowTerminateRequest 

type WorkflowTerminateRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WorkflowTerminateRequest) Descriptor 

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

func (*WorkflowTerminateRequest) GetName 

func (m *WorkflowTerminateRequest) GetName() string

func (*WorkflowTerminateRequest) GetNamespace 

func (m *WorkflowTerminateRequest) GetNamespace() string

func (*WorkflowTerminateRequest) Marshal 

func (m *WorkflowTerminateRequest) Marshal() (dAtA []byte, err error)

func (*WorkflowTerminateRequest) MarshalTo 

func (m *WorkflowTerminateRequest) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowTerminateRequest) MarshalToSizedBuffer 

func (m *WorkflowTerminateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowTerminateRequest) ProtoMessage 

func (*WorkflowTerminateRequest) ProtoMessage()

func (*WorkflowTerminateRequest) Reset 

func (m *WorkflowTerminateRequest) Reset()

func (*WorkflowTerminateRequest) Size 

func (m *WorkflowTerminateRequest) Size() (n int)

func (*WorkflowTerminateRequest) String 

func (m *WorkflowTerminateRequest) String() string

func (*WorkflowTerminateRequest) Unmarshal 

func (m *WorkflowTerminateRequest) Unmarshal(dAtA []byte) error

func (*WorkflowTerminateRequest) XXX_DiscardUnknown 

func (m *WorkflowTerminateRequest) XXX_DiscardUnknown()

func (*WorkflowTerminateRequest) XXX_Marshal 

func (m *WorkflowTerminateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowTerminateRequest) XXX_Merge 

func (m *WorkflowTerminateRequest) XXX_Merge(src proto.Message)

func (*WorkflowTerminateRequest) XXX_Size 

func (m *WorkflowTerminateRequest) XXX_Size() int

func (*WorkflowTerminateRequest) XXX_Unmarshal 

func (m *WorkflowTerminateRequest) XXX_Unmarshal(b []byte) error

type WorkflowWatchEvent 

type WorkflowWatchEvent struct {
	// the type of change
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// the workflow
	Object               *v1alpha1.Workflow `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*WorkflowWatchEvent) Descriptor 

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

func (*WorkflowWatchEvent) GetObject 

func (m *WorkflowWatchEvent) GetObject() *v1alpha1.Workflow

func (*WorkflowWatchEvent) GetType 

func (m *WorkflowWatchEvent) GetType() string

func (*WorkflowWatchEvent) Marshal 

func (m *WorkflowWatchEvent) Marshal() (dAtA []byte, err error)

func (*WorkflowWatchEvent) MarshalTo 

func (m *WorkflowWatchEvent) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowWatchEvent) MarshalToSizedBuffer 

func (m *WorkflowWatchEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowWatchEvent) ProtoMessage 

func (*WorkflowWatchEvent) ProtoMessage()

func (*WorkflowWatchEvent) Reset 

func (m *WorkflowWatchEvent) Reset()

func (*WorkflowWatchEvent) Size 

func (m *WorkflowWatchEvent) Size() (n int)

func (*WorkflowWatchEvent) String 

func (m *WorkflowWatchEvent) String() string

func (*WorkflowWatchEvent) Unmarshal 

func (m *WorkflowWatchEvent) Unmarshal(dAtA []byte) error

func (*WorkflowWatchEvent) XXX_DiscardUnknown 

func (m *WorkflowWatchEvent) XXX_DiscardUnknown()

func (*WorkflowWatchEvent) XXX_Marshal 

func (m *WorkflowWatchEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowWatchEvent) XXX_Merge 

func (m *WorkflowWatchEvent) XXX_Merge(src proto.Message)

func (*WorkflowWatchEvent) XXX_Size 

func (m *WorkflowWatchEvent) XXX_Size() int

func (*WorkflowWatchEvent) XXX_Unmarshal 

func (m *WorkflowWatchEvent) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Directories

Path Synopsis

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.