workflowarchive

package
v3.5.4 Latest Latest
Warning

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

 Go to latest Published: Jan 14, 2024 License: Apache-2.0 Imports: 19 Imported by: 10

Documentation

Overview

Package workflowarchive is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthWorkflowArchive        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowWorkflowArchive          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupWorkflowArchive = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterArchivedWorkflowServiceHandler 

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

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

func RegisterArchivedWorkflowServiceHandlerClient 

func RegisterArchivedWorkflowServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ArchivedWorkflowServiceClient) error

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

func RegisterArchivedWorkflowServiceHandlerFromEndpoint 

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

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

func RegisterArchivedWorkflowServiceHandlerServer 

func RegisterArchivedWorkflowServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ArchivedWorkflowServiceServer) error

RegisterArchivedWorkflowServiceHandlerServer registers the http handlers for service ArchivedWorkflowService to "mux". UnaryRPC :call ArchivedWorkflowServiceServer 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 RegisterArchivedWorkflowServiceHandlerFromEndpoint instead.

func RegisterArchivedWorkflowServiceServer 

func RegisterArchivedWorkflowServiceServer(s *grpc.Server, srv ArchivedWorkflowServiceServer)

Types

type ArchivedWorkflowDeletedResponse 

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

func (*ArchivedWorkflowDeletedResponse) Descriptor 

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

func (*ArchivedWorkflowDeletedResponse) Marshal 

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

func (*ArchivedWorkflowDeletedResponse) MarshalTo 

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

func (*ArchivedWorkflowDeletedResponse) MarshalToSizedBuffer 

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

func (*ArchivedWorkflowDeletedResponse) ProtoMessage 

func (*ArchivedWorkflowDeletedResponse) ProtoMessage()

func (*ArchivedWorkflowDeletedResponse) Reset 

func (m *ArchivedWorkflowDeletedResponse) Reset()

func (*ArchivedWorkflowDeletedResponse) Size 

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

func (*ArchivedWorkflowDeletedResponse) String 

func (m *ArchivedWorkflowDeletedResponse) String() string

func (*ArchivedWorkflowDeletedResponse) Unmarshal 

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

func (*ArchivedWorkflowDeletedResponse) XXX_DiscardUnknown 

func (m *ArchivedWorkflowDeletedResponse) XXX_DiscardUnknown()

func (*ArchivedWorkflowDeletedResponse) XXX_Marshal 

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

func (*ArchivedWorkflowDeletedResponse) XXX_Merge 

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

func (*ArchivedWorkflowDeletedResponse) XXX_Size 

func (m *ArchivedWorkflowDeletedResponse) XXX_Size() int

func (*ArchivedWorkflowDeletedResponse) XXX_Unmarshal 

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

type ArchivedWorkflowServiceClient 

type ArchivedWorkflowServiceClient interface {
	ListArchivedWorkflows(ctx context.Context, in *ListArchivedWorkflowsRequest, opts ...grpc.CallOption) (*v1alpha1.WorkflowList, error)
	GetArchivedWorkflow(ctx context.Context, in *GetArchivedWorkflowRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error)
	DeleteArchivedWorkflow(ctx context.Context, in *DeleteArchivedWorkflowRequest, opts ...grpc.CallOption) (*ArchivedWorkflowDeletedResponse, error)
	ListArchivedWorkflowLabelKeys(ctx context.Context, in *ListArchivedWorkflowLabelKeysRequest, opts ...grpc.CallOption) (*v1alpha1.LabelKeys, error)
	ListArchivedWorkflowLabelValues(ctx context.Context, in *ListArchivedWorkflowLabelValuesRequest, opts ...grpc.CallOption) (*v1alpha1.LabelValues, error)
	RetryArchivedWorkflow(ctx context.Context, in *RetryArchivedWorkflowRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error)
	ResubmitArchivedWorkflow(ctx context.Context, in *ResubmitArchivedWorkflowRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error)
}

