Versions in this module Expand all Collapse all v3 v3.1.5 Jul 29, 2021 Changes in this version + var ErrIntOverflowWorkflow = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthWorkflow = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupWorkflow = fmt.Errorf("proto: unexpected end of group") + 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 struct + Content string + PodName string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LogEntry) Descriptor() ([]byte, []int) + func (*LogEntry) ProtoMessage() + 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 (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 struct + 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 struct + ListOptions *v1.ListOptions + Namespace string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WatchEventsRequest) Descriptor() ([]byte, []int) + func (*WatchEventsRequest) ProtoMessage() + 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 (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 struct + Fields string + ListOptions *v1.ListOptions + Namespace string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WatchWorkflowsRequest) Descriptor() ([]byte, []int) + func (*WatchWorkflowsRequest) ProtoMessage() + func (m *WatchWorkflowsRequest) GetFields() string + 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 (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 struct + CreateOptions *v1.CreateOptions + InstanceID string + Namespace string + ServerDryRun bool + Workflow *v1alpha1.Workflow + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WorkflowCreateRequest) Descriptor() ([]byte, []int) + func (*WorkflowCreateRequest) ProtoMessage() + 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 (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 struct + DeleteOptions *v1.DeleteOptions + Name string + Namespace string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WorkflowDeleteRequest) Descriptor() ([]byte, []int) + func (*WorkflowDeleteRequest) ProtoMessage() + 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 (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 struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WorkflowDeleteResponse) Descriptor() ([]byte, []int) + func (*WorkflowDeleteResponse) ProtoMessage() + 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 (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 struct + Fields string + GetOptions *v1.GetOptions + Name string + Namespace string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WorkflowGetRequest) Descriptor() ([]byte, []int) + func (*WorkflowGetRequest) ProtoMessage() + 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 (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 struct + Namespace string + Workflow *v1alpha1.Workflow + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WorkflowLintRequest) Descriptor() ([]byte, []int) + func (*WorkflowLintRequest) ProtoMessage() + 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 (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 struct + Fields string + ListOptions *v1.ListOptions + Namespace string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WorkflowListRequest) Descriptor() ([]byte, []int) + func (*WorkflowListRequest) ProtoMessage() + 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 (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 struct + Grep string + LogOptions *v11.PodLogOptions + Name string + Namespace string + PodName string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WorkflowLogRequest) Descriptor() ([]byte, []int) + func (*WorkflowLogRequest) ProtoMessage() + func (m *WorkflowLogRequest) GetGrep() string + 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 (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 struct + Memoized bool + Name string + Namespace string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WorkflowResubmitRequest) Descriptor() ([]byte, []int) + func (*WorkflowResubmitRequest) ProtoMessage() + 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 (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 struct + Name string + Namespace string + NodeFieldSelector string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WorkflowResumeRequest) Descriptor() ([]byte, []int) + func (*WorkflowResumeRequest) ProtoMessage() + 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 (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 struct + Name string + Namespace string + NodeFieldSelector string + RestartSuccessful bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WorkflowRetryRequest) Descriptor() ([]byte, []int) + func (*WorkflowRetryRequest) ProtoMessage() + 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 (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 interface + CreateWorkflow func(ctx context.Context, in *WorkflowCreateRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error) + DeleteWorkflow func(ctx context.Context, in *WorkflowDeleteRequest, opts ...grpc.CallOption) (*WorkflowDeleteResponse, error) + GetWorkflow func(ctx context.Context, in *WorkflowGetRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error) + LintWorkflow func(ctx context.Context, in *WorkflowLintRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error) + ListWorkflows func(ctx context.Context, in *WorkflowListRequest, opts ...grpc.CallOption) (*v1alpha1.WorkflowList, error) + PodLogs func(ctx context.Context, in *WorkflowLogRequest, opts ...grpc.CallOption) (WorkflowService_PodLogsClient, error) + ResubmitWorkflow func(ctx context.Context, in *WorkflowResubmitRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error) + ResumeWorkflow func(ctx context.Context, in *WorkflowResumeRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error) + RetryWorkflow func(ctx context.Context, in *WorkflowRetryRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error) + SetWorkflow func(ctx context.Context, in *WorkflowSetRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error) + StopWorkflow func(ctx context.Context, in *WorkflowStopRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error) + SubmitWorkflow func(ctx context.Context, in *WorkflowSubmitRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error) + SuspendWorkflow func(ctx context.Context, in *WorkflowSuspendRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error) + TerminateWorkflow func(ctx context.Context, in *WorkflowTerminateRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error) + WatchEvents func(ctx context.Context, in *WatchEventsRequest, opts ...grpc.CallOption) (WorkflowService_WatchEventsClient, error) + WatchWorkflows func(ctx context.Context, in *WatchWorkflowsRequest, opts ...grpc.CallOption) (WorkflowService_WatchWorkflowsClient, error) + WorkflowLogs func(ctx context.Context, in *WorkflowLogRequest, opts ...grpc.CallOption) (WorkflowService_WorkflowLogsClient, error) + func NewWorkflowServiceClient(cc *grpc.ClientConn) WorkflowServiceClient + type WorkflowServiceServer interface + CreateWorkflow func(context.Context, *WorkflowCreateRequest) (*v1alpha1.Workflow, error) + DeleteWorkflow func(context.Context, *WorkflowDeleteRequest) (*WorkflowDeleteResponse, error) + GetWorkflow func(context.Context, *WorkflowGetRequest) (*v1alpha1.Workflow, error) + LintWorkflow func(context.Context, *WorkflowLintRequest) (*v1alpha1.Workflow, error) + ListWorkflows func(context.Context, *WorkflowListRequest) (*v1alpha1.WorkflowList, error) + PodLogs func(*WorkflowLogRequest, WorkflowService_PodLogsServer) error + ResubmitWorkflow func(context.Context, *WorkflowResubmitRequest) (*v1alpha1.Workflow, error) + ResumeWorkflow func(context.Context, *WorkflowResumeRequest) (*v1alpha1.Workflow, error) + RetryWorkflow func(context.Context, *WorkflowRetryRequest) (*v1alpha1.Workflow, error) + SetWorkflow func(context.Context, *WorkflowSetRequest) (*v1alpha1.Workflow, error) + StopWorkflow func(context.Context, *WorkflowStopRequest) (*v1alpha1.Workflow, error) + SubmitWorkflow func(context.Context, *WorkflowSubmitRequest) (*v1alpha1.Workflow, error) + SuspendWorkflow func(context.Context, *WorkflowSuspendRequest) (*v1alpha1.Workflow, error) + TerminateWorkflow func(context.Context, *WorkflowTerminateRequest) (*v1alpha1.Workflow, error) + WatchEvents func(*WatchEventsRequest, WorkflowService_WatchEventsServer) error + WatchWorkflows func(*WatchWorkflowsRequest, WorkflowService_WatchWorkflowsServer) error + WorkflowLogs func(*WorkflowLogRequest, WorkflowService_WorkflowLogsServer) error + type WorkflowService_PodLogsClient interface + Recv func() (*LogEntry, error) + type WorkflowService_PodLogsServer interface + Send func(*LogEntry) error + type WorkflowService_WatchEventsClient interface + Recv func() (*v11.Event, error) + type WorkflowService_WatchEventsServer interface + Send func(*v11.Event) error + type WorkflowService_WatchWorkflowsClient interface + Recv func() (*WorkflowWatchEvent, error) + type WorkflowService_WatchWorkflowsServer interface + Send func(*WorkflowWatchEvent) error + type WorkflowService_WorkflowLogsClient interface + Recv func() (*LogEntry, error) + type WorkflowService_WorkflowLogsServer interface + Send func(*LogEntry) error + type WorkflowSetRequest struct + Message string + Name string + Namespace string + NodeFieldSelector string + OutputParameters string + Phase string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WorkflowSetRequest) Descriptor() ([]byte, []int) + func (*WorkflowSetRequest) ProtoMessage() + 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 (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 struct + Message string + Name string + Namespace string + NodeFieldSelector string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WorkflowStopRequest) Descriptor() ([]byte, []int) + func (*WorkflowStopRequest) ProtoMessage() + 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 (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 struct + Namespace string + ResourceKind string + ResourceName string + SubmitOptions *v1alpha1.SubmitOpts + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WorkflowSubmitRequest) Descriptor() ([]byte, []int) + func (*WorkflowSubmitRequest) ProtoMessage() + 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 (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 struct + Name string + Namespace string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WorkflowSuspendRequest) Descriptor() ([]byte, []int) + func (*WorkflowSuspendRequest) ProtoMessage() + 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 (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 struct + Name string + Namespace string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WorkflowTerminateRequest) Descriptor() ([]byte, []int) + func (*WorkflowTerminateRequest) ProtoMessage() + 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 (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 struct + Object *v1alpha1.Workflow + Type string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WorkflowWatchEvent) Descriptor() ([]byte, []int) + func (*WorkflowWatchEvent) ProtoMessage() + 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 (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 Other modules containing this package github.com/kostas-theo/argo-workflows