workflow

package
v3.6.2 Latest Latest
Warning

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

 Go to latest Published: Dec 2, 2024 License: Apache-2.0 Imports: 21 Imported by: 31

Documentation

Overview

Package workflow is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthWorkflow        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowWorkflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupWorkflow = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterWorkflowServiceHandler 

func RegisterWorkflowServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterWorkflowServiceHandler registers the http handlers for service WorkflowService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterWorkflowServiceHandlerClient 

func RegisterWorkflowServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client WorkflowServiceClient) error

RegisterWorkflowServiceHandlerClient registers the http handlers for service WorkflowService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "WorkflowServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "WorkflowServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "WorkflowServiceClient" to call the correct interceptors.

func RegisterWorkflowServiceHandlerFromEndpoint 

func RegisterWorkflowServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterWorkflowServiceHandlerFromEndpoint is same as RegisterWorkflowServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterWorkflowServiceHandlerServer 

func RegisterWorkflowServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server WorkflowServiceServer) error

RegisterWorkflowServiceHandlerServer registers the http handlers for service WorkflowService to "mux". UnaryRPC :call WorkflowServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterWorkflowServiceHandlerFromEndpoint instead.

func RegisterWorkflowServiceServer 

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

Types

type LogEntry 

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

func (*LogEntry) Descriptor 

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

func (*LogEntry) GetContent 

func (m *LogEntry) GetContent() string

func (*LogEntry) GetPodName 

func (m *LogEntry) GetPodName() string

func (*LogEntry) Marshal 

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

func (*LogEntry) MarshalTo 

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

func (*LogEntry) MarshalToSizedBuffer 

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

func (*LogEntry) ProtoMessage 

func (*LogEntry) ProtoMessage()

func (*LogEntry) Reset 

func (m *LogEntry) Reset()

func (*LogEntry) Size 

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

func (*LogEntry) String 

func (m *LogEntry) String() string

func (*LogEntry) Unmarshal 

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

func (*LogEntry) XXX_DiscardUnknown 

func (m *LogEntry) XXX_DiscardUnknown()

func (*LogEntry) XXX_Marshal 

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

func (*LogEntry) XXX_Merge 

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

func (*LogEntry) XXX_Size 

func (m *LogEntry) XXX_Size() int

func (*LogEntry) XXX_Unmarshal 

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

type UnimplementedWorkflowServiceServer 

type UnimplementedWorkflowServiceServer struct {
}

UnimplementedWorkflowServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedWorkflowServiceServer) CreateWorkflow 

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

func (*UnimplementedWorkflowServiceServer) DeleteWorkflow 

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

func (*UnimplementedWorkflowServiceServer) GetWorkflow 

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

func (*UnimplementedWorkflowServiceServer) LintWorkflow 

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

func (*UnimplementedWorkflowServiceServer) ListWorkflows 

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

func (*UnimplementedWorkflowServiceServer) PodLogs 

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

func (*UnimplementedWorkflowServiceServer) ResubmitWorkflow 

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

func (*UnimplementedWorkflowServiceServer) ResumeWorkflow 

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

func (*UnimplementedWorkflowServiceServer) RetryWorkflow 

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

func (*UnimplementedWorkflowServiceServer) SetWorkflow 

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

func (*UnimplementedWorkflowServiceServer) StopWorkflow 

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

func (*UnimplementedWorkflowServiceServer) SubmitWorkflow 

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

func (*UnimplementedWorkflowServiceServer) SuspendWorkflow 

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

func (*UnimplementedWorkflowServiceServer) TerminateWorkflow 

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

func (*UnimplementedWorkflowServiceServer) WatchEvents 

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

func (*UnimplementedWorkflowServiceServer) WatchWorkflows 

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

func (*UnimplementedWorkflowServiceServer) WorkflowLogs 

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

type WatchEventsRequest 

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

func (*WatchEventsRequest) Descriptor 

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

func (*WatchEventsRequest) GetListOptions 

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

func (*WatchEventsRequest) GetNamespace 

func (m *WatchEventsRequest) GetNamespace() string

func (*WatchEventsRequest) Marshal 

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

func (*WatchEventsRequest) MarshalTo 

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

func (*WatchEventsRequest) MarshalToSizedBuffer 

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

func (*WatchEventsRequest) ProtoMessage 

func (*WatchEventsRequest) ProtoMessage()