ArchivedWorkflowServiceClient is the client API for ArchivedWorkflowService service.

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

func NewArchivedWorkflowServiceClient 

func NewArchivedWorkflowServiceClient(cc *grpc.ClientConn) ArchivedWorkflowServiceClient

type ArchivedWorkflowServiceServer 

type ArchivedWorkflowServiceServer interface {
	ListArchivedWorkflows(context.Context, *ListArchivedWorkflowsRequest) (*v1alpha1.WorkflowList, error)
	GetArchivedWorkflow(context.Context, *GetArchivedWorkflowRequest) (*v1alpha1.Workflow, error)
	DeleteArchivedWorkflow(context.Context, *DeleteArchivedWorkflowRequest) (*ArchivedWorkflowDeletedResponse, error)
	ListArchivedWorkflowLabelKeys(context.Context, *ListArchivedWorkflowLabelKeysRequest) (*v1alpha1.LabelKeys, error)
	ListArchivedWorkflowLabelValues(context.Context, *ListArchivedWorkflowLabelValuesRequest) (*v1alpha1.LabelValues, error)
	RetryArchivedWorkflow(context.Context, *RetryArchivedWorkflowRequest) (*v1alpha1.Workflow, error)
	ResubmitArchivedWorkflow(context.Context, *ResubmitArchivedWorkflowRequest) (*v1alpha1.Workflow, error)
}

ArchivedWorkflowServiceServer is the server API for ArchivedWorkflowService service.

type DeleteArchivedWorkflowRequest 

