workflow

package
v2.5.0+incompatible Latest Latest
Warning

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

Go to latest
Published: Feb 19, 2020 License: Apache-2.0 Imports: 21 Imported by: 0

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.

func RegisterWorkflowServiceServer

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

Types

type LogEntry

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

func (*LogEntry) Descriptor

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

func (*LogEntry) GetContent

func (m *LogEntry) GetContent() 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) DeleteWorkflow

func (*UnimplementedWorkflowServiceServer) GetWorkflow

func (*UnimplementedWorkflowServiceServer) LintWorkflow

func (*UnimplementedWorkflowServiceServer) ListWorkflows

func (*UnimplementedWorkflowServiceServer) PodLogs

func (*UnimplementedWorkflowServiceServer) ResubmitWorkflow

func (*UnimplementedWorkflowServiceServer) ResumeWorkflow

func (*UnimplementedWorkflowServiceServer) RetryWorkflow

func (*UnimplementedWorkflowServiceServer) SuspendWorkflow

func (*UnimplementedWorkflowServiceServer) TerminateWorkflow

func (*UnimplementedWorkflowServiceServer) WatchWorkflows

type WatchWorkflowsRequest

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

func (*WatchWorkflowsRequest) Descriptor

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

func (*WatchWorkflowsRequest) GetListOptions

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

func (*WatchWorkflowsRequest) GetNamespace

func (m *WatchWorkflowsRequest) GetNamespace() string

func (*WatchWorkflowsRequest) Marshal

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

func (*WatchWorkflowsRequest) MarshalTo

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

func (*WatchWorkflowsRequest) MarshalToSizedBuffer

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

func (*WatchWorkflowsRequest) ProtoMessage

func (*WatchWorkflowsRequest) ProtoMessage()

func (*WatchWorkflowsRequest) Reset

func (m *WatchWorkflowsRequest) Reset()

func (*WatchWorkflowsRequest) Size

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

func (*WatchWorkflowsRequest) String

func (m *WatchWorkflowsRequest) String() string

func (*WatchWorkflowsRequest) Unmarshal

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

func (*WatchWorkflowsRequest) XXX_DiscardUnknown

func (m *WatchWorkflowsRequest) XXX_DiscardUnknown()

func (*WatchWorkflowsRequest) XXX_Marshal

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

func (*WatchWorkflowsRequest) XXX_Merge

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

func (*WatchWorkflowsRequest) XXX_Size

func (m *WatchWorkflowsRequest) XXX_Size() int

func (*WatchWorkflowsRequest) XXX_Unmarshal

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

type WorkflowCreateRequest

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

func (*WorkflowCreateRequest) Descriptor

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

func (*WorkflowCreateRequest) GetCreateOptions

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

func (*WorkflowCreateRequest) GetInstanceID

func (m *WorkflowCreateRequest) GetInstanceID() string

func (*WorkflowCreateRequest) GetNamespace

func (m *WorkflowCreateRequest) GetNamespace() string

func (*WorkflowCreateRequest) GetServerDryRun

func (m *WorkflowCreateRequest) GetServerDryRun() bool

func (*WorkflowCreateRequest) GetWorkflow

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

func (*WorkflowCreateRequest) Marshal

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

func (*WorkflowCreateRequest) MarshalTo

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

func (*WorkflowCreateRequest) MarshalToSizedBuffer

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

func (*WorkflowCreateRequest) ProtoMessage

func (*WorkflowCreateRequest) ProtoMessage()

func (*WorkflowCreateRequest) Reset

func (m *WorkflowCreateRequest) Reset()

func (*WorkflowCreateRequest) Size

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

func (*WorkflowCreateRequest) String

func (m *WorkflowCreateRequest) String() string

func (*WorkflowCreateRequest) Unmarshal

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

func (*WorkflowCreateRequest) XXX_DiscardUnknown

func (m *WorkflowCreateRequest) XXX_DiscardUnknown()

func (*WorkflowCreateRequest) XXX_Marshal

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

func (*WorkflowCreateRequest) XXX_Merge

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

func (*WorkflowCreateRequest) XXX_Size

func (m *WorkflowCreateRequest) XXX_Size() int

func (*WorkflowCreateRequest) XXX_Unmarshal

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