func (*WatchEventsRequest) Reset 

func (m *WatchEventsRequest) Reset()

func (*WatchEventsRequest) Size 

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

func (*WatchEventsRequest) String 

func (m *WatchEventsRequest) String() string

func (*WatchEventsRequest) Unmarshal 

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

func (*WatchEventsRequest) XXX_DiscardUnknown 

func (m *WatchEventsRequest) XXX_DiscardUnknown()

func (*WatchEventsRequest) XXX_Marshal 

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

func (*WatchEventsRequest) XXX_Merge 

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

func (*WatchEventsRequest) XXX_Size 

func (m *WatchEventsRequest) XXX_Size() int

func (*WatchEventsRequest) XXX_Unmarshal 

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

type WatchWorkflowsRequest 

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

func (*WatchWorkflowsRequest) Descriptor 

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

func (*WatchWorkflowsRequest) GetFields added in v3.1.0 

func (m *WatchWorkflowsRequest) GetFields() string

func (*WatchWorkflowsRequest) GetListOptions 

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

func (*WatchWorkflowsRequest) GetNamespace 

func (m *WatchWorkflowsRequest) GetNamespace() string

func (*WatchWorkflowsRequest) Marshal 

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

func (*WatchWorkflowsRequest) MarshalTo 

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

func (*WatchWorkflowsRequest) MarshalToSizedBuffer 

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

func (*WatchWorkflowsRequest) ProtoMessage 

func (*WatchWorkflowsRequest) ProtoMessage()

func (*WatchWorkflowsRequest) Reset 

func (m *WatchWorkflowsRequest) Reset()

func (*WatchWorkflowsRequest) Size 

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

func (*WatchWorkflowsRequest) String 

func (m *WatchWorkflowsRequest) String() string

func (*WatchWorkflowsRequest) Unmarshal 

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

func (*WatchWorkflowsRequest) XXX_DiscardUnknown 

func (m *WatchWorkflowsRequest) XXX_DiscardUnknown()

func (*WatchWorkflowsRequest) XXX_Marshal 

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

func (*WatchWorkflowsRequest) XXX_Merge 

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

func (*WatchWorkflowsRequest) XXX_Size 

func (m *WatchWorkflowsRequest) XXX_Size() int

func (*WatchWorkflowsRequest) XXX_Unmarshal 

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

type WorkflowCreateRequest 

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

func (*WorkflowCreateRequest) Descriptor 

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

func (*WorkflowCreateRequest) GetCreateOptions 

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

func (*WorkflowCreateRequest) GetInstanceID deprecated 

func (m *WorkflowCreateRequest) GetInstanceID() string

Deprecated: Do not use.

func (*WorkflowCreateRequest) GetNamespace 

func (m *WorkflowCreateRequest) GetNamespace() string

func (*WorkflowCreateRequest) GetServerDryRun 

func (m *WorkflowCreateRequest) GetServerDryRun() bool

func (*WorkflowCreateRequest) GetWorkflow 

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

func (*WorkflowCreateRequest) Marshal 

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

func (*WorkflowCreateRequest) MarshalTo 

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

func (*WorkflowCreateRequest) MarshalToSizedBuffer 

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

func (*WorkflowCreateRequest) ProtoMessage 

func (*WorkflowCreateRequest) ProtoMessage()

func (*WorkflowCreateRequest) Reset 

func (m *WorkflowCreateRequest) Reset()

func (*WorkflowCreateRequest) Size 

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

func (*WorkflowCreateRequest) String 

func (m *WorkflowCreateRequest) String() string

func (*WorkflowCreateRequest) Unmarshal 

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

func (*WorkflowCreateRequest) XXX_DiscardUnknown 

func (m *WorkflowCreateRequest) XXX_DiscardUnknown()

func (*WorkflowCreateRequest) XXX_Marshal 

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

func (*WorkflowCreateRequest) XXX_Merge 

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

func (*WorkflowCreateRequest) XXX_Size 

func (m *WorkflowCreateRequest) XXX_Size() int

func (*WorkflowCreateRequest) XXX_Unmarshal 

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

type WorkflowDeleteRequest 

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

func (*WorkflowDeleteRequest) Descriptor 

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

func (*WorkflowDeleteRequest) GetDeleteOptions 

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

func (*WorkflowDeleteRequest) GetForce added in v3.4.0 

