Documentation ¶
Overview ¶
Package workflow is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Variables
- func RegisterWorkflowServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterWorkflowServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client WorkflowServiceClient) error
- func RegisterWorkflowServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterWorkflowServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server WorkflowServiceServer) error
- func RegisterWorkflowServiceServer(s *grpc.Server, srv WorkflowServiceServer)
- type LogEntry
- func (*LogEntry) Descriptor() ([]byte, []int)
- func (m *LogEntry) GetContent() string
- func (m *LogEntry) Marshal() (dAtA []byte, err error)
- func (m *LogEntry) MarshalTo(dAtA []byte) (int, error)
- func (m *LogEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LogEntry) ProtoMessage()
- func (m *LogEntry) Reset()
- func (m *LogEntry) Size() (n int)
- func (m *LogEntry) String() string
- func (m *LogEntry) Unmarshal(dAtA []byte) error
- func (m *LogEntry) XXX_DiscardUnknown()
- func (m *LogEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogEntry) XXX_Merge(src proto.Message)
- func (m *LogEntry) XXX_Size() int
- func (m *LogEntry) XXX_Unmarshal(b []byte) error
- type UnimplementedWorkflowServiceServer
- func (*UnimplementedWorkflowServiceServer) CreateWorkflow(ctx context.Context, req *WorkflowCreateRequest) (*v1alpha1.Workflow, error)
- func (*UnimplementedWorkflowServiceServer) DeleteWorkflow(ctx context.Context, req *WorkflowDeleteRequest) (*WorkflowDeleteResponse, error)
- func (*UnimplementedWorkflowServiceServer) GetWorkflow(ctx context.Context, req *WorkflowGetRequest) (*v1alpha1.Workflow, error)
- func (*UnimplementedWorkflowServiceServer) LintWorkflow(ctx context.Context, req *WorkflowLintRequest) (*v1alpha1.Workflow, error)
- func (*UnimplementedWorkflowServiceServer) ListWorkflows(ctx context.Context, req *WorkflowListRequest) (*v1alpha1.WorkflowList, error)
- func (*UnimplementedWorkflowServiceServer) PodLogs(req *WorkflowLogRequest, srv WorkflowService_PodLogsServer) error
- func (*UnimplementedWorkflowServiceServer) ResubmitWorkflow(ctx context.Context, req *WorkflowResubmitRequest) (*v1alpha1.Workflow, error)
- func (*UnimplementedWorkflowServiceServer) ResumeWorkflow(ctx context.Context, req *WorkflowResumeRequest) (*v1alpha1.Workflow, error)
- func (*UnimplementedWorkflowServiceServer) RetryWorkflow(ctx context.Context, req *WorkflowRetryRequest) (*v1alpha1.Workflow, error)
- func (*UnimplementedWorkflowServiceServer) SuspendWorkflow(ctx context.Context, req *WorkflowSuspendRequest) (*v1alpha1.Workflow, error)
- func (*UnimplementedWorkflowServiceServer) TerminateWorkflow(ctx context.Context, req *WorkflowTerminateRequest) (*v1alpha1.Workflow, error)
- func (*UnimplementedWorkflowServiceServer) WatchWorkflows(req *WatchWorkflowsRequest, srv WorkflowService_WatchWorkflowsServer) error
- type WatchWorkflowsRequest
- func (*WatchWorkflowsRequest) Descriptor() ([]byte, []int)
- func (m *WatchWorkflowsRequest) GetListOptions() *v1.ListOptions
- func (m *WatchWorkflowsRequest) GetNamespace() string
- func (m *WatchWorkflowsRequest) Marshal() (dAtA []byte, err error)
- func (m *WatchWorkflowsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *WatchWorkflowsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WatchWorkflowsRequest) ProtoMessage()
- func (m *WatchWorkflowsRequest) Reset()
- func (m *WatchWorkflowsRequest) Size() (n int)
- func (m *WatchWorkflowsRequest) String() string
- func (m *WatchWorkflowsRequest) Unmarshal(dAtA []byte) error
- func (m *WatchWorkflowsRequest) XXX_DiscardUnknown()
- func (m *WatchWorkflowsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WatchWorkflowsRequest) XXX_Merge(src proto.Message)
- func (m *WatchWorkflowsRequest) XXX_Size() int
- func (m *WatchWorkflowsRequest) XXX_Unmarshal(b []byte) error
- type WorkflowCreateRequest
- func (*WorkflowCreateRequest) Descriptor() ([]byte, []int)
- func (m *WorkflowCreateRequest) GetCreateOptions() *v1.CreateOptions
- func (m *WorkflowCreateRequest) GetInstanceID() string
- func (m *WorkflowCreateRequest) GetNamespace() string
- func (m *WorkflowCreateRequest) GetServerDryRun() bool
- func (m *WorkflowCreateRequest) GetWorkflow() *v1alpha1.Workflow
- func (m *WorkflowCreateRequest) Marshal() (dAtA []byte, err error)
- func (m *WorkflowCreateRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkflowCreateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkflowCreateRequest) ProtoMessage()
- func (m *WorkflowCreateRequest) Reset()
- func (m *WorkflowCreateRequest) Size() (n int)
- func (m *WorkflowCreateRequest) String() string
- func (m *WorkflowCreateRequest) Unmarshal(dAtA []byte) error
- func (m *WorkflowCreateRequest) XXX_DiscardUnknown()
- func (m *WorkflowCreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkflowCreateRequest) XXX_Merge(src proto.Message)
- func (m *WorkflowCreateRequest) XXX_Size() int
- func (m *WorkflowCreateRequest) XXX_Unmarshal(b []byte) error
- type WorkflowDeleteRequest
- func (*WorkflowDeleteRequest) Descriptor() ([]byte, []int)
- func (m *WorkflowDeleteRequest) GetDeleteOptions() *v1.DeleteOptions
- func (m *WorkflowDeleteRequest) GetName() string
- func (m *WorkflowDeleteRequest) GetNamespace() string
- func (m *WorkflowDeleteRequest) Marshal() (dAtA []byte, err error)
- func (m *WorkflowDeleteRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkflowDeleteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkflowDeleteRequest) ProtoMessage()
- func (m *WorkflowDeleteRequest) Reset()
- func (m *WorkflowDeleteRequest) Size() (n int)
- func (m *WorkflowDeleteRequest) String() string
- func (m *WorkflowDeleteRequest) Unmarshal(dAtA []byte) error
- func (m *WorkflowDeleteRequest) XXX_DiscardUnknown()
- func (m *WorkflowDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkflowDeleteRequest) XXX_Merge(src proto.Message)
- func (m *WorkflowDeleteRequest) XXX_Size() int
- func (m *WorkflowDeleteRequest) XXX_Unmarshal(b []byte) error
- type WorkflowDeleteResponse
- func (*WorkflowDeleteResponse) Descriptor() ([]byte, []int)
- func (m *WorkflowDeleteResponse) Marshal() (dAtA []byte, err error)
- func (m *WorkflowDeleteResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkflowDeleteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkflowDeleteResponse) ProtoMessage()
- func (m *WorkflowDeleteResponse) Reset()
- func (m *WorkflowDeleteResponse) Size() (n int)
- func (m *WorkflowDeleteResponse) String() string
- func (m *WorkflowDeleteResponse) Unmarshal(dAtA []byte) error
- func (m *WorkflowDeleteResponse) XXX_DiscardUnknown()
- func (m *WorkflowDeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkflowDeleteResponse) XXX_Merge(src proto.Message)
- func (m *WorkflowDeleteResponse) XXX_Size() int
- func (m *WorkflowDeleteResponse) XXX_Unmarshal(b []byte) error
- type WorkflowGetRequest
- func (*WorkflowGetRequest) Descriptor() ([]byte, []int)
- func (m *WorkflowGetRequest) GetGetOptions() *v1.GetOptions
- func (m *WorkflowGetRequest) GetName() string
- func (m *WorkflowGetRequest) GetNamespace() string
- func (m *WorkflowGetRequest) Marshal() (dAtA []byte, err error)
- func (m *WorkflowGetRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkflowGetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkflowGetRequest) ProtoMessage()
- func (m *WorkflowGetRequest) Reset()
- func (m *WorkflowGetRequest) Size() (n int)
- func (m *WorkflowGetRequest) String() string
- func (m *WorkflowGetRequest) Unmarshal(dAtA []byte) error
- func (m *WorkflowGetRequest) XXX_DiscardUnknown()
- func (m *WorkflowGetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkflowGetRequest) XXX_Merge(src proto.Message)
- func (m *WorkflowGetRequest) XXX_Size() int
- func (m *WorkflowGetRequest) XXX_Unmarshal(b []byte) error
- type WorkflowLintRequest
- func (*WorkflowLintRequest) Descriptor() ([]byte, []int)
- func (m *WorkflowLintRequest) GetNamespace() string
- func (m *WorkflowLintRequest) GetWorkflow() *v1alpha1.Workflow
- func (m *WorkflowLintRequest) Marshal() (dAtA []byte, err error)
- func (m *WorkflowLintRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkflowLintRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkflowLintRequest) ProtoMessage()
- func (m *WorkflowLintRequest) Reset()
- func (m *WorkflowLintRequest) Size() (n int)
- func (m *WorkflowLintRequest) String() string
- func (m *WorkflowLintRequest) Unmarshal(dAtA []byte) error
- func (m *WorkflowLintRequest) XXX_DiscardUnknown()
- func (m *WorkflowLintRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkflowLintRequest) XXX_Merge(src proto.Message)
- func (m *WorkflowLintRequest) XXX_Size() int
- func (m *WorkflowLintRequest) XXX_Unmarshal(b []byte) error
- type WorkflowListRequest
- func (*WorkflowListRequest) Descriptor() ([]byte, []int)
- func (m *WorkflowListRequest) GetListOptions() *v1.ListOptions
- func (m *WorkflowListRequest) GetNamespace() string
- func (m *WorkflowListRequest) Marshal() (dAtA []byte, err error)
- func (m *WorkflowListRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkflowListRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkflowListRequest) ProtoMessage()
- func (m *WorkflowListRequest) Reset()
- func (m *WorkflowListRequest) Size() (n int)
- func (m *WorkflowListRequest) String() string
- func (m *WorkflowListRequest) Unmarshal(dAtA []byte) error
- func (m *WorkflowListRequest) XXX_DiscardUnknown()
- func (m *WorkflowListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkflowListRequest) XXX_Merge(src proto.Message)
- func (m *WorkflowListRequest) XXX_Size() int
- func (m *WorkflowListRequest) XXX_Unmarshal(b []byte) error
- type WorkflowLogRequest
- func (*WorkflowLogRequest) Descriptor() ([]byte, []int)
- func (m *WorkflowLogRequest) GetLogOptions() *v11.PodLogOptions
- func (m *WorkflowLogRequest) GetName() string
- func (m *WorkflowLogRequest) GetNamespace() string
- func (m *WorkflowLogRequest) GetPodName() string
- func (m *WorkflowLogRequest) Marshal() (dAtA []byte, err error)
- func (m *WorkflowLogRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkflowLogRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkflowLogRequest) ProtoMessage()
- func (m *WorkflowLogRequest) Reset()
- func (m *WorkflowLogRequest) Size() (n int)
- func (m *WorkflowLogRequest) String() string
- func (m *WorkflowLogRequest) Unmarshal(dAtA []byte) error
- func (m *WorkflowLogRequest) XXX_DiscardUnknown()
- func (m *WorkflowLogRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkflowLogRequest) XXX_Merge(src proto.Message)
- func (m *WorkflowLogRequest) XXX_Size() int
- func (m *WorkflowLogRequest) XXX_Unmarshal(b []byte) error
- type WorkflowResubmitRequest
- func (*WorkflowResubmitRequest) Descriptor() ([]byte, []int)
- func (m *WorkflowResubmitRequest) GetMemoized() bool
- func (m *WorkflowResubmitRequest) GetName() string
- func (m *WorkflowResubmitRequest) GetNamespace() string
- func (m *WorkflowResubmitRequest) Marshal() (dAtA []byte, err error)
- func (m *WorkflowResubmitRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkflowResubmitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkflowResubmitRequest) ProtoMessage()
- func (m *WorkflowResubmitRequest) Reset()
- func (m *WorkflowResubmitRequest) Size() (n int)
- func (m *WorkflowResubmitRequest) String() string
- func (m *WorkflowResubmitRequest) Unmarshal(dAtA []byte) error
- func (m *WorkflowResubmitRequest) XXX_DiscardUnknown()
- func (m *WorkflowResubmitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkflowResubmitRequest) XXX_Merge(src proto.Message)
- func (m *WorkflowResubmitRequest) XXX_Size() int
- func (m *WorkflowResubmitRequest) XXX_Unmarshal(b []byte) error
- type WorkflowResumeRequest
- func (*WorkflowResumeRequest) Descriptor() ([]byte, []int)
- func (m *WorkflowResumeRequest) GetName() string
- func (m *WorkflowResumeRequest) GetNamespace() string
- func (m *WorkflowResumeRequest) Marshal() (dAtA []byte, err error)
- func (m *WorkflowResumeRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkflowResumeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkflowResumeRequest) ProtoMessage()
- func (m *WorkflowResumeRequest) Reset()
- func (m *WorkflowResumeRequest) Size() (n int)
- func (m *WorkflowResumeRequest) String() string
- func (m *WorkflowResumeRequest) Unmarshal(dAtA []byte) error
- func (m *WorkflowResumeRequest) XXX_DiscardUnknown()
- func (m *WorkflowResumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkflowResumeRequest) XXX_Merge(src proto.Message)
- func (m *WorkflowResumeRequest) XXX_Size() int
- func (m *WorkflowResumeRequest) XXX_Unmarshal(b []byte) error
- type WorkflowRetryRequest
- func (*WorkflowRetryRequest) Descriptor() ([]byte, []int)
- func (m *WorkflowRetryRequest) GetName() string
- func (m *WorkflowRetryRequest) GetNamespace() string
- func (m *WorkflowRetryRequest) Marshal() (dAtA []byte, err error)
- func (m *WorkflowRetryRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkflowRetryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkflowRetryRequest) ProtoMessage()
- func (m *WorkflowRetryRequest) Reset()
- func (m *WorkflowRetryRequest) Size() (n int)
- func (m *WorkflowRetryRequest) String() string
- func (m *WorkflowRetryRequest) Unmarshal(dAtA []byte) error
- func (m *WorkflowRetryRequest) XXX_DiscardUnknown()
- func (m *WorkflowRetryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkflowRetryRequest) XXX_Merge(src proto.Message)
- func (m *WorkflowRetryRequest) XXX_Size() int
- func (m *WorkflowRetryRequest) XXX_Unmarshal(b []byte) error
- type WorkflowServiceClient
- type WorkflowServiceServer
- type WorkflowService_PodLogsClient
- type WorkflowService_PodLogsServer
- type WorkflowService_WatchWorkflowsClient
- type WorkflowService_WatchWorkflowsServer
- type WorkflowSuspendRequest
- func (*WorkflowSuspendRequest) Descriptor() ([]byte, []int)
- func (m *WorkflowSuspendRequest) GetName() string
- func (m *WorkflowSuspendRequest) GetNamespace() string
- func (m *WorkflowSuspendRequest) Marshal() (dAtA []byte, err error)
- func (m *WorkflowSuspendRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkflowSuspendRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkflowSuspendRequest) ProtoMessage()
- func (m *WorkflowSuspendRequest) Reset()
- func (m *WorkflowSuspendRequest) Size() (n int)
- func (m *WorkflowSuspendRequest) String() string
- func (m *WorkflowSuspendRequest) Unmarshal(dAtA []byte) error
- func (m *WorkflowSuspendRequest) XXX_DiscardUnknown()
- func (m *WorkflowSuspendRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkflowSuspendRequest) XXX_Merge(src proto.Message)
- func (m *WorkflowSuspendRequest) XXX_Size() int
- func (m *WorkflowSuspendRequest) XXX_Unmarshal(b []byte) error
- type WorkflowTerminateRequest
- func (*WorkflowTerminateRequest) Descriptor() ([]byte, []int)
- func (m *WorkflowTerminateRequest) GetName() string
- func (m *WorkflowTerminateRequest) GetNamespace() string
- func (m *WorkflowTerminateRequest) Marshal() (dAtA []byte, err error)
- func (m *WorkflowTerminateRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkflowTerminateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkflowTerminateRequest) ProtoMessage()
- func (m *WorkflowTerminateRequest) Reset()
- func (m *WorkflowTerminateRequest) Size() (n int)
- func (m *WorkflowTerminateRequest) String() string
- func (m *WorkflowTerminateRequest) Unmarshal(dAtA []byte) error
- func (m *WorkflowTerminateRequest) XXX_DiscardUnknown()
- func (m *WorkflowTerminateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkflowTerminateRequest) XXX_Merge(src proto.Message)
- func (m *WorkflowTerminateRequest) XXX_Size() int
- func (m *WorkflowTerminateRequest) XXX_Unmarshal(b []byte) error
- type WorkflowWatchEvent
- func (*WorkflowWatchEvent) Descriptor() ([]byte, []int)
- func (m *WorkflowWatchEvent) GetObject() *v1alpha1.Workflow
- func (m *WorkflowWatchEvent) GetType() string
- func (m *WorkflowWatchEvent) Marshal() (dAtA []byte, err error)
- func (m *WorkflowWatchEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkflowWatchEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkflowWatchEvent) ProtoMessage()
- func (m *WorkflowWatchEvent) Reset()
- func (m *WorkflowWatchEvent) Size() (n int)
- func (m *WorkflowWatchEvent) String() string
- func (m *WorkflowWatchEvent) Unmarshal(dAtA []byte) error
- func (m *WorkflowWatchEvent) XXX_DiscardUnknown()
- func (m *WorkflowWatchEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkflowWatchEvent) XXX_Merge(src proto.Message)
- func (m *WorkflowWatchEvent) XXX_Size() int
- func (m *WorkflowWatchEvent) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
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.
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LogEntry) Descriptor ¶
func (*LogEntry) GetContent ¶
func (*LogEntry) MarshalToSizedBuffer ¶
func (*LogEntry) ProtoMessage ¶
func (*LogEntry) ProtoMessage()
func (*LogEntry) XXX_DiscardUnknown ¶
func (m *LogEntry) XXX_DiscardUnknown()
func (*LogEntry) XXX_Marshal ¶
func (*LogEntry) XXX_Unmarshal ¶
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) 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) WatchWorkflows ¶
func (*UnimplementedWorkflowServiceServer) WatchWorkflows(req *WatchWorkflowsRequest, srv WorkflowService_WatchWorkflowsServer) 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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*WatchWorkflowsRequest) Descriptor ¶
func (*WatchWorkflowsRequest) Descriptor() ([]byte, []int)
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"` InstanceID string `protobuf:"bytes,3,opt,name=instanceID,proto3" json:"instanceID,omitempty"` 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 ¶
func (m *WorkflowCreateRequest) GetInstanceID() string
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"` 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) 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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*WorkflowGetRequest) Descriptor ¶
func (*WorkflowGetRequest) Descriptor() ([]byte, []int)
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) 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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*WorkflowListRequest) Descriptor ¶
func (*WorkflowListRequest) Descriptor() ([]byte, []int)
func (*WorkflowListRequest) GetListOptions ¶
func (m *WorkflowListRequest) GetListOptions() *v1.ListOptions
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*WorkflowLogRequest) Descriptor ¶
func (*WorkflowLogRequest) Descriptor() ([]byte, []int)
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) 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"` 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) 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"` 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) 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"` 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) 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) 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) LintWorkflow(ctx context.Context, in *WorkflowLintRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error) PodLogs(ctx context.Context, in *WorkflowLogRequest, opts ...grpc.CallOption) (WorkflowService_PodLogsClient, 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 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) LintWorkflow(context.Context, *WorkflowLintRequest) (*v1alpha1.Workflow, error) PodLogs(*WorkflowLogRequest, WorkflowService_PodLogsServer) error }
WorkflowServiceServer is the server API for WorkflowService service.
func NewWorkflowServer ¶
func NewWorkflowServer(offloadNodeStatusRepo sqldb.OffloadNodeStatusRepo) WorkflowServiceServer
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_WatchWorkflowsClient ¶
type WorkflowService_WatchWorkflowsClient interface { Recv() (*WorkflowWatchEvent, error) grpc.ClientStream }
type WorkflowService_WatchWorkflowsServer ¶
type WorkflowService_WatchWorkflowsServer interface { Send(*WorkflowWatchEvent) error grpc.ServerStream }
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