type WorkflowDeleteRequest

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

func (*WorkflowDeleteRequest) Descriptor

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

func (*WorkflowDeleteRequest) GetDeleteOptions

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

func (*WorkflowDeleteRequest) GetName

func (m *WorkflowDeleteRequest) GetName() string

func (*WorkflowDeleteRequest) GetNamespace

func (m *WorkflowDeleteRequest) GetNamespace() string

func (*WorkflowDeleteRequest) Marshal

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

func (*WorkflowDeleteRequest) MarshalTo

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

func (*WorkflowDeleteRequest) MarshalToSizedBuffer

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

func (*WorkflowDeleteRequest) ProtoMessage

func (*WorkflowDeleteRequest) ProtoMessage()

func (*WorkflowDeleteRequest) Reset

func (m *WorkflowDeleteRequest) Reset()

func (*WorkflowDeleteRequest) Size

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

func (*WorkflowDeleteRequest) String

func (m *WorkflowDeleteRequest) String() string

func (*WorkflowDeleteRequest) Unmarshal

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

func (*WorkflowDeleteRequest) XXX_DiscardUnknown

func (m *WorkflowDeleteRequest) XXX_DiscardUnknown()

func (*WorkflowDeleteRequest) XXX_Marshal

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

func (*WorkflowDeleteRequest) XXX_Merge

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

func (*WorkflowDeleteRequest) XXX_Size

func (m *WorkflowDeleteRequest) XXX_Size() int

func (*WorkflowDeleteRequest) XXX_Unmarshal

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

type WorkflowDeleteResponse

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

func (*WorkflowDeleteResponse) Descriptor

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

func (*WorkflowDeleteResponse) Marshal

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

func (*WorkflowDeleteResponse) MarshalTo

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

func (*WorkflowDeleteResponse) MarshalToSizedBuffer

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

func (*WorkflowDeleteResponse) ProtoMessage

func (*WorkflowDeleteResponse) ProtoMessage()

func (*WorkflowDeleteResponse) Reset

func (m *WorkflowDeleteResponse) Reset()

func (*WorkflowDeleteResponse) Size

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

func (*WorkflowDeleteResponse) String

func (m *WorkflowDeleteResponse) String() string

func (*WorkflowDeleteResponse) Unmarshal

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

func (*WorkflowDeleteResponse) XXX_DiscardUnknown

func (m *WorkflowDeleteResponse) XXX_DiscardUnknown()

func (*WorkflowDeleteResponse) XXX_Marshal

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

func (*WorkflowDeleteResponse) XXX_Merge

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

func (*WorkflowDeleteResponse) XXX_Size

func (m *WorkflowDeleteResponse) XXX_Size() int

func (*WorkflowDeleteResponse) XXX_Unmarshal

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

type WorkflowGetRequest

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

func (*WorkflowGetRequest) Descriptor

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

func (*WorkflowGetRequest) GetGetOptions

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

func (*WorkflowGetRequest) GetName

func (m *WorkflowGetRequest) GetName() string

func (*WorkflowGetRequest) GetNamespace

func (m *WorkflowGetRequest) GetNamespace() string

func (*WorkflowGetRequest) Marshal

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

func (*WorkflowGetRequest) MarshalTo

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

func (*WorkflowGetRequest) MarshalToSizedBuffer

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

func (*WorkflowGetRequest) ProtoMessage

func (*WorkflowGetRequest) ProtoMessage()

func (*WorkflowGetRequest) Reset

func (m *WorkflowGetRequest) Reset()

func (*WorkflowGetRequest) Size

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

func (*WorkflowGetRequest) String

func (m *WorkflowGetRequest) String() string

func (*WorkflowGetRequest) Unmarshal

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

func (*WorkflowGetRequest) XXX_DiscardUnknown

func (m *WorkflowGetRequest) XXX_DiscardUnknown()

func (*WorkflowGetRequest) XXX_Marshal

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

func (*WorkflowGetRequest) XXX_Merge

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

func (*WorkflowGetRequest) XXX_Size

func (m *WorkflowGetRequest) XXX_Size() int

func (*WorkflowGetRequest) XXX_Unmarshal

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

type WorkflowLintRequest

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

func (*WorkflowLintRequest) Descriptor

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

func (*WorkflowLintRequest) GetNamespace