func (m *WorkflowDeleteRequest) GetForce() bool

func (*WorkflowDeleteRequest) GetName 

func (m *WorkflowDeleteRequest) GetName() string

func (*WorkflowDeleteRequest) GetNamespace 

func (m *WorkflowDeleteRequest) GetNamespace() string

func (*WorkflowDeleteRequest) Marshal 

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

func (*WorkflowDeleteRequest) MarshalTo 

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

func (*WorkflowDeleteRequest) MarshalToSizedBuffer 

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

func (*WorkflowDeleteRequest) ProtoMessage 

func (*WorkflowDeleteRequest) ProtoMessage()

func (*WorkflowDeleteRequest) Reset 

func (m *WorkflowDeleteRequest) Reset()

func (*WorkflowDeleteRequest) Size 

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

func (*WorkflowDeleteRequest) String 

func (m *WorkflowDeleteRequest) String() string

func (*WorkflowDeleteRequest) Unmarshal 

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

func (*WorkflowDeleteRequest) XXX_DiscardUnknown 

func (m *WorkflowDeleteRequest) XXX_DiscardUnknown()

func (*WorkflowDeleteRequest) XXX_Marshal 

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

func (*WorkflowDeleteRequest) XXX_Merge 

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

func (*WorkflowDeleteRequest) XXX_Size 

func (m *WorkflowDeleteRequest) XXX_Size() int

func (*WorkflowDeleteRequest) XXX_Unmarshal 

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

type WorkflowDeleteResponse 

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

func (*WorkflowDeleteResponse) Descriptor 

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

func (*WorkflowDeleteResponse) Marshal 

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

func (*WorkflowDeleteResponse) MarshalTo 

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

func (*WorkflowDeleteResponse) MarshalToSizedBuffer 

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

func (*WorkflowDeleteResponse) ProtoMessage 

func (*WorkflowDeleteResponse) ProtoMessage()

func (*WorkflowDeleteResponse) Reset 

func (m *WorkflowDeleteResponse) Reset()

func (*WorkflowDeleteResponse) Size 

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

func (*WorkflowDeleteResponse) String 

func (m *WorkflowDeleteResponse) String() string

func (*WorkflowDeleteResponse) Unmarshal 

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

func (*WorkflowDeleteResponse) XXX_DiscardUnknown 

func (m *WorkflowDeleteResponse) XXX_DiscardUnknown()

func (*WorkflowDeleteResponse) XXX_Marshal 

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

func (*WorkflowDeleteResponse) XXX_Merge 

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

func (*WorkflowDeleteResponse) XXX_Size 

func (m *WorkflowDeleteResponse) XXX_Size() int

func (*WorkflowDeleteResponse) XXX_Unmarshal 

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

type WorkflowGetRequest 