type DeleteArchivedWorkflowRequest struct {
	Uid                  string   `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,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 (*DeleteArchivedWorkflowRequest) Descriptor 

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

func (*DeleteArchivedWorkflowRequest) GetNamespace added in v3.4.5 

func (m *DeleteArchivedWorkflowRequest) GetNamespace() string

func (*DeleteArchivedWorkflowRequest) GetUid 

func (m *DeleteArchivedWorkflowRequest) GetUid() string

func (*DeleteArchivedWorkflowRequest) Marshal 

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

func (*DeleteArchivedWorkflowRequest) MarshalTo 

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

func (*DeleteArchivedWorkflowRequest) MarshalToSizedBuffer 

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

func (*DeleteArchivedWorkflowRequest) ProtoMessage 

func (*DeleteArchivedWorkflowRequest) ProtoMessage()

func (*DeleteArchivedWorkflowRequest) Reset 

func (m *DeleteArchivedWorkflowRequest) Reset()

func (*DeleteArchivedWorkflowRequest) Size 

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

func (*DeleteArchivedWorkflowRequest) String 

func (m *DeleteArchivedWorkflowRequest) String() string

func (*DeleteArchivedWorkflowRequest) Unmarshal 

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

func (*DeleteArchivedWorkflowRequest) XXX_DiscardUnknown 

func (m *DeleteArchivedWorkflowRequest) XXX_DiscardUnknown()

func (*DeleteArchivedWorkflowRequest) XXX_Marshal 

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

func (*DeleteArchivedWorkflowRequest) XXX_Merge 

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

func (*DeleteArchivedWorkflowRequest) XXX_Size 

func (m *DeleteArchivedWorkflowRequest) XXX_Size() int

func (*DeleteArchivedWorkflowRequest) XXX_Unmarshal 

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

type GetArchivedWorkflowRequest 

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

func (*GetArchivedWorkflowRequest) Descriptor 

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

func (*GetArchivedWorkflowRequest) GetName added in v3.5.0 

func (m *GetArchivedWorkflowRequest) GetName() string

func (*GetArchivedWorkflowRequest) GetNamespace added in v3.4.5 

func (m *GetArchivedWorkflowRequest) GetNamespace() string

func (*GetArchivedWorkflowRequest) GetUid 

func (m *GetArchivedWorkflowRequest) GetUid() string

func (*GetArchivedWorkflowRequest) Marshal 

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

func (*GetArchivedWorkflowRequest) MarshalTo 

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

func (*GetArchivedWorkflowRequest) MarshalToSizedBuffer 

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

func (*GetArchivedWorkflowRequest) ProtoMessage 

func (*GetArchivedWorkflowRequest) ProtoMessage()

func (*GetArchivedWorkflowRequest) Reset 

func (m *GetArchivedWorkflowRequest) Reset()

func (*GetArchivedWorkflowRequest) Size 

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

func (*GetArchivedWorkflowRequest) String 

func (m *GetArchivedWorkflowRequest) String() string

func (*GetArchivedWorkflowRequest) Unmarshal 

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

func (*GetArchivedWorkflowRequest) XXX_DiscardUnknown 

func (m *GetArchivedWorkflowRequest) XXX_DiscardUnknown()

func (*GetArchivedWorkflowRequest) XXX_Marshal 

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

func (*GetArchivedWorkflowRequest) XXX_Merge 

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

func (*GetArchivedWorkflowRequest) XXX_Size 

func (m *GetArchivedWorkflowRequest) XXX_Size() int

func (*GetArchivedWorkflowRequest) XXX_Unmarshal 

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

type ListArchivedWorkflowLabelKeysRequest added in v3.3.0 

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

func (*ListArchivedWorkflowLabelKeysRequest) Descriptor added in v3.3.0 

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

func (*ListArchivedWorkflowLabelKeysRequest) GetNamespace added in v3.4.5 

func (m *ListArchivedWorkflowLabelKeysRequest) GetNamespace() string

func (*ListArchivedWorkflowLabelKeysRequest) Marshal added in v3.3.0 

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

func (*ListArchivedWorkflowLabelKeysRequest) MarshalTo added in v3.3.0 

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

func (*ListArchivedWorkflowLabelKeysRequest) MarshalToSizedBuffer added in v3.3.0 

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

func (*ListArchivedWorkflowLabelKeysRequest) ProtoMessage added in v3.3.0 

func (*ListArchivedWorkflowLabelKeysRequest) ProtoMessage()

func (*ListArchivedWorkflowLabelKeysRequest) Reset added in v3.3.0 

func (m *ListArchivedWorkflowLabelKeysRequest) Reset()

func (*ListArchivedWorkflowLabelKeysRequest) Size added in v3.3.0 

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

func (*ListArchivedWorkflowLabelKeysRequest) String added in v3.3.0 

func (m *ListArchivedWorkflowLabelKeysRequest) String() string

func (*ListArchivedWorkflowLabelKeysRequest) Unmarshal added in v3.3.0 

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

func (*ListArchivedWorkflowLabelKeysRequest) XXX_DiscardUnknown added in v3.3.0 

func (m *ListArchivedWorkflowLabelKeysRequest) XXX_DiscardUnknown()

func (*ListArchivedWorkflowLabelKeysRequest) XXX_Marshal added in v3.3.0 

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

func (*ListArchivedWorkflowLabelKeysRequest) XXX_Merge added in v3.3.0 

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

func (*ListArchivedWorkflowLabelKeysRequest) XXX_Size added in v3.3.0 

func (m *ListArchivedWorkflowLabelKeysRequest) XXX_Size() int

func (*ListArchivedWorkflowLabelKeysRequest) XXX_Unmarshal added in v3.3.0 

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

type ListArchivedWorkflowLabelValuesRequest added in v3.3.0 

type ListArchivedWorkflowLabelValuesRequest struct {
	ListOptions          *v1.ListOptions `protobuf:"bytes,1,opt,name=listOptions,proto3" json:"listOptions,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 (*ListArchivedWorkflowLabelValuesRequest) Descriptor added in v3.3.0 

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

func (*ListArchivedWorkflowLabelValuesRequest) GetListOptions added in v3.3.0 

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

func (*ListArchivedWorkflowLabelValuesRequest) GetNamespace added in v3.4.5 

func (m *ListArchivedWorkflowLabelValuesRequest) GetNamespace() string

func (*ListArchivedWorkflowLabelValuesRequest) Marshal added in v3.3.0 

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

func (*ListArchivedWorkflowLabelValuesRequest) MarshalTo added in v3.3.0 

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

func (*ListArchivedWorkflowLabelValuesRequest) MarshalToSizedBuffer added in v3.3.0 

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

func (*ListArchivedWorkflowLabelValuesRequest) ProtoMessage added in v3.3.0 

func (*ListArchivedWorkflowLabelValuesRequest) ProtoMessage()

func (*ListArchivedWorkflowLabelValuesRequest) Reset added in v3.3.0 

func (m *ListArchivedWorkflowLabelValuesRequest) Reset()

func (*ListArchivedWorkflowLabelValuesRequest) Size added in v3.3.0 

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

func (*ListArchivedWorkflowLabelValuesRequest) String added in v3.3.0 

func (m *ListArchivedWorkflowLabelValuesRequest) String() string

func (*ListArchivedWorkflowLabelValuesRequest) Unmarshal added in v3.3.0 

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

func (*ListArchivedWorkflowLabelValuesRequest) XXX_DiscardUnknown added in v3.3.0 

func (m *ListArchivedWorkflowLabelValuesRequest) XXX_DiscardUnknown()

func (*ListArchivedWorkflowLabelValuesRequest) XXX_Marshal added in v3.3.0 

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

func (*ListArchivedWorkflowLabelValuesRequest) XXX_Merge added in v3.3.0 

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

func (*ListArchivedWorkflowLabelValuesRequest) XXX_Size added in v3.3.0 

func (m *ListArchivedWorkflowLabelValuesRequest) XXX_Size() int

func (*ListArchivedWorkflowLabelValuesRequest) XXX_Unmarshal added in v3.3.0 

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

type ListArchivedWorkflowsRequest 

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

func (*ListArchivedWorkflowsRequest) Descriptor 

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

func (*ListArchivedWorkflowsRequest) GetListOptions 

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

func (*ListArchivedWorkflowsRequest) GetNamePrefix added in v3.3.0 

func (m *ListArchivedWorkflowsRequest) GetNamePrefix() string

func (*ListArchivedWorkflowsRequest) GetNamespace added in v3.4.5 

func (m *ListArchivedWorkflowsRequest) GetNamespace() string

func (*ListArchivedWorkflowsRequest) Marshal 

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

func (*ListArchivedWorkflowsRequest) MarshalTo 

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

func (*ListArchivedWorkflowsRequest) MarshalToSizedBuffer 

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

func (*ListArchivedWorkflowsRequest) ProtoMessage 

func (*ListArchivedWorkflowsRequest) ProtoMessage()

func (*ListArchivedWorkflowsRequest) Reset 

func (m *ListArchivedWorkflowsRequest) Reset()

func (*ListArchivedWorkflowsRequest) Size 

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

func (*ListArchivedWorkflowsRequest) String 

func (m *ListArchivedWorkflowsRequest) String() string

func (*ListArchivedWorkflowsRequest) Unmarshal 

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

func (*ListArchivedWorkflowsRequest) XXX_DiscardUnknown 

func (m *ListArchivedWorkflowsRequest) XXX_DiscardUnknown()

func (*ListArchivedWorkflowsRequest) XXX_Marshal 

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

func (*ListArchivedWorkflowsRequest) XXX_Merge 

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

func (*ListArchivedWorkflowsRequest) XXX_Size 

func (m *ListArchivedWorkflowsRequest) XXX_Size() int

func (*ListArchivedWorkflowsRequest) XXX_Unmarshal 

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

type ResubmitArchivedWorkflowRequest added in v3.4.0 

type ResubmitArchivedWorkflowRequest struct {
	Uid                  string   `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            string   `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Memoized             bool     `protobuf:"varint,4,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 (*ResubmitArchivedWorkflowRequest) Descriptor added in v3.4.0 

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

func (*ResubmitArchivedWorkflowRequest) GetMemoized added in v3.4.0 

func (m *ResubmitArchivedWorkflowRequest) GetMemoized() bool

func (*ResubmitArchivedWorkflowRequest) GetName added in v3.4.0 

func (m *ResubmitArchivedWorkflowRequest) GetName() string

func (*ResubmitArchivedWorkflowRequest) GetNamespace added in v3.4.0 

func (m *ResubmitArchivedWorkflowRequest) GetNamespace() string

func (*ResubmitArchivedWorkflowRequest) GetParameters added in v3.4.0 

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

func (*ResubmitArchivedWorkflowRequest) GetUid added in v3.4.0 

func (m *ResubmitArchivedWorkflowRequest) GetUid() string

func (*ResubmitArchivedWorkflowRequest) Marshal added in v3.4.0 

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

func (*ResubmitArchivedWorkflowRequest) MarshalTo added in v3.4.0 

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

func (*ResubmitArchivedWorkflowRequest) MarshalToSizedBuffer added in v3.4.0 

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

func (*ResubmitArchivedWorkflowRequest) ProtoMessage added in v3.4.0 

func (*ResubmitArchivedWorkflowRequest) ProtoMessage()

func (*ResubmitArchivedWorkflowRequest) Reset added in v3.4.0 

func (m *ResubmitArchivedWorkflowRequest) Reset()

func (*ResubmitArchivedWorkflowRequest) Size added in v3.4.0 

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

func (*ResubmitArchivedWorkflowRequest) String added in v3.4.0 

func (m *ResubmitArchivedWorkflowRequest) String() string

func (*ResubmitArchivedWorkflowRequest) Unmarshal added in v3.4.0 

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

func (*ResubmitArchivedWorkflowRequest) XXX_DiscardUnknown added in v3.4.0 

func (m *ResubmitArchivedWorkflowRequest) XXX_DiscardUnknown()

func (*ResubmitArchivedWorkflowRequest) XXX_Marshal added in v3.4.0 

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

func (*ResubmitArchivedWorkflowRequest) XXX_Merge added in v3.4.0 

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

func (*ResubmitArchivedWorkflowRequest) XXX_Size added in v3.4.0 

func (m *ResubmitArchivedWorkflowRequest) XXX_Size() int

func (*ResubmitArchivedWorkflowRequest) XXX_Unmarshal added in v3.4.0 

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

type RetryArchivedWorkflowRequest added in v3.4.0 

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

func (*RetryArchivedWorkflowRequest) Descriptor added in v3.4.0 

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

func (*RetryArchivedWorkflowRequest) GetName added in v3.4.0 

func (m *RetryArchivedWorkflowRequest) GetName() string

func (*RetryArchivedWorkflowRequest) GetNamespace added in v3.4.0 

func (m *RetryArchivedWorkflowRequest) GetNamespace() string

func (*RetryArchivedWorkflowRequest) GetNodeFieldSelector added in v3.4.0 

func (m *RetryArchivedWorkflowRequest) GetNodeFieldSelector() string

func (*RetryArchivedWorkflowRequest) GetParameters added in v3.4.0 

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

func (*RetryArchivedWorkflowRequest) GetRestartSuccessful added in v3.4.0 

func (m *RetryArchivedWorkflowRequest) GetRestartSuccessful() bool

func (*RetryArchivedWorkflowRequest) GetUid added in v3.4.0 

func (m *RetryArchivedWorkflowRequest) GetUid() string

func (*RetryArchivedWorkflowRequest) Marshal added in v3.4.0 

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

func (*RetryArchivedWorkflowRequest) MarshalTo added in v3.4.0 

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

func (*RetryArchivedWorkflowRequest) MarshalToSizedBuffer added in v3.4.0 

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

func (*RetryArchivedWorkflowRequest) ProtoMessage added in v3.4.0 

func (*RetryArchivedWorkflowRequest) ProtoMessage()

func (*RetryArchivedWorkflowRequest) Reset added in v3.4.0 

func (m *RetryArchivedWorkflowRequest) Reset()

func (*RetryArchivedWorkflowRequest) Size added in v3.4.0 

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

func (*RetryArchivedWorkflowRequest) String added in v3.4.0 

func (m *RetryArchivedWorkflowRequest) String() string

func (*RetryArchivedWorkflowRequest) Unmarshal added in v3.4.0 

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

func (*RetryArchivedWorkflowRequest) XXX_DiscardUnknown added in v3.4.0 

func (m *RetryArchivedWorkflowRequest) XXX_DiscardUnknown()

func (*RetryArchivedWorkflowRequest) XXX_Marshal added in v3.4.0 

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

func (*RetryArchivedWorkflowRequest) XXX_Merge added in v3.4.0 

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

func (*RetryArchivedWorkflowRequest) XXX_Size added in v3.4.0 

func (m *RetryArchivedWorkflowRequest) XXX_Size() int

func (*RetryArchivedWorkflowRequest) XXX_Unmarshal added in v3.4.0 

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

type UnimplementedArchivedWorkflowServiceServer 

type UnimplementedArchivedWorkflowServiceServer struct {
}

UnimplementedArchivedWorkflowServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedArchivedWorkflowServiceServer) DeleteArchivedWorkflow 

func (*UnimplementedArchivedWorkflowServiceServer) DeleteArchivedWorkflow(ctx context.Context, req *DeleteArchivedWorkflowRequest) (*ArchivedWorkflowDeletedResponse, error)

func (*UnimplementedArchivedWorkflowServiceServer) GetArchivedWorkflow 

func (*UnimplementedArchivedWorkflowServiceServer) GetArchivedWorkflow(ctx context.Context, req *GetArchivedWorkflowRequest) (*v1alpha1.Workflow, error)

func (*UnimplementedArchivedWorkflowServiceServer) ListArchivedWorkflowLabelKeys added in v3.3.0 

func (*UnimplementedArchivedWorkflowServiceServer) ListArchivedWorkflowLabelKeys(ctx context.Context, req *ListArchivedWorkflowLabelKeysRequest) (*v1alpha1.LabelKeys, error)

func (*UnimplementedArchivedWorkflowServiceServer) ListArchivedWorkflowLabelValues added in v3.3.0 

func (*UnimplementedArchivedWorkflowServiceServer) ListArchivedWorkflowLabelValues(ctx context.Context, req *ListArchivedWorkflowLabelValuesRequest) (*v1alpha1.LabelValues, error)

func (*UnimplementedArchivedWorkflowServiceServer) ListArchivedWorkflows 

func (*UnimplementedArchivedWorkflowServiceServer) ListArchivedWorkflows(ctx context.Context, req *ListArchivedWorkflowsRequest) (*v1alpha1.WorkflowList, error)

func (*UnimplementedArchivedWorkflowServiceServer) ResubmitArchivedWorkflow added in v3.4.0 

func (*UnimplementedArchivedWorkflowServiceServer) ResubmitArchivedWorkflow(ctx context.Context, req *ResubmitArchivedWorkflowRequest) (*v1alpha1.Workflow, error)

func (*UnimplementedArchivedWorkflowServiceServer) RetryArchivedWorkflow added in v3.4.0 

func (*UnimplementedArchivedWorkflowServiceServer) RetryArchivedWorkflow(ctx context.Context, req *RetryArchivedWorkflowRequest) (*v1alpha1.Workflow, error)

Source Files

View all Source files

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.