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) GetPodName() 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) SetWorkflow(ctx context.Context, req *WorkflowSetRequest) (*v1alpha1.Workflow, error)
- func (*UnimplementedWorkflowServiceServer) StopWorkflow(ctx context.Context, req *WorkflowStopRequest) (*v1alpha1.Workflow, error)
- func (*UnimplementedWorkflowServiceServer) SubmitWorkflow(ctx context.Context, req *WorkflowSubmitRequest) (*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) WatchEvents(req *WatchEventsRequest, srv WorkflowService_WatchEventsServer) error
- func (*UnimplementedWorkflowServiceServer) WatchWorkflows(req *WatchWorkflowsRequest, srv WorkflowService_WatchWorkflowsServer) error
- func (*UnimplementedWorkflowServiceServer) WorkflowLogs(req *WorkflowLogRequest, srv WorkflowService_WorkflowLogsServer) error
- type WatchEventsRequest
- func (*WatchEventsRequest) Descriptor() ([]byte, []int)
- func (m *WatchEventsRequest) GetListOptions() *v1.ListOptions
- func (m *WatchEventsRequest) GetNamespace() string
- func (m *WatchEventsRequest) Marshal() (dAtA []byte, err error)
- func (m *WatchEventsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *WatchEventsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WatchEventsRequest) ProtoMessage()
- func (m *WatchEventsRequest) Reset()
- func (m *WatchEventsRequest) Size() (n int)
- func (m *WatchEventsRequest) String() string
- func (m *WatchEventsRequest) Unmarshal(dAtA []byte) error
- func (m *WatchEventsRequest) XXX_DiscardUnknown()
- func (m *WatchEventsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WatchEventsRequest) XXX_Merge(src proto.Message)
- func (m *WatchEventsRequest) XXX_Size() int
- func (m *WatchEventsRequest) XXX_Unmarshal(b []byte) 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() stringdeprecated
- 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) GetFields() string
- 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) GetFields() string
- 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) GetNodeFieldSelector() 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) GetNodeFieldSelector() string
- func (m *WorkflowRetryRequest) GetRestartSuccessful() bool
- 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_WatchEventsClient
- type WorkflowService_WatchEventsServer
- type WorkflowService_WatchWorkflowsClient
- type WorkflowService_WatchWorkflowsServer
- type WorkflowService_WorkflowLogsClient
- type WorkflowService_WorkflowLogsServer
- type WorkflowSetRequest
- func (*WorkflowSetRequest) Descriptor() ([]byte, []int)
- func (m *WorkflowSetRequest) GetMessage() string
- func (m *WorkflowSetRequest) GetName() string
- func (m *WorkflowSetRequest) GetNamespace() string
- func (m *WorkflowSetRequest) GetNodeFieldSelector() string
- func (m *WorkflowSetRequest) GetOutputParameters() string
- func (m *WorkflowSetRequest) GetPhase() string
- func (m *WorkflowSetRequest) Marshal() (dAtA []byte, err error)
- func (m *WorkflowSetRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkflowSetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkflowSetRequest) ProtoMessage()
- func (m *WorkflowSetRequest) Reset()
- func (m *WorkflowSetRequest) Size() (n int)
- func (m *WorkflowSetRequest) String() string
- func (m *WorkflowSetRequest) Unmarshal(dAtA []byte) error
- func (m *WorkflowSetRequest) XXX_DiscardUnknown()
- func (m *WorkflowSetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkflowSetRequest) XXX_Merge(src proto.Message)
- func (m *WorkflowSetRequest) XXX_Size() int
- func (m *WorkflowSetRequest) XXX_Unmarshal(b []byte) error
- type WorkflowStopRequest
- func (*WorkflowStopRequest) Descriptor() ([]byte, []int)
- func (m *WorkflowStopRequest) GetMessage() string
- func (m *WorkflowStopRequest) GetName() string
- func (m *WorkflowStopRequest) GetNamespace() string
- func (m *WorkflowStopRequest) GetNodeFieldSelector() string
- func (m *WorkflowStopRequest) Marshal() (dAtA []byte, err error)
- func (m *WorkflowStopRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkflowStopRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkflowStopRequest) ProtoMessage()
- func (m *WorkflowStopRequest) Reset()
- func (m *WorkflowStopRequest) Size() (n int)
- func (m *WorkflowStopRequest) String() string
- func (m *WorkflowStopRequest) Unmarshal(dAtA []byte) error
- func (m *WorkflowStopRequest) XXX_DiscardUnknown()
- func (m *WorkflowStopRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkflowStopRequest) XXX_Merge(src proto.Message)
- func (m *WorkflowStopRequest) XXX_Size() int
- func (m *WorkflowStopRequest) XXX_Unmarshal(b []byte) error
- type WorkflowSubmitRequest
- func (*WorkflowSubmitRequest) Descriptor() ([]byte, []int)
- func (m *WorkflowSubmitRequest) GetNamespace() string
- func (m *WorkflowSubmitRequest) GetResourceKind() string
- func (m *WorkflowSubmitRequest) GetResourceName() string
- func (m *WorkflowSubmitRequest) GetSubmitOptions() *v1alpha1.SubmitOpts
- func (m *WorkflowSubmitRequest) Marshal() (dAtA []byte, err error)
- func (m *WorkflowSubmitRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkflowSubmitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkflowSubmitRequest) ProtoMessage()
- func (m *WorkflowSubmitRequest) Reset()
- func (m *WorkflowSubmitRequest) Size() (n int)
- func (m *WorkflowSubmitRequest) String() string
- func (m *WorkflowSubmitRequest) Unmarshal(dAtA []byte) error
- func (m *WorkflowSubmitRequest) XXX_DiscardUnknown()
- func (m *WorkflowSubmitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkflowSubmitRequest) XXX_Merge(src proto.Message)
- func (m *WorkflowSubmitRequest) XXX_Size() int
- func (m *WorkflowSubmitRequest) XXX_Unmarshal(b []byte) error
- 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"` 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) GetContent ¶
func (*LogEntry) GetPodName ¶
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) 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"` 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"` // 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"` 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"` // 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"` 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) 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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*WorkflowListRequest) Descriptor ¶
func (*WorkflowListRequest) Descriptor() ([]byte, []int)
func (*WorkflowListRequest) GetFields ¶
func (m *WorkflowListRequest) GetFields() string
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"` 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"` 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) 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