type WorkflowGetRequest struct {
	Name       string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace  string         `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	GetOptions *v1.GetOptions `protobuf:"bytes,3,opt,name=getOptions,proto3" json:"getOptions,omitempty"`
	// Fields to be included or excluded in the response. e.g. "spec,status.phase", "-status.nodes"
	Fields               string   `protobuf:"bytes,4,opt,name=fields,proto3" json:"fields,omitempty"`
	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"`
	// Filter type used for name filtering. Exact | Contains | Prefix. Default to Exact
	NameFilter           string   `protobuf:"bytes,4,opt,name=nameFilter,proto3" json:"nameFilter,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) GetNameFilter added in v3.6.0 

func (m *WorkflowListRequest) GetNameFilter() string

func (*WorkflowListRequest) GetNamespace 

func (m *WorkflowListRequest) GetNamespace() string

func (*WorkflowListRequest) Marshal 

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

func (*WorkflowListRequest) MarshalTo 

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

func (*WorkflowListRequest) MarshalToSizedBuffer 

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

func (*WorkflowListRequest) ProtoMessage 

func (*WorkflowListRequest) ProtoMessage()

func (*WorkflowListRequest) Reset 

func (m *WorkflowListRequest) Reset()

func (*WorkflowListRequest) Size 

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

func (*WorkflowListRequest) String 

func (m *WorkflowListRequest) String() string

func (*WorkflowListRequest) Unmarshal 

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

func (*WorkflowListRequest) XXX_DiscardUnknown 

func (m *WorkflowListRequest) XXX_DiscardUnknown()

func (*WorkflowListRequest) XXX_Marshal 

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

func (*WorkflowListRequest) XXX_Merge 

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

func (*WorkflowListRequest) XXX_Size 

func (m *WorkflowListRequest) XXX_Size() int

func (*WorkflowListRequest) XXX_Unmarshal 

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

type WorkflowLogRequest 

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

func (*WorkflowLogRequest) Descriptor 

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

func (*WorkflowLogRequest) GetGrep added in v3.1.0 

func (m *WorkflowLogRequest) GetGrep() string

func (*WorkflowLogRequest) GetLogOptions 

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

func (*WorkflowLogRequest) GetName 

func (m *WorkflowLogRequest) GetName() string

func (*WorkflowLogRequest) GetNamespace 

func (m *WorkflowLogRequest) GetNamespace() string

func (*WorkflowLogRequest) GetPodName 

func (m *WorkflowLogRequest) GetPodName() string

func (*WorkflowLogRequest) GetSelector added in v3.3.0 

func (m *WorkflowLogRequest) GetSelector() string

func (*WorkflowLogRequest) Marshal 

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

func (*WorkflowLogRequest) MarshalTo 

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

func (*WorkflowLogRequest) MarshalToSizedBuffer 

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

func (*WorkflowLogRequest) ProtoMessage 

func (*WorkflowLogRequest) ProtoMessage()

func (*WorkflowLogRequest) Reset 

func (m *WorkflowLogRequest) Reset()

func (*WorkflowLogRequest) Size 

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

func (*WorkflowLogRequest) String 

func (m *WorkflowLogRequest) String() string

func (*WorkflowLogRequest) Unmarshal 

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

func (*WorkflowLogRequest) XXX_DiscardUnknown 

func (m *WorkflowLogRequest) XXX_DiscardUnknown()

func (*WorkflowLogRequest) XXX_Marshal 

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

func (*WorkflowLogRequest) XXX_Merge 

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

func (*WorkflowLogRequest) XXX_Size 

func (m *WorkflowLogRequest) XXX_Size() int

func (*WorkflowLogRequest) XXX_Unmarshal 

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

type WorkflowResubmitRequest 

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

func (*WorkflowResubmitRequest) Descriptor 

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

func (*WorkflowResubmitRequest) GetMemoized 

func (m *WorkflowResubmitRequest) GetMemoized() bool

func (*WorkflowResubmitRequest) GetName 

func (m *WorkflowResubmitRequest) GetName() string

func (*WorkflowResubmitRequest) GetNamespace 

func (m *WorkflowResubmitRequest) GetNamespace() string

func (*WorkflowResubmitRequest) GetParameters added in v3.4.0 

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

func (*WorkflowResubmitRequest) Marshal 

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

func (*WorkflowResubmitRequest) MarshalTo 

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

func (*WorkflowResubmitRequest) MarshalToSizedBuffer 

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

func (*WorkflowResubmitRequest) ProtoMessage 

func (*WorkflowResubmitRequest) ProtoMessage()

func (*WorkflowResubmitRequest) Reset 

func (m *WorkflowResubmitRequest) Reset()

func (*WorkflowResubmitRequest) Size 

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

func (*WorkflowResubmitRequest) String 

func (m *WorkflowResubmitRequest) String() string

func (*WorkflowResubmitRequest) Unmarshal 

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

func (*WorkflowResubmitRequest) XXX_DiscardUnknown 

func (m *WorkflowResubmitRequest) XXX_DiscardUnknown()

func (*WorkflowResubmitRequest) XXX_Marshal 

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

func (*WorkflowResubmitRequest) XXX_Merge 

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

func (*WorkflowResubmitRequest) XXX_Size 

func (m *WorkflowResubmitRequest) XXX_Size() int

func (*WorkflowResubmitRequest) XXX_Unmarshal 

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

type WorkflowResumeRequest 

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

func (*WorkflowResumeRequest) Descriptor 

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

func (*WorkflowResumeRequest) GetName 

func (m *WorkflowResumeRequest) GetName() string

func (*WorkflowResumeRequest) GetNamespace 

func (m *WorkflowResumeRequest) GetNamespace() string

func (*WorkflowResumeRequest) GetNodeFieldSelector 

func (m *WorkflowResumeRequest) GetNodeFieldSelector() string

func (*WorkflowResumeRequest) Marshal 

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

func (*WorkflowResumeRequest) MarshalTo 

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

func (*WorkflowResumeRequest) MarshalToSizedBuffer 

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

func (*WorkflowResumeRequest) ProtoMessage 

func (*WorkflowResumeRequest) ProtoMessage()

func (*WorkflowResumeRequest) Reset 

func (m *WorkflowResumeRequest) Reset()

func (*WorkflowResumeRequest) Size 

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

func (*WorkflowResumeRequest) String 

func (m *WorkflowResumeRequest) String() string

func (*WorkflowResumeRequest) Unmarshal 

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

func (*WorkflowResumeRequest) XXX_DiscardUnknown 

func (m *WorkflowResumeRequest) XXX_DiscardUnknown()

func (*WorkflowResumeRequest) XXX_Marshal 

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

func (*WorkflowResumeRequest) XXX_Merge 

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

func (*WorkflowResumeRequest) XXX_Size 

func (m *WorkflowResumeRequest) XXX_Size() int

func (*WorkflowResumeRequest) XXX_Unmarshal 

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

type WorkflowRetryRequest 

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

func (*WorkflowRetryRequest) Descriptor 

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

func (*WorkflowRetryRequest) GetName 

func (m *WorkflowRetryRequest) GetName() string

func (*WorkflowRetryRequest) GetNamespace 

func (m *WorkflowRetryRequest) GetNamespace() string

func (*WorkflowRetryRequest) GetNodeFieldSelector 

func (m *WorkflowRetryRequest) GetNodeFieldSelector() string

func (*WorkflowRetryRequest) GetParameters added in v3.4.0 

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

func (*WorkflowRetryRequest) GetRestartSuccessful 

func (m *WorkflowRetryRequest) GetRestartSuccessful() bool

func (*WorkflowRetryRequest) Marshal 

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

func (*WorkflowRetryRequest) MarshalTo 

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

func (*WorkflowRetryRequest) MarshalToSizedBuffer 

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

func (*WorkflowRetryRequest) ProtoMessage 

func (*WorkflowRetryRequest) ProtoMessage()

func (*WorkflowRetryRequest) Reset 

func (m *WorkflowRetryRequest) Reset()

func (*WorkflowRetryRequest) Size 

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

func (*WorkflowRetryRequest) String 

func (m *WorkflowRetryRequest) String() string

func (*WorkflowRetryRequest) Unmarshal 

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

func (*WorkflowRetryRequest) XXX_DiscardUnknown 

func (m *WorkflowRetryRequest) XXX_DiscardUnknown()

func (*WorkflowRetryRequest) XXX_Marshal 

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

func (*WorkflowRetryRequest) XXX_Merge 

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

func (*WorkflowRetryRequest) XXX_Size 

func (m *WorkflowRetryRequest) XXX_Size() int

func (*WorkflowRetryRequest) XXX_Unmarshal 

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

type WorkflowServiceClient 

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

WorkflowServiceClient is the client API for WorkflowService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewWorkflowServiceClient 

func NewWorkflowServiceClient(cc *grpc.ClientConn) WorkflowServiceClient

type WorkflowServiceServer 

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

WorkflowServiceServer is the server API for WorkflowService service.

type WorkflowService_PodLogsClient 

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

type WorkflowService_PodLogsServer 

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

type WorkflowService_WatchEventsClient 

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

type WorkflowService_WatchEventsServer 

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

type WorkflowService_WatchWorkflowsClient 

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

type WorkflowService_WatchWorkflowsServer 

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

type WorkflowService_WorkflowLogsClient 

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

type WorkflowService_WorkflowLogsServer 

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

type WorkflowSetRequest 

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

func (*WorkflowSetRequest) Descriptor 

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

func (*WorkflowSetRequest) GetMessage 

func (m *WorkflowSetRequest) GetMessage() string

func (*WorkflowSetRequest) GetName 

func (m *WorkflowSetRequest) GetName() string

func (*WorkflowSetRequest) GetNamespace 

func (m *WorkflowSetRequest) GetNamespace() string

func (*WorkflowSetRequest) GetNodeFieldSelector 

func (m *WorkflowSetRequest) GetNodeFieldSelector() string

func (*WorkflowSetRequest) GetOutputParameters 

func (m *WorkflowSetRequest) GetOutputParameters() string

func (*WorkflowSetRequest) GetPhase 

func (m *WorkflowSetRequest) GetPhase() string

func (*WorkflowSetRequest) Marshal 

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

func (*WorkflowSetRequest) MarshalTo 

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

func (*WorkflowSetRequest) MarshalToSizedBuffer 

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

func (*WorkflowSetRequest) ProtoMessage 

func (*WorkflowSetRequest) ProtoMessage()

func (*WorkflowSetRequest) Reset 

func (m *WorkflowSetRequest) Reset()

func (*WorkflowSetRequest) Size 

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

func (*WorkflowSetRequest) String 

func (m *WorkflowSetRequest) String() string

func (*WorkflowSetRequest) Unmarshal 

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

func (*WorkflowSetRequest) XXX_DiscardUnknown 

func (m *WorkflowSetRequest) XXX_DiscardUnknown()

func (*WorkflowSetRequest) XXX_Marshal 

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

func (*WorkflowSetRequest) XXX_Merge 

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

func (*WorkflowSetRequest) XXX_Size 

func (m *WorkflowSetRequest) XXX_Size() int

func (*WorkflowSetRequest) XXX_Unmarshal 

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

type WorkflowStopRequest 

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

func (*WorkflowStopRequest) Descriptor 

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

func (*WorkflowStopRequest) GetMessage 

func (m *WorkflowStopRequest) GetMessage() string

func (*WorkflowStopRequest) GetName 

func (m *WorkflowStopRequest) GetName() string

func (*WorkflowStopRequest) GetNamespace 

func (m *WorkflowStopRequest) GetNamespace() string

func (*WorkflowStopRequest) GetNodeFieldSelector 

func (m *WorkflowStopRequest) GetNodeFieldSelector() string

func (*WorkflowStopRequest) Marshal 

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

func (*WorkflowStopRequest) MarshalTo 

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

func (*WorkflowStopRequest) MarshalToSizedBuffer 

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

func (*WorkflowStopRequest) ProtoMessage 

func (*WorkflowStopRequest) ProtoMessage()

func (*WorkflowStopRequest) Reset 

func (m *WorkflowStopRequest) Reset()

func (*WorkflowStopRequest) Size 

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

func (*WorkflowStopRequest) String 

func (m *WorkflowStopRequest) String() string

func (*WorkflowStopRequest) Unmarshal 

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

func (*WorkflowStopRequest) XXX_DiscardUnknown 

func (m *WorkflowStopRequest) XXX_DiscardUnknown()

func (*WorkflowStopRequest) XXX_Marshal 

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

func (*WorkflowStopRequest) XXX_Merge 

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

func (*WorkflowStopRequest) XXX_Size 

func (m *WorkflowStopRequest) XXX_Size() int

func (*WorkflowStopRequest) XXX_Unmarshal 

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

type WorkflowSubmitRequest 

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

func (*WorkflowSubmitRequest) Descriptor 

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

func (*WorkflowSubmitRequest) GetNamespace 

func (m *WorkflowSubmitRequest) GetNamespace() string

func (*WorkflowSubmitRequest) GetResourceKind 

func (m *WorkflowSubmitRequest) GetResourceKind() string

func (*WorkflowSubmitRequest) GetResourceName 

func (m *WorkflowSubmitRequest) GetResourceName() string

func (*WorkflowSubmitRequest) GetSubmitOptions 

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

func (*WorkflowSubmitRequest) Marshal 

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

func (*WorkflowSubmitRequest) MarshalTo 

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

func (*WorkflowSubmitRequest) MarshalToSizedBuffer 

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

func (*WorkflowSubmitRequest) ProtoMessage 

func (*WorkflowSubmitRequest) ProtoMessage()

func (*WorkflowSubmitRequest) Reset 

func (m *WorkflowSubmitRequest) Reset()

func (*WorkflowSubmitRequest) Size 

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

func (*WorkflowSubmitRequest) String 

func (m *WorkflowSubmitRequest) String() string

func (*WorkflowSubmitRequest) Unmarshal 

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

func (*WorkflowSubmitRequest) XXX_DiscardUnknown 

func (m *WorkflowSubmitRequest) XXX_DiscardUnknown()

func (*WorkflowSubmitRequest) XXX_Marshal 

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

func (*WorkflowSubmitRequest) XXX_Merge 

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

func (*WorkflowSubmitRequest) XXX_Size 

func (m *WorkflowSubmitRequest) XXX_Size() int

func (*WorkflowSubmitRequest) XXX_Unmarshal 

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

type WorkflowSuspendRequest 

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

func (*WorkflowSuspendRequest) Descriptor 

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

func (*WorkflowSuspendRequest) GetName 

func (m *WorkflowSuspendRequest) GetName() string

func (*WorkflowSuspendRequest) GetNamespace 

func (m *WorkflowSuspendRequest) GetNamespace() string

func (*WorkflowSuspendRequest) Marshal 

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

func (*WorkflowSuspendRequest) MarshalTo 

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

func (*WorkflowSuspendRequest) MarshalToSizedBuffer 

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

func (*WorkflowSuspendRequest) ProtoMessage 

func (*WorkflowSuspendRequest) ProtoMessage()

func (*WorkflowSuspendRequest) Reset 

func (m *WorkflowSuspendRequest) Reset()

func (*WorkflowSuspendRequest) Size 

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

func (*WorkflowSuspendRequest) String 

func (m *WorkflowSuspendRequest) String() string

func (*WorkflowSuspendRequest) Unmarshal 

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

func (*WorkflowSuspendRequest) XXX_DiscardUnknown 

func (m *WorkflowSuspendRequest) XXX_DiscardUnknown()

func (*WorkflowSuspendRequest) XXX_Marshal 

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

func (*WorkflowSuspendRequest) XXX_Merge 

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

func (*WorkflowSuspendRequest) XXX_Size 

func (m *WorkflowSuspendRequest) XXX_Size() int

func (*WorkflowSuspendRequest) XXX_Unmarshal 

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

type WorkflowTerminateRequest 

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

func (*WorkflowTerminateRequest) Descriptor 

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

func (*WorkflowTerminateRequest) GetName 

func (m *WorkflowTerminateRequest) GetName() string

func (*WorkflowTerminateRequest) GetNamespace 

func (m *WorkflowTerminateRequest) GetNamespace() string

func (*WorkflowTerminateRequest) Marshal 

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

func (*WorkflowTerminateRequest) MarshalTo 

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

func (*WorkflowTerminateRequest) MarshalToSizedBuffer 

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

func (*WorkflowTerminateRequest) ProtoMessage 

func (*WorkflowTerminateRequest) ProtoMessage()

func (*WorkflowTerminateRequest) Reset 

func (m *WorkflowTerminateRequest) Reset()

func (*WorkflowTerminateRequest) Size 

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

func (*WorkflowTerminateRequest) String 

func (m *WorkflowTerminateRequest) String() string

func (*WorkflowTerminateRequest) Unmarshal 

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

func (*WorkflowTerminateRequest) XXX_DiscardUnknown 

func (m *WorkflowTerminateRequest) XXX_DiscardUnknown()

func (*WorkflowTerminateRequest) XXX_Marshal 

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

func (*WorkflowTerminateRequest) XXX_Merge 

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

func (*WorkflowTerminateRequest) XXX_Size 

func (m *WorkflowTerminateRequest) XXX_Size() int

func (*WorkflowTerminateRequest) XXX_Unmarshal 

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

type WorkflowWatchEvent 

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

func (*WorkflowWatchEvent) Descriptor 

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

func (*WorkflowWatchEvent) GetObject 

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

func (*WorkflowWatchEvent) GetType 

func (m *WorkflowWatchEvent) GetType() string

func (*WorkflowWatchEvent) Marshal 

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

func (*WorkflowWatchEvent) MarshalTo 

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

func (*WorkflowWatchEvent) MarshalToSizedBuffer 

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

func (*WorkflowWatchEvent) ProtoMessage 

func (*WorkflowWatchEvent) ProtoMessage()

func (*WorkflowWatchEvent) Reset 

func (m *WorkflowWatchEvent) Reset()

func (*WorkflowWatchEvent) Size 

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

func (*WorkflowWatchEvent) String 

func (m *WorkflowWatchEvent) String() string

func (*WorkflowWatchEvent) Unmarshal 

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

func (*WorkflowWatchEvent) XXX_DiscardUnknown 

func (m *WorkflowWatchEvent) XXX_DiscardUnknown()

func (*WorkflowWatchEvent) XXX_Marshal 

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

func (*WorkflowWatchEvent) XXX_Merge 

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

func (*WorkflowWatchEvent) XXX_Size 

func (m *WorkflowWatchEvent) XXX_Size() int

func (*WorkflowWatchEvent) XXX_Unmarshal 

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.