func (m *WorkflowLintRequest) GetNamespace() string

func (*WorkflowLintRequest) GetWorkflow

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

func (*WorkflowLintRequest) Marshal

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

func (*WorkflowLintRequest) MarshalTo

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

func (*WorkflowLintRequest) MarshalToSizedBuffer

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

func (*WorkflowLintRequest) ProtoMessage

func (*WorkflowLintRequest) ProtoMessage()

func (*WorkflowLintRequest) Reset

func (m *WorkflowLintRequest) Reset()

func (*WorkflowLintRequest) Size

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

func (*WorkflowLintRequest) String

func (m *WorkflowLintRequest) String() string

func (*WorkflowLintRequest) Unmarshal

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

func (*WorkflowLintRequest) XXX_DiscardUnknown

func (m *WorkflowLintRequest) XXX_DiscardUnknown()

func (*WorkflowLintRequest) XXX_Marshal

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

func (*WorkflowLintRequest) XXX_Merge

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

func (*WorkflowLintRequest) XXX_Size

func (m *WorkflowLintRequest) XXX_Size() int

func (*WorkflowLintRequest) XXX_Unmarshal

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

type WorkflowListRequest

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

func (*WorkflowListRequest) Descriptor

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

func (*WorkflowListRequest) GetListOptions

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

func (*WorkflowListRequest) GetNamespace

func (m *WorkflowListRequest) GetNamespace() string

func (*WorkflowListRequest) Marshal

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

func (*WorkflowListRequest) MarshalTo

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

func (*WorkflowListRequest) MarshalToSizedBuffer

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

func (*WorkflowListRequest) ProtoMessage

func (*WorkflowListRequest) ProtoMessage()

func (*WorkflowListRequest) Reset

func (m *WorkflowListRequest) Reset()

func (*WorkflowListRequest) Size

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

func (*WorkflowListRequest) String

func (m *WorkflowListRequest) String() string

func (*WorkflowListRequest) Unmarshal

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

func (*WorkflowListRequest) XXX_DiscardUnknown

func (m *WorkflowListRequest) XXX_DiscardUnknown()

func (*WorkflowListRequest) XXX_Marshal

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

func (*WorkflowListRequest) XXX_Merge

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

func (*WorkflowListRequest) XXX_Size

func (m *WorkflowListRequest) XXX_Size() int

func (*WorkflowListRequest) XXX_Unmarshal

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

type WorkflowLogRequest

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

func (*WorkflowLogRequest) Descriptor

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

func (*WorkflowLogRequest) GetLogOptions

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

func (*WorkflowLogRequest) GetName

func (m *WorkflowLogRequest) GetName() string

func (*WorkflowLogRequest) GetNamespace

func (m *WorkflowLogRequest) GetNamespace() string

func (*WorkflowLogRequest) GetPodName

func (m *WorkflowLogRequest) GetPodName() string

func (*WorkflowLogRequest) Marshal

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

func (*WorkflowLogRequest) MarshalTo

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

func (*WorkflowLogRequest) MarshalToSizedBuffer

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

func (*WorkflowLogRequest) ProtoMessage

func (*WorkflowLogRequest) ProtoMessage()

func (*WorkflowLogRequest) Reset

func (m *WorkflowLogRequest) Reset()

func (*WorkflowLogRequest) Size

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

func (*WorkflowLogRequest) String

func (m *WorkflowLogRequest) String() string

func (*WorkflowLogRequest) Unmarshal

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

func (*WorkflowLogRequest) XXX_DiscardUnknown

func (m *WorkflowLogRequest) XXX_DiscardUnknown()

func (*WorkflowLogRequest) XXX_Marshal

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

func (*WorkflowLogRequest) XXX_Merge

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

func (*WorkflowLogRequest) XXX_Size

func (m *WorkflowLogRequest) XXX_Size() int

func (*WorkflowLogRequest) XXX_Unmarshal

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

type WorkflowResubmitRequest

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

func (*WorkflowResubmitRequest) Descriptor

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

func (*WorkflowResubmitRequest) GetMemoized

func (m *WorkflowResubmitRequest) GetMemoized() bool

func (*WorkflowResubmitRequest) GetName

func (m *WorkflowResubmitRequest) GetName() string

func (*WorkflowResubmitRequest) GetNamespace

func (m *WorkflowResubmitRequest) GetNamespace() string

func (*WorkflowResubmitRequest) Marshal

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

func (*WorkflowResubmitRequest) MarshalTo

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

func (*WorkflowResubmitRequest) MarshalToSizedBuffer

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

func (*WorkflowResubmitRequest) ProtoMessage

func (*WorkflowResubmitRequest) ProtoMessage()

func (*WorkflowResubmitRequest) Reset

func (m *WorkflowResubmitRequest) Reset()

func (*WorkflowResubmitRequest) Size

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

func (*WorkflowResubmitRequest) String

func (m *WorkflowResubmitRequest) String() string

func (*WorkflowResubmitRequest) Unmarshal

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

func (*WorkflowResubmitRequest) XXX_DiscardUnknown

func (m *WorkflowResubmitRequest) XXX_DiscardUnknown()

func (*WorkflowResubmitRequest) XXX_Marshal

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

func (*WorkflowResubmitRequest) XXX_Merge

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

func (*WorkflowResubmitRequest) XXX_Size

func (m *WorkflowResubmitRequest) XXX_Size() int

func (*WorkflowResubmitRequest) XXX_Unmarshal

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

type WorkflowResumeRequest

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

func (*WorkflowResumeRequest) Descriptor

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

func (*WorkflowResumeRequest) GetName

func (m *WorkflowResumeRequest) GetName() string

func (*WorkflowResumeRequest) GetNamespace

func (m *WorkflowResumeRequest) GetNamespace() string

func (*WorkflowResumeRequest) Marshal

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

func (*WorkflowResumeRequest) MarshalTo

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

func (*WorkflowResumeRequest) MarshalToSizedBuffer

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

func (*WorkflowResumeRequest) ProtoMessage

func (*WorkflowResumeRequest) ProtoMessage()

func (*WorkflowResumeRequest) Reset

func (m *WorkflowResumeRequest) Reset()

func (*WorkflowResumeRequest) Size

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

func (*WorkflowResumeRequest) String

func (m *WorkflowResumeRequest) String() string

func (*WorkflowResumeRequest) Unmarshal

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

func (*WorkflowResumeRequest) XXX_DiscardUnknown

func (m *WorkflowResumeRequest) XXX_DiscardUnknown()

func (*WorkflowResumeRequest) XXX_Marshal

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

func (*WorkflowResumeRequest) XXX_Merge

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

func (*WorkflowResumeRequest) XXX_Size

func (m *WorkflowResumeRequest) XXX_Size() int

func (*WorkflowResumeRequest) XXX_Unmarshal

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

type WorkflowRetryRequest

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

func (*WorkflowRetryRequest) Descriptor

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

func (*WorkflowRetryRequest) GetName

func (m *WorkflowRetryRequest) GetName() string

func (*WorkflowRetryRequest) GetNamespace

func (m *WorkflowRetryRequest) GetNamespace() string

func (*WorkflowRetryRequest) Marshal

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

func (*WorkflowRetryRequest) MarshalTo

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

func (*WorkflowRetryRequest) MarshalToSizedBuffer

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

func (*WorkflowRetryRequest) ProtoMessage

func (*WorkflowRetryRequest) ProtoMessage()

func (*WorkflowRetryRequest) Reset

func (m *WorkflowRetryRequest) Reset()

func (*WorkflowRetryRequest) Size

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

func (*WorkflowRetryRequest) String

func (m *WorkflowRetryRequest) String() string

func (*WorkflowRetryRequest) Unmarshal

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

func (*WorkflowRetryRequest) XXX_DiscardUnknown

func (m *WorkflowRetryRequest) XXX_DiscardUnknown()

func (*WorkflowRetryRequest) XXX_Marshal

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

func (*WorkflowRetryRequest) XXX_Merge

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

func (*WorkflowRetryRequest) XXX_Size

func (m *WorkflowRetryRequest) XXX_Size() int

func (*WorkflowRetryRequest) XXX_Unmarshal

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

type WorkflowServiceClient

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 WorkflowService_PodLogsClient

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

type WorkflowService_PodLogsServer

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

type WorkflowService_WatchWorkflowsClient

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

type WorkflowService_WatchWorkflowsServer

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

type WorkflowSuspendRequest

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

func (*WorkflowSuspendRequest) Descriptor

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

func (*WorkflowSuspendRequest) GetName

func (m *WorkflowSuspendRequest) GetName() string

func (*WorkflowSuspendRequest) GetNamespace

func (m *WorkflowSuspendRequest) GetNamespace() string

func (*WorkflowSuspendRequest) Marshal

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

func (*WorkflowSuspendRequest) MarshalTo

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

func (*WorkflowSuspendRequest) MarshalToSizedBuffer

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

func (*WorkflowSuspendRequest) ProtoMessage

func (*WorkflowSuspendRequest) ProtoMessage()

func (*WorkflowSuspendRequest) Reset

func (m *WorkflowSuspendRequest) Reset()

func (*WorkflowSuspendRequest) Size

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

func (*WorkflowSuspendRequest) String

func (m *WorkflowSuspendRequest) String() string

func (*WorkflowSuspendRequest) Unmarshal

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

func (*WorkflowSuspendRequest) XXX_DiscardUnknown

func (m *WorkflowSuspendRequest) XXX_DiscardUnknown()

func (*WorkflowSuspendRequest) XXX_Marshal

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

func (*WorkflowSuspendRequest) XXX_Merge

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

func (*WorkflowSuspendRequest) XXX_Size

func (m *WorkflowSuspendRequest) XXX_Size() int

func (*WorkflowSuspendRequest) XXX_Unmarshal

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

type WorkflowTerminateRequest

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

func (*WorkflowTerminateRequest) Descriptor

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

func (*WorkflowTerminateRequest) GetName

func (m *WorkflowTerminateRequest) GetName() string

func (*WorkflowTerminateRequest) GetNamespace

func (m *WorkflowTerminateRequest) GetNamespace() string

func (*WorkflowTerminateRequest) Marshal

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

func (*WorkflowTerminateRequest) MarshalTo

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

func (*WorkflowTerminateRequest) MarshalToSizedBuffer

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

func (*WorkflowTerminateRequest) ProtoMessage

func (*WorkflowTerminateRequest) ProtoMessage()

func (*WorkflowTerminateRequest) Reset

func (m *WorkflowTerminateRequest) Reset()

func (*WorkflowTerminateRequest) Size

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

func (*WorkflowTerminateRequest) String

func (m *WorkflowTerminateRequest) String() string

func (*WorkflowTerminateRequest) Unmarshal

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

func (*WorkflowTerminateRequest) XXX_DiscardUnknown

func (m *WorkflowTerminateRequest) XXX_DiscardUnknown()

func (*WorkflowTerminateRequest) XXX_Marshal

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

func (*WorkflowTerminateRequest) XXX_Merge

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

func (*WorkflowTerminateRequest) XXX_Size

func (m *WorkflowTerminateRequest) XXX_Size() int

func (*WorkflowTerminateRequest) XXX_Unmarshal

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

type WorkflowWatchEvent

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

func (*WorkflowWatchEvent) Descriptor

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

func (*WorkflowWatchEvent) GetObject

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

func (*WorkflowWatchEvent) GetType

func (m *WorkflowWatchEvent) GetType() string

func (*WorkflowWatchEvent) Marshal

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

func (*WorkflowWatchEvent) MarshalTo

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

func (*WorkflowWatchEvent) MarshalToSizedBuffer

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

func (*WorkflowWatchEvent) ProtoMessage

func (*WorkflowWatchEvent) ProtoMessage()

func (*WorkflowWatchEvent) Reset

func (m *WorkflowWatchEvent) Reset()

func (*WorkflowWatchEvent) Size

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

func (*WorkflowWatchEvent) String

func (m *WorkflowWatchEvent) String() string

func (*WorkflowWatchEvent) Unmarshal

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

func (*WorkflowWatchEvent) XXX_DiscardUnknown

func (m *WorkflowWatchEvent) XXX_DiscardUnknown()

func (*WorkflowWatchEvent) XXX_Marshal

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

func (*WorkflowWatchEvent) XXX_Merge

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

func (*WorkflowWatchEvent) XXX_Size

func (m *WorkflowWatchEvent) XXX_Size() int

func (*WorkflowWatchEvent) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL