zishuo/onepanel
1
0
Fork 0
mirror of https://github.com/onepanelio/onepanel.git synced 2025-10-05 13:46:51 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity
Files
b114204206e08139a368f5b6eef14ee7cf9d5f8b
onepanel/api/workflow.pb.go
Aleksandr Melnikov b114204206 Proto updates.
2020-03-27 12:17:39 -07:00

2521 lines
101 KiB
Go
Raw Blame History

// Code generated by protoc-gen-go. DO NOT EDIT.
// source: workflow.proto
package api
import (
context "context"
fmt "fmt"
proto "github.com/golang/protobuf/proto"
empty "github.com/golang/protobuf/ptypes/empty"
_ "google.golang.org/genproto/googleapis/api/annotations"
grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
math "math"
)
// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
type CreateWorkflowExecutionRequest struct {
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
WorkflowExecution *WorkflowExecution `protobuf:"bytes,2,opt,name=workflowExecution,proto3" json:"workflowExecution,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *CreateWorkflowExecutionRequest) Reset() { *m = CreateWorkflowExecutionRequest{} }
func (m *CreateWorkflowExecutionRequest) String() string { return proto.CompactTextString(m) }
func (*CreateWorkflowExecutionRequest) ProtoMessage() {}
func (*CreateWorkflowExecutionRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{0}
}
func (m *CreateWorkflowExecutionRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_CreateWorkflowExecutionRequest.Unmarshal(m, b)
}
func (m *CreateWorkflowExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_CreateWorkflowExecutionRequest.Marshal(b, m, deterministic)
}
func (m *CreateWorkflowExecutionRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_CreateWorkflowExecutionRequest.Merge(m, src)
}
func (m *CreateWorkflowExecutionRequest) XXX_Size() int {
return xxx_messageInfo_CreateWorkflowExecutionRequest.Size(m)
}
func (m *CreateWorkflowExecutionRequest) XXX_DiscardUnknown() {
xxx_messageInfo_CreateWorkflowExecutionRequest.DiscardUnknown(m)
}
var xxx_messageInfo_CreateWorkflowExecutionRequest proto.InternalMessageInfo
func (m *CreateWorkflowExecutionRequest) GetNamespace() string {
if m != nil {
return m.Namespace
}
return ""
}
func (m *CreateWorkflowExecutionRequest) GetWorkflowExecution() *WorkflowExecution {
if m != nil {
return m.WorkflowExecution
}
return nil
}
type GetWorkflowExecutionRequest struct {
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetWorkflowExecutionRequest) Reset() { *m = GetWorkflowExecutionRequest{} }
func (m *GetWorkflowExecutionRequest) String() string { return proto.CompactTextString(m) }
func (*GetWorkflowExecutionRequest) ProtoMessage() {}
func (*GetWorkflowExecutionRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{1}
}
func (m *GetWorkflowExecutionRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetWorkflowExecutionRequest.Unmarshal(m, b)
}
func (m *GetWorkflowExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetWorkflowExecutionRequest.Marshal(b, m, deterministic)
}
func (m *GetWorkflowExecutionRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetWorkflowExecutionRequest.Merge(m, src)
}
func (m *GetWorkflowExecutionRequest) XXX_Size() int {
return xxx_messageInfo_GetWorkflowExecutionRequest.Size(m)
}
func (m *GetWorkflowExecutionRequest) XXX_DiscardUnknown() {
xxx_messageInfo_GetWorkflowExecutionRequest.DiscardUnknown(m)
}
var xxx_messageInfo_GetWorkflowExecutionRequest proto.InternalMessageInfo
func (m *GetWorkflowExecutionRequest) GetNamespace() string {
if m != nil {
return m.Namespace
}
return ""
}
func (m *GetWorkflowExecutionRequest) GetName() string {
if m != nil {
return m.Name
}
return ""
}
type GetArtifactRequest struct {
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetArtifactRequest) Reset() { *m = GetArtifactRequest{} }
func (m *GetArtifactRequest) String() string { return proto.CompactTextString(m) }
func (*GetArtifactRequest) ProtoMessage() {}
func (*GetArtifactRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{2}
}
func (m *GetArtifactRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetArtifactRequest.Unmarshal(m, b)
}
func (m *GetArtifactRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetArtifactRequest.Marshal(b, m, deterministic)
}
func (m *GetArtifactRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetArtifactRequest.Merge(m, src)
}
func (m *GetArtifactRequest) XXX_Size() int {
return xxx_messageInfo_GetArtifactRequest.Size(m)
}
func (m *GetArtifactRequest) XXX_DiscardUnknown() {
xxx_messageInfo_GetArtifactRequest.DiscardUnknown(m)
}
var xxx_messageInfo_GetArtifactRequest proto.InternalMessageInfo
func (m *GetArtifactRequest) GetNamespace() string {
if m != nil {
return m.Namespace
}
return ""
}
func (m *GetArtifactRequest) GetName() string {
if m != nil {
return m.Name
}
return ""
}
func (m *GetArtifactRequest) GetKey() string {
if m != nil {
return m.Key
}
return ""
}
type WatchWorkflowExecutionRequest struct {
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *WatchWorkflowExecutionRequest) Reset() { *m = WatchWorkflowExecutionRequest{} }
func (m *WatchWorkflowExecutionRequest) String() string { return proto.CompactTextString(m) }
func (*WatchWorkflowExecutionRequest) ProtoMessage() {}
func (*WatchWorkflowExecutionRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{3}
}
func (m *WatchWorkflowExecutionRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_WatchWorkflowExecutionRequest.Unmarshal(m, b)
}
func (m *WatchWorkflowExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_WatchWorkflowExecutionRequest.Marshal(b, m, deterministic)
}
func (m *WatchWorkflowExecutionRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_WatchWorkflowExecutionRequest.Merge(m, src)
}
func (m *WatchWorkflowExecutionRequest) XXX_Size() int {
return xxx_messageInfo_WatchWorkflowExecutionRequest.Size(m)
}
func (m *WatchWorkflowExecutionRequest) XXX_DiscardUnknown() {
xxx_messageInfo_WatchWorkflowExecutionRequest.DiscardUnknown(m)
}
var xxx_messageInfo_WatchWorkflowExecutionRequest proto.InternalMessageInfo
func (m *WatchWorkflowExecutionRequest) GetNamespace() string {
if m != nil {
return m.Namespace
}
return ""
}
func (m *WatchWorkflowExecutionRequest) GetName() string {
if m != nil {
return m.Name
}
return ""
}
type ResubmitWorkflowExecutionRequest struct {
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ResubmitWorkflowExecutionRequest) Reset() { *m = ResubmitWorkflowExecutionRequest{} }
func (m *ResubmitWorkflowExecutionRequest) String() string { return proto.CompactTextString(m) }
func (*ResubmitWorkflowExecutionRequest) ProtoMessage() {}
func (*ResubmitWorkflowExecutionRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{4}
}
func (m *ResubmitWorkflowExecutionRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ResubmitWorkflowExecutionRequest.Unmarshal(m, b)
}
func (m *ResubmitWorkflowExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ResubmitWorkflowExecutionRequest.Marshal(b, m, deterministic)
}
func (m *ResubmitWorkflowExecutionRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_ResubmitWorkflowExecutionRequest.Merge(m, src)
}
func (m *ResubmitWorkflowExecutionRequest) XXX_Size() int {
return xxx_messageInfo_ResubmitWorkflowExecutionRequest.Size(m)
}
func (m *ResubmitWorkflowExecutionRequest) XXX_DiscardUnknown() {
xxx_messageInfo_ResubmitWorkflowExecutionRequest.DiscardUnknown(m)
}
var xxx_messageInfo_ResubmitWorkflowExecutionRequest proto.InternalMessageInfo
func (m *ResubmitWorkflowExecutionRequest) GetNamespace() string {
if m != nil {
return m.Namespace
}
return ""
}
func (m *ResubmitWorkflowExecutionRequest) GetName() string {
if m != nil {
return m.Name
}
return ""
}
type TerminateWorkflowExecutionRequest struct {
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *TerminateWorkflowExecutionRequest) Reset() { *m = TerminateWorkflowExecutionRequest{} }
func (m *TerminateWorkflowExecutionRequest) String() string { return proto.CompactTextString(m) }
func (*TerminateWorkflowExecutionRequest) ProtoMessage() {}
func (*TerminateWorkflowExecutionRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{5}
}
func (m *TerminateWorkflowExecutionRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_TerminateWorkflowExecutionRequest.Unmarshal(m, b)
}
func (m *TerminateWorkflowExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_TerminateWorkflowExecutionRequest.Marshal(b, m, deterministic)
}
func (m *TerminateWorkflowExecutionRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_TerminateWorkflowExecutionRequest.Merge(m, src)
}
func (m *TerminateWorkflowExecutionRequest) XXX_Size() int {
return xxx_messageInfo_TerminateWorkflowExecutionRequest.Size(m)
}
func (m *TerminateWorkflowExecutionRequest) XXX_DiscardUnknown() {
xxx_messageInfo_TerminateWorkflowExecutionRequest.DiscardUnknown(m)
}
var xxx_messageInfo_TerminateWorkflowExecutionRequest proto.InternalMessageInfo
func (m *TerminateWorkflowExecutionRequest) GetNamespace() string {
if m != nil {
return m.Namespace
}
return ""
}
func (m *TerminateWorkflowExecutionRequest) GetName() string {
if m != nil {
return m.Name
}
return ""
}
type GetWorkflowExecutionLogsRequest struct {
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
PodName string `protobuf:"bytes,3,opt,name=podName,proto3" json:"podName,omitempty"`
ContainerName string `protobuf:"bytes,4,opt,name=containerName,proto3" json:"containerName,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetWorkflowExecutionLogsRequest) Reset() { *m = GetWorkflowExecutionLogsRequest{} }
func (m *GetWorkflowExecutionLogsRequest) String() string { return proto.CompactTextString(m) }
func (*GetWorkflowExecutionLogsRequest) ProtoMessage() {}
func (*GetWorkflowExecutionLogsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{6}
}
func (m *GetWorkflowExecutionLogsRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetWorkflowExecutionLogsRequest.Unmarshal(m, b)
}
func (m *GetWorkflowExecutionLogsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetWorkflowExecutionLogsRequest.Marshal(b, m, deterministic)
}
func (m *GetWorkflowExecutionLogsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetWorkflowExecutionLogsRequest.Merge(m, src)
}
func (m *GetWorkflowExecutionLogsRequest) XXX_Size() int {
return xxx_messageInfo_GetWorkflowExecutionLogsRequest.Size(m)
}
func (m *GetWorkflowExecutionLogsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_GetWorkflowExecutionLogsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_GetWorkflowExecutionLogsRequest proto.InternalMessageInfo
func (m *GetWorkflowExecutionLogsRequest) GetNamespace() string {
if m != nil {
return m.Namespace
}
return ""
}
func (m *GetWorkflowExecutionLogsRequest) GetName() string {
if m != nil {
return m.Name
}
return ""
}
func (m *GetWorkflowExecutionLogsRequest) GetPodName() string {
if m != nil {
return m.PodName
}
return ""
}
func (m *GetWorkflowExecutionLogsRequest) GetContainerName() string {
if m != nil {
return m.ContainerName
}
return ""
}
type GetWorkflowExecutionMetricsRequest struct {
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
PodName string `protobuf:"bytes,3,opt,name=podName,proto3" json:"podName,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetWorkflowExecutionMetricsRequest) Reset() { *m = GetWorkflowExecutionMetricsRequest{} }
func (m *GetWorkflowExecutionMetricsRequest) String() string { return proto.CompactTextString(m) }
func (*GetWorkflowExecutionMetricsRequest) ProtoMessage() {}
func (*GetWorkflowExecutionMetricsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{7}
}
func (m *GetWorkflowExecutionMetricsRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetWorkflowExecutionMetricsRequest.Unmarshal(m, b)
}
func (m *GetWorkflowExecutionMetricsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetWorkflowExecutionMetricsRequest.Marshal(b, m, deterministic)
}
func (m *GetWorkflowExecutionMetricsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetWorkflowExecutionMetricsRequest.Merge(m, src)
}
func (m *GetWorkflowExecutionMetricsRequest) XXX_Size() int {
return xxx_messageInfo_GetWorkflowExecutionMetricsRequest.Size(m)
}
func (m *GetWorkflowExecutionMetricsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_GetWorkflowExecutionMetricsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_GetWorkflowExecutionMetricsRequest proto.InternalMessageInfo
func (m *GetWorkflowExecutionMetricsRequest) GetNamespace() string {
if m != nil {
return m.Namespace
}
return ""
}
func (m *GetWorkflowExecutionMetricsRequest) GetName() string {
if m != nil {
return m.Name
}
return ""
}
func (m *GetWorkflowExecutionMetricsRequest) GetPodName() string {
if m != nil {
return m.PodName
}
return ""
}
type GetWorkflowExecutionMetricsResponse struct {
Metrics []*Metric `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetWorkflowExecutionMetricsResponse) Reset() { *m = GetWorkflowExecutionMetricsResponse{} }
func (m *GetWorkflowExecutionMetricsResponse) String() string { return proto.CompactTextString(m) }
func (*GetWorkflowExecutionMetricsResponse) ProtoMessage() {}
func (*GetWorkflowExecutionMetricsResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{8}
}
func (m *GetWorkflowExecutionMetricsResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetWorkflowExecutionMetricsResponse.Unmarshal(m, b)
}
func (m *GetWorkflowExecutionMetricsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetWorkflowExecutionMetricsResponse.Marshal(b, m, deterministic)
}
func (m *GetWorkflowExecutionMetricsResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetWorkflowExecutionMetricsResponse.Merge(m, src)
}
func (m *GetWorkflowExecutionMetricsResponse) XXX_Size() int {
return xxx_messageInfo_GetWorkflowExecutionMetricsResponse.Size(m)
}
func (m *GetWorkflowExecutionMetricsResponse) XXX_DiscardUnknown() {
xxx_messageInfo_GetWorkflowExecutionMetricsResponse.DiscardUnknown(m)
}
var xxx_messageInfo_GetWorkflowExecutionMetricsResponse proto.InternalMessageInfo
func (m *GetWorkflowExecutionMetricsResponse) GetMetrics() []*Metric {
if m != nil {
return m.Metrics
}
return nil
}
type ListWorkflowExecutionsRequest struct {
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
WorkflowTemplateUid string `protobuf:"bytes,2,opt,name=workflowTemplateUid,proto3" json:"workflowTemplateUid,omitempty"`
WorkflowTemplateVersion string `protobuf:"bytes,3,opt,name=workflowTemplateVersion,proto3" json:"workflowTemplateVersion,omitempty"`
PageSize int32 `protobuf:"varint,4,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
Page int32 `protobuf:"varint,5,opt,name=page,proto3" json:"page,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ListWorkflowExecutionsRequest) Reset() { *m = ListWorkflowExecutionsRequest{} }
func (m *ListWorkflowExecutionsRequest) String() string { return proto.CompactTextString(m) }
func (*ListWorkflowExecutionsRequest) ProtoMessage() {}
func (*ListWorkflowExecutionsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{9}
}
func (m *ListWorkflowExecutionsRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ListWorkflowExecutionsRequest.Unmarshal(m, b)
}
func (m *ListWorkflowExecutionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ListWorkflowExecutionsRequest.Marshal(b, m, deterministic)
}
func (m *ListWorkflowExecutionsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_ListWorkflowExecutionsRequest.Merge(m, src)
}
func (m *ListWorkflowExecutionsRequest) XXX_Size() int {
return xxx_messageInfo_ListWorkflowExecutionsRequest.Size(m)
}
func (m *ListWorkflowExecutionsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_ListWorkflowExecutionsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_ListWorkflowExecutionsRequest proto.InternalMessageInfo
func (m *ListWorkflowExecutionsRequest) GetNamespace() string {
if m != nil {
return m.Namespace
}
return ""
}
func (m *ListWorkflowExecutionsRequest) GetWorkflowTemplateUid() string {
if m != nil {
return m.WorkflowTemplateUid
}
return ""
}
func (m *ListWorkflowExecutionsRequest) GetWorkflowTemplateVersion() string {
if m != nil {
return m.WorkflowTemplateVersion
}
return ""
}
func (m *ListWorkflowExecutionsRequest) GetPageSize() int32 {
if m != nil {
return m.PageSize
}
return 0
}
func (m *ListWorkflowExecutionsRequest) GetPage() int32 {
if m != nil {
return m.Page
}
return 0
}
type ListWorkflowExecutionsResponse struct {
Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
WorkflowExecutions []*WorkflowExecution `protobuf:"bytes,2,rep,name=workflowExecutions,proto3" json:"workflowExecutions,omitempty"`
Page int32 `protobuf:"varint,3,opt,name=page,proto3" json:"page,omitempty"`
Pages int32 `protobuf:"varint,4,opt,name=pages,proto3" json:"pages,omitempty"`
TotalCount int32 `protobuf:"varint,5,opt,name=totalCount,proto3" json:"totalCount,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ListWorkflowExecutionsResponse) Reset() { *m = ListWorkflowExecutionsResponse{} }
func (m *ListWorkflowExecutionsResponse) String() string { return proto.CompactTextString(m) }
func (*ListWorkflowExecutionsResponse) ProtoMessage() {}
func (*ListWorkflowExecutionsResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{10}
}
func (m *ListWorkflowExecutionsResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ListWorkflowExecutionsResponse.Unmarshal(m, b)
}
func (m *ListWorkflowExecutionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ListWorkflowExecutionsResponse.Marshal(b, m, deterministic)
}
func (m *ListWorkflowExecutionsResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_ListWorkflowExecutionsResponse.Merge(m, src)
}
func (m *ListWorkflowExecutionsResponse) XXX_Size() int {
return xxx_messageInfo_ListWorkflowExecutionsResponse.Size(m)
}
func (m *ListWorkflowExecutionsResponse) XXX_DiscardUnknown() {
xxx_messageInfo_ListWorkflowExecutionsResponse.DiscardUnknown(m)
}
var xxx_messageInfo_ListWorkflowExecutionsResponse proto.InternalMessageInfo
func (m *ListWorkflowExecutionsResponse) GetCount() int32 {
if m != nil {
return m.Count
}
return 0
}
func (m *ListWorkflowExecutionsResponse) GetWorkflowExecutions() []*WorkflowExecution {
if m != nil {
return m.WorkflowExecutions
}
return nil
}
func (m *ListWorkflowExecutionsResponse) GetPage() int32 {
if m != nil {
return m.Page
}
return 0
}
func (m *ListWorkflowExecutionsResponse) GetPages() int32 {
if m != nil {
return m.Pages
}
return 0
}
func (m *ListWorkflowExecutionsResponse) GetTotalCount() int32 {
if m != nil {
return m.TotalCount
}
return 0
}
type LogEntry struct {
Timestamp string `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
Content string `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *LogEntry) Reset() { *m = LogEntry{} }
func (m *LogEntry) String() string { return proto.CompactTextString(m) }
func (*LogEntry) ProtoMessage() {}
func (*LogEntry) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{11}
}
func (m *LogEntry) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_LogEntry.Unmarshal(m, b)
}
func (m *LogEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_LogEntry.Marshal(b, m, deterministic)
}
func (m *LogEntry) XXX_Merge(src proto.Message) {
xxx_messageInfo_LogEntry.Merge(m, src)
}
func (m *LogEntry) XXX_Size() int {
return xxx_messageInfo_LogEntry.Size(m)
}
func (m *LogEntry) XXX_DiscardUnknown() {
xxx_messageInfo_LogEntry.DiscardUnknown(m)
}
var xxx_messageInfo_LogEntry proto.InternalMessageInfo
func (m *LogEntry) GetTimestamp() string {
if m != nil {
return m.Timestamp
}
return ""
}
func (m *LogEntry) GetContent() string {
if m != nil {
return m.Content
}
return ""
}
type WorkflowExecution struct {
CreatedAt string `protobuf:"bytes,1,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
Phase string `protobuf:"bytes,4,opt,name=phase,proto3" json:"phase,omitempty"`
StartedAt string `protobuf:"bytes,5,opt,name=startedAt,proto3" json:"startedAt,omitempty"`
FinishedAt string `protobuf:"bytes,6,opt,name=finishedAt,proto3" json:"finishedAt,omitempty"`
Manifest string `protobuf:"bytes,7,opt,name=manifest,proto3" json:"manifest,omitempty"`
Parameters []*WorkflowExecutionParameter `protobuf:"bytes,8,rep,name=parameters,proto3" json:"parameters,omitempty"`
WorkflowTemplate *WorkflowTemplate `protobuf:"bytes,9,opt,name=workflowTemplate,proto3" json:"workflowTemplate,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *WorkflowExecution) Reset() { *m = WorkflowExecution{} }
func (m *WorkflowExecution) String() string { return proto.CompactTextString(m) }
func (*WorkflowExecution) ProtoMessage() {}
func (*WorkflowExecution) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{12}
}
func (m *WorkflowExecution) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_WorkflowExecution.Unmarshal(m, b)
}
func (m *WorkflowExecution) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_WorkflowExecution.Marshal(b, m, deterministic)
}
func (m *WorkflowExecution) XXX_Merge(src proto.Message) {
xxx_messageInfo_WorkflowExecution.Merge(m, src)
}
func (m *WorkflowExecution) XXX_Size() int {
return xxx_messageInfo_WorkflowExecution.Size(m)
}
func (m *WorkflowExecution) XXX_DiscardUnknown() {
xxx_messageInfo_WorkflowExecution.DiscardUnknown(m)
}
var xxx_messageInfo_WorkflowExecution proto.InternalMessageInfo
func (m *WorkflowExecution) GetCreatedAt() string {
if m != nil {
return m.CreatedAt
}
return ""
}
func (m *WorkflowExecution) GetUid() string {
if m != nil {
return m.Uid
}
return ""
}
func (m *WorkflowExecution) GetName() string {
if m != nil {
return m.Name
}
return ""
}
func (m *WorkflowExecution) GetPhase() string {
if m != nil {
return m.Phase
}
return ""
}
func (m *WorkflowExecution) GetStartedAt() string {
if m != nil {
return m.StartedAt
}
return ""
}
func (m *WorkflowExecution) GetFinishedAt() string {
if m != nil {
return m.FinishedAt
}
return ""
}
func (m *WorkflowExecution) GetManifest() string {
if m != nil {
return m.Manifest
}
return ""
}
func (m *WorkflowExecution) GetParameters() []*WorkflowExecutionParameter {
if m != nil {
return m.Parameters
}
return nil
}
func (m *WorkflowExecution) GetWorkflowTemplate() *WorkflowTemplate {
if m != nil {
return m.WorkflowTemplate
}
return nil
}
type WorkflowExecutionParameter struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *WorkflowExecutionParameter) Reset() { *m = WorkflowExecutionParameter{} }
func (m *WorkflowExecutionParameter) String() string { return proto.CompactTextString(m) }
func (*WorkflowExecutionParameter) ProtoMessage() {}
func (*WorkflowExecutionParameter) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{13}
}
func (m *WorkflowExecutionParameter) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_WorkflowExecutionParameter.Unmarshal(m, b)
}
func (m *WorkflowExecutionParameter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_WorkflowExecutionParameter.Marshal(b, m, deterministic)
}
func (m *WorkflowExecutionParameter) XXX_Merge(src proto.Message) {
xxx_messageInfo_WorkflowExecutionParameter.Merge(m, src)
}
func (m *WorkflowExecutionParameter) XXX_Size() int {
return xxx_messageInfo_WorkflowExecutionParameter.Size(m)
}
func (m *WorkflowExecutionParameter) XXX_DiscardUnknown() {
xxx_messageInfo_WorkflowExecutionParameter.DiscardUnknown(m)
}
var xxx_messageInfo_WorkflowExecutionParameter proto.InternalMessageInfo
func (m *WorkflowExecutionParameter) GetName() string {
if m != nil {
return m.Name
}
return ""
}
func (m *WorkflowExecutionParameter) GetValue() string {
if m != nil {
return m.Value
}
return ""
}
type ArtifactResponse struct {
Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ArtifactResponse) Reset() { *m = ArtifactResponse{} }
func (m *ArtifactResponse) String() string { return proto.CompactTextString(m) }
func (*ArtifactResponse) ProtoMessage() {}
func (*ArtifactResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{14}
}
func (m *ArtifactResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ArtifactResponse.Unmarshal(m, b)
}
func (m *ArtifactResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ArtifactResponse.Marshal(b, m, deterministic)
}
func (m *ArtifactResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_ArtifactResponse.Merge(m, src)
}
func (m *ArtifactResponse) XXX_Size() int {
return xxx_messageInfo_ArtifactResponse.Size(m)
}
func (m *ArtifactResponse) XXX_DiscardUnknown() {
xxx_messageInfo_ArtifactResponse.DiscardUnknown(m)
}
var xxx_messageInfo_ArtifactResponse proto.InternalMessageInfo
func (m *ArtifactResponse) GetData() []byte {
if m != nil {
return m.Data
}
return nil
}
type File struct {
Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Extension string `protobuf:"bytes,3,opt,name=extension,proto3" json:"extension,omitempty"`
Size int64 `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
ContentType string `protobuf:"bytes,5,opt,name=contentType,proto3" json:"contentType,omitempty"`
LastModified string `protobuf:"bytes,6,opt,name=lastModified,proto3" json:"lastModified,omitempty"`
Directory bool `protobuf:"varint,7,opt,name=directory,proto3" json:"directory,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *File) Reset() { *m = File{} }
func (m *File) String() string { return proto.CompactTextString(m) }
func (*File) ProtoMessage() {}
func (*File) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{15}
}
func (m *File) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_File.Unmarshal(m, b)
}
func (m *File) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_File.Marshal(b, m, deterministic)
}
func (m *File) XXX_Merge(src proto.Message) {
xxx_messageInfo_File.Merge(m, src)
}
func (m *File) XXX_Size() int {
return xxx_messageInfo_File.Size(m)
}
func (m *File) XXX_DiscardUnknown() {
xxx_messageInfo_File.DiscardUnknown(m)
}
var xxx_messageInfo_File proto.InternalMessageInfo
func (m *File) GetPath() string {
if m != nil {
return m.Path
}
return ""
}
func (m *File) GetName() string {
if m != nil {
return m.Name
}
return ""
}
func (m *File) GetExtension() string {
if m != nil {
return m.Extension
}
return ""
}
func (m *File) GetSize() int64 {
if m != nil {
return m.Size
}
return 0
}
func (m *File) GetContentType() string {
if m != nil {
return m.ContentType
}
return ""
}
func (m *File) GetLastModified() string {
if m != nil {
return m.LastModified
}
return ""
}
func (m *File) GetDirectory() bool {
if m != nil {
return m.Directory
}
return false
}
type ListFilesRequest struct {
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ListFilesRequest) Reset() { *m = ListFilesRequest{} }
func (m *ListFilesRequest) String() string { return proto.CompactTextString(m) }
func (*ListFilesRequest) ProtoMessage() {}
func (*ListFilesRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{16}
}
func (m *ListFilesRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ListFilesRequest.Unmarshal(m, b)
}
func (m *ListFilesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ListFilesRequest.Marshal(b, m, deterministic)
}
func (m *ListFilesRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_ListFilesRequest.Merge(m, src)
}
func (m *ListFilesRequest) XXX_Size() int {
return xxx_messageInfo_ListFilesRequest.Size(m)
}
func (m *ListFilesRequest) XXX_DiscardUnknown() {
xxx_messageInfo_ListFilesRequest.DiscardUnknown(m)
}
var xxx_messageInfo_ListFilesRequest proto.InternalMessageInfo
func (m *ListFilesRequest) GetNamespace() string {
if m != nil {
return m.Namespace
}
return ""
}
func (m *ListFilesRequest) GetName() string {
if m != nil {
return m.Name
}
return ""
}
func (m *ListFilesRequest) GetPath() string {
if m != nil {
return m.Path
}
return ""
}
type ListFilesResponse struct {
Files []*File `protobuf:"bytes,1,rep,name=files,proto3" json:"files,omitempty"`
ParentPath string `protobuf:"bytes,2,opt,name=parentPath,proto3" json:"parentPath,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ListFilesResponse) Reset() { *m = ListFilesResponse{} }
func (m *ListFilesResponse) String() string { return proto.CompactTextString(m) }
func (*ListFilesResponse) ProtoMessage() {}
func (*ListFilesResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{17}
}
func (m *ListFilesResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ListFilesResponse.Unmarshal(m, b)
}
func (m *ListFilesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ListFilesResponse.Marshal(b, m, deterministic)
}
func (m *ListFilesResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_ListFilesResponse.Merge(m, src)
}
func (m *ListFilesResponse) XXX_Size() int {
return xxx_messageInfo_ListFilesResponse.Size(m)
}
func (m *ListFilesResponse) XXX_DiscardUnknown() {
xxx_messageInfo_ListFilesResponse.DiscardUnknown(m)
}
var xxx_messageInfo_ListFilesResponse proto.InternalMessageInfo
func (m *ListFilesResponse) GetFiles() []*File {
if m != nil {
return m.Files
}
return nil
}
func (m *ListFilesResponse) GetParentPath() string {
if m != nil {
return m.ParentPath
}
return ""
}
type KeyValue struct {
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *KeyValue) Reset() { *m = KeyValue{} }
func (m *KeyValue) String() string { return proto.CompactTextString(m) }
func (*KeyValue) ProtoMessage() {}
func (*KeyValue) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{18}
}
func (m *KeyValue) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_KeyValue.Unmarshal(m, b)
}
func (m *KeyValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_KeyValue.Marshal(b, m, deterministic)
}
func (m *KeyValue) XXX_Merge(src proto.Message) {
xxx_messageInfo_KeyValue.Merge(m, src)
}
func (m *KeyValue) XXX_Size() int {
return xxx_messageInfo_KeyValue.Size(m)
}
func (m *KeyValue) XXX_DiscardUnknown() {
xxx_messageInfo_KeyValue.DiscardUnknown(m)
}
var xxx_messageInfo_KeyValue proto.InternalMessageInfo
func (m *KeyValue) GetKey() string {
if m != nil {
return m.Key
}
return ""
}
func (m *KeyValue) GetValue() string {
if m != nil {
return m.Value
}
return ""
}
type Labels struct {
Items []*KeyValue `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Labels) Reset() { *m = Labels{} }
func (m *Labels) String() string { return proto.CompactTextString(m) }
func (*Labels) ProtoMessage() {}
func (*Labels) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{19}
}
func (m *Labels) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Labels.Unmarshal(m, b)
}
func (m *Labels) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Labels.Marshal(b, m, deterministic)
}
func (m *Labels) XXX_Merge(src proto.Message) {
xxx_messageInfo_Labels.Merge(m, src)
}
func (m *Labels) XXX_Size() int {
return xxx_messageInfo_Labels.Size(m)
}
func (m *Labels) XXX_DiscardUnknown() {
xxx_messageInfo_Labels.DiscardUnknown(m)
}
var xxx_messageInfo_Labels proto.InternalMessageInfo
func (m *Labels) GetItems() []*KeyValue {
if m != nil {
return m.Items
}
return nil
}
type AddLabelsRequest struct {
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Labels *Labels `protobuf:"bytes,3,opt,name=labels,proto3" json:"labels,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *AddLabelsRequest) Reset() { *m = AddLabelsRequest{} }
func (m *AddLabelsRequest) String() string { return proto.CompactTextString(m) }
func (*AddLabelsRequest) ProtoMessage() {}
func (*AddLabelsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{20}
}
func (m *AddLabelsRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_AddLabelsRequest.Unmarshal(m, b)
}
func (m *AddLabelsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_AddLabelsRequest.Marshal(b, m, deterministic)
}
func (m *AddLabelsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_AddLabelsRequest.Merge(m, src)
}
func (m *AddLabelsRequest) XXX_Size() int {
return xxx_messageInfo_AddLabelsRequest.Size(m)
}
func (m *AddLabelsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_AddLabelsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_AddLabelsRequest proto.InternalMessageInfo
func (m *AddLabelsRequest) GetNamespace() string {
if m != nil {
return m.Namespace
}
return ""
}
func (m *AddLabelsRequest) GetName() string {
if m != nil {
return m.Name
}
return ""
}
func (m *AddLabelsRequest) GetLabels() *Labels {
if m != nil {
return m.Labels
}
return nil
}
type ReplaceLabelsRequest struct {
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Labels *Labels `protobuf:"bytes,3,opt,name=labels,proto3" json:"labels,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ReplaceLabelsRequest) Reset() { *m = ReplaceLabelsRequest{} }
func (m *ReplaceLabelsRequest) String() string { return proto.CompactTextString(m) }
func (*ReplaceLabelsRequest) ProtoMessage() {}
func (*ReplaceLabelsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{21}
}
func (m *ReplaceLabelsRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ReplaceLabelsRequest.Unmarshal(m, b)
}
func (m *ReplaceLabelsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ReplaceLabelsRequest.Marshal(b, m, deterministic)
}
func (m *ReplaceLabelsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_ReplaceLabelsRequest.Merge(m, src)
}
func (m *ReplaceLabelsRequest) XXX_Size() int {
return xxx_messageInfo_ReplaceLabelsRequest.Size(m)
}
func (m *ReplaceLabelsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_ReplaceLabelsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_ReplaceLabelsRequest proto.InternalMessageInfo
func (m *ReplaceLabelsRequest) GetNamespace() string {
if m != nil {
return m.Namespace
}
return ""
}
func (m *ReplaceLabelsRequest) GetName() string {
if m != nil {
return m.Name
}
return ""
}
func (m *ReplaceLabelsRequest) GetLabels() *Labels {
if m != nil {
return m.Labels
}
return nil
}
type GetLabelsRequest struct {
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetLabelsRequest) Reset() { *m = GetLabelsRequest{} }
func (m *GetLabelsRequest) String() string { return proto.CompactTextString(m) }
func (*GetLabelsRequest) ProtoMessage() {}
func (*GetLabelsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{22}
}
func (m *GetLabelsRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetLabelsRequest.Unmarshal(m, b)
}
func (m *GetLabelsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetLabelsRequest.Marshal(b, m, deterministic)
}
func (m *GetLabelsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetLabelsRequest.Merge(m, src)
}
func (m *GetLabelsRequest) XXX_Size() int {
return xxx_messageInfo_GetLabelsRequest.Size(m)
}
func (m *GetLabelsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_GetLabelsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_GetLabelsRequest proto.InternalMessageInfo
func (m *GetLabelsRequest) GetNamespace() string {
if m != nil {
return m.Namespace
}
return ""
}
func (m *GetLabelsRequest) GetName() string {
if m != nil {
return m.Name
}
return ""
}
type GetLabelsResponse struct {
Labels []*KeyValue `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetLabelsResponse) Reset() { *m = GetLabelsResponse{} }
func (m *GetLabelsResponse) String() string { return proto.CompactTextString(m) }
func (*GetLabelsResponse) ProtoMessage() {}
func (*GetLabelsResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{23}
}
func (m *GetLabelsResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetLabelsResponse.Unmarshal(m, b)
}
func (m *GetLabelsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetLabelsResponse.Marshal(b, m, deterministic)
}
func (m *GetLabelsResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetLabelsResponse.Merge(m, src)
}
func (m *GetLabelsResponse) XXX_Size() int {
return xxx_messageInfo_GetLabelsResponse.Size(m)
}
func (m *GetLabelsResponse) XXX_DiscardUnknown() {
xxx_messageInfo_GetLabelsResponse.DiscardUnknown(m)
}
var xxx_messageInfo_GetLabelsResponse proto.InternalMessageInfo
func (m *GetLabelsResponse) GetLabels() []*KeyValue {
if m != nil {
return m.Labels
}
return nil
}
type DeleteLabelRequest struct {
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *DeleteLabelRequest) Reset() { *m = DeleteLabelRequest{} }
func (m *DeleteLabelRequest) String() string { return proto.CompactTextString(m) }
func (*DeleteLabelRequest) ProtoMessage() {}
func (*DeleteLabelRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_892c7f566756b0be, []int{24}
}
func (m *DeleteLabelRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DeleteLabelRequest.Unmarshal(m, b)
}
func (m *DeleteLabelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_DeleteLabelRequest.Marshal(b, m, deterministic)
}
func (m *DeleteLabelRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_DeleteLabelRequest.Merge(m, src)
}
func (m *DeleteLabelRequest) XXX_Size() int {
return xxx_messageInfo_DeleteLabelRequest.Size(m)
}
func (m *DeleteLabelRequest) XXX_DiscardUnknown() {
xxx_messageInfo_DeleteLabelRequest.DiscardUnknown(m)
}
var xxx_messageInfo_DeleteLabelRequest proto.InternalMessageInfo
func (m *DeleteLabelRequest) GetNamespace() string {
if m != nil {
return m.Namespace
}
return ""
}
func (m *DeleteLabelRequest) GetName() string {
if m != nil {
return m.Name
}
return ""
}
func (m *DeleteLabelRequest) GetKey() string {
if m != nil {
return m.Key
}
return ""
}
func init() {
proto.RegisterType((*CreateWorkflowExecutionRequest)(nil), "api.CreateWorkflowExecutionRequest")
proto.RegisterType((*GetWorkflowExecutionRequest)(nil), "api.GetWorkflowExecutionRequest")
proto.RegisterType((*GetArtifactRequest)(nil), "api.GetArtifactRequest")
proto.RegisterType((*WatchWorkflowExecutionRequest)(nil), "api.WatchWorkflowExecutionRequest")
proto.RegisterType((*ResubmitWorkflowExecutionRequest)(nil), "api.ResubmitWorkflowExecutionRequest")
proto.RegisterType((*TerminateWorkflowExecutionRequest)(nil), "api.TerminateWorkflowExecutionRequest")
proto.RegisterType((*GetWorkflowExecutionLogsRequest)(nil), "api.GetWorkflowExecutionLogsRequest")
proto.RegisterType((*GetWorkflowExecutionMetricsRequest)(nil), "api.GetWorkflowExecutionMetricsRequest")
proto.RegisterType((*GetWorkflowExecutionMetricsResponse)(nil), "api.GetWorkflowExecutionMetricsResponse")
proto.RegisterType((*ListWorkflowExecutionsRequest)(nil), "api.ListWorkflowExecutionsRequest")
proto.RegisterType((*ListWorkflowExecutionsResponse)(nil), "api.ListWorkflowExecutionsResponse")
proto.RegisterType((*LogEntry)(nil), "api.LogEntry")
proto.RegisterType((*WorkflowExecution)(nil), "api.WorkflowExecution")
proto.RegisterType((*WorkflowExecutionParameter)(nil), "api.WorkflowExecutionParameter")
proto.RegisterType((*ArtifactResponse)(nil), "api.ArtifactResponse")
proto.RegisterType((*File)(nil), "api.File")
proto.RegisterType((*ListFilesRequest)(nil), "api.ListFilesRequest")
proto.RegisterType((*ListFilesResponse)(nil), "api.ListFilesResponse")
proto.RegisterType((*KeyValue)(nil), "api.KeyValue")
proto.RegisterType((*Labels)(nil), "api.Labels")
proto.RegisterType((*AddLabelsRequest)(nil), "api.AddLabelsRequest")
proto.RegisterType((*ReplaceLabelsRequest)(nil), "api.ReplaceLabelsRequest")
proto.RegisterType((*GetLabelsRequest)(nil), "api.GetLabelsRequest")
proto.RegisterType((*GetLabelsResponse)(nil), "api.GetLabelsResponse")
proto.RegisterType((*DeleteLabelRequest)(nil), "api.DeleteLabelRequest")
}
func init() { proto.RegisterFile("workflow.proto", fileDescriptor_892c7f566756b0be) }
var fileDescriptor_892c7f566756b0be = []byte{
// 1711 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xbc, 0x58, 0x4b, 0x6f, 0x1b, 0x47,
0x12, 0x46, 0x8b, 0x92, 0x2c, 0x95, 0xec, 0x5d, 0xa9, 0x6d, 0x49, 0xd4, 0x58, 0x2f, 0xb7, 0x6c,
0xaf, 0x2c, 0xac, 0x39, 0xb6, 0xd6, 0xbb, 0x58, 0x68, 0xed, 0xb5, 0x65, 0xbd, 0xd6, 0x6b, 0x39,
0x76, 0x68, 0xf9, 0x81, 0x5c, 0x92, 0x16, 0xd9, 0x94, 0x06, 0x22, 0x39, 0x93, 0x99, 0xa6, 0x64,
0x45, 0xe0, 0x21, 0x8f, 0x43, 0x4e, 0x41, 0x00, 0x07, 0x81, 0xe1, 0x00, 0x41, 0x02, 0xe4, 0x90,
0x9f, 0x90, 0x53, 0x0e, 0x41, 0x02, 0x04, 0xc8, 0xd1, 0xa7, 0x9c, 0x72, 0x49, 0xfe, 0x47, 0xd0,
0xaf, 0xd1, 0x90, 0x9c, 0xa1, 0x44, 0x4a, 0xc9, 0x89, 0xd3, 0x55, 0xdd, 0x55, 0x5f, 0x3d, 0xba,
0xba, 0x8a, 0xf0, 0x97, 0x1d, 0xd7, 0xdf, 0x2a, 0x14, 0xdd, 0x9d, 0x8c, 0xe7, 0xbb, 0xdc, 0xc5,
0x29, 0xea, 0x39, 0xd6, 0xe8, 0x86, 0xeb, 0x6e, 0x14, 0x99, 0x4d, 0x3d, 0xc7, 0xa6, 0xe5, 0xb2,
0xcb, 0x29, 0x77, 0xdc, 0x72, 0xa0, 0xb6, 0x58, 0x67, 0x35, 0x57, 0xae, 0xd6, 0x2b, 0x05, 0x9b,
0x95, 0x3c, 0xbe, 0xab, 0x99, 0xc3, 0x46, 0xde, 0x9b, 0x9c, 0x95, 0xbc, 0x22, 0xe5, 0x4c, 0x33,
0x4e, 0x96, 0x18, 0xf7, 0x9d, 0x9c, 0x5a, 0x91, 0x0f, 0x10, 0x8c, 0x2f, 0xf8, 0x8c, 0x72, 0xf6,
0x44, 0xef, 0x5f, 0x7a, 0xc6, 0x72, 0x15, 0xa1, 0x26, 0xcb, 0xde, 0xae, 0xb0, 0x80, 0xe3, 0x51,
0xe8, 0x2d, 0xd3, 0x12, 0x0b, 0x3c, 0x9a, 0x63, 0x69, 0x34, 0x89, 0xa6, 0x7b, 0xb3, 0xfb, 0x04,
0xbc, 0x08, 0x03, 0x3b, 0xf5, 0x27, 0xd3, 0x1d, 0x93, 0x68, 0xba, 0x6f, 0x76, 0x28, 0x43, 0x3d,
0x27, 0xd3, 0x28, 0xb7, 0xf1, 0x00, 0xb9, 0x0f, 0x67, 0x57, 0x18, 0x6f, 0x13, 0x02, 0x86, 0x4e,
0xb1, 0x90, 0x5a, 0x7b, 0xb3, 0xf2, 0x9b, 0x3c, 0x05, 0xbc, 0xc2, 0xf8, 0xbc, 0xcf, 0x9d, 0x02,
0xcd, 0xf1, 0xb6, 0xe5, 0xe0, 0x7e, 0x48, 0x6d, 0xb1, 0xdd, 0x74, 0x4a, 0x92, 0xc4, 0x27, 0x79,
0x1d, 0xc6, 0x9e, 0x50, 0x9e, 0xdb, 0x3c, 0x46, 0xb0, 0x6b, 0x30, 0x99, 0x65, 0x41, 0x65, 0xbd,
0xe4, 0x1c, 0xa7, 0x0b, 0x1e, 0xc1, 0xb9, 0x35, 0xe6, 0x97, 0x9c, 0x72, 0xfb, 0xc1, 0x8d, 0x13,
0xfb, 0x1c, 0xc1, 0x44, 0x5c, 0xac, 0x56, 0xdd, 0x8d, 0xa0, 0x7d, 0x3f, 0xa7, 0xe1, 0x84, 0xe7,
0xe6, 0x5f, 0x13, 0x64, 0xe5, 0x6b, 0xb3, 0xc4, 0xe7, 0xe1, 0x54, 0xce, 0x2d, 0x73, 0xea, 0x94,
0x99, 0x2f, 0xf9, 0x9d, 0x92, 0x5f, 0x4b, 0x24, 0x1e, 0x90, 0x38, 0x50, 0xf7, 0x64, 0xae, 0xff,
0x11, 0xb8, 0xc8, 0x2a, 0x4c, 0x35, 0xd5, 0x18, 0x78, 0x6e, 0x39, 0x60, 0xf8, 0x02, 0x9c, 0x50,
0x17, 0x2e, 0x48, 0xa3, 0xc9, 0xd4, 0x74, 0xdf, 0x6c, 0x9f, 0xbc, 0x15, 0x6a, 0x5b, 0xd6, 0xf0,
0xc8, 0xcf, 0x08, 0xc6, 0x56, 0x9d, 0xa0, 0x51, 0xde, 0x21, 0xb1, 0x5f, 0x81, 0xd3, 0xe6, 0x56,
0xad, 0xe9, 0xfb, 0xfe, 0xc8, 0xc9, 0x6b, 0x53, 0xe2, 0x58, 0xf8, 0xdf, 0x30, 0x5c, 0x4f, 0x7e,
0xcc, 0xfc, 0x40, 0x5c, 0x5f, 0x65, 0x69, 0x12, 0x1b, 0x5b, 0xd0, 0xe3, 0xd1, 0x0d, 0xf6, 0xd0,
0x79, 0x47, 0x05, 0xa3, 0x2b, 0x1b, 0xae, 0x85, 0x0f, 0xc5, 0x77, 0xba, 0x4b, 0xd2, 0xe5, 0x37,
0xf9, 0x11, 0xc1, 0x78, 0x92, 0x6d, 0xda, 0x4b, 0x67, 0xa0, 0x2b, 0xe7, 0x56, 0xca, 0x5c, 0x1a,
0xd6, 0x95, 0x55, 0x0b, 0xbc, 0x0c, 0xb8, 0xa1, 0x54, 0x04, 0xe9, 0x0e, 0xe9, 0xc6, 0xa4, 0xe2,
0x12, 0x73, 0x22, 0x04, 0x95, 0xda, 0x07, 0x25, 0x34, 0x8a, 0xdf, 0x40, 0x5b, 0xa0, 0x16, 0x78,
0x1c, 0x80, 0xbb, 0x9c, 0x16, 0x17, 0x24, 0x18, 0x65, 0x44, 0x84, 0x42, 0x6e, 0x43, 0xcf, 0xaa,
0xbb, 0xb1, 0x54, 0xe6, 0xfe, 0xae, 0x08, 0x08, 0x77, 0x4a, 0x2c, 0xe0, 0xb4, 0xe4, 0x99, 0x80,
0x84, 0x04, 0x91, 0x38, 0x22, 0x43, 0x59, 0x99, 0xeb, 0x20, 0x98, 0x25, 0xf9, 0xa9, 0x03, 0x06,
0x1a, 0x70, 0x0b, 0x69, 0x39, 0x59, 0x87, 0xf3, 0xf3, 0xdc, 0x48, 0x0b, 0x09, 0xa2, 0x0c, 0x55,
0xc2, 0x70, 0x8a, 0xcf, 0x30, 0x59, 0x53, 0x91, 0x64, 0x15, 0x36, 0x6d, 0xd2, 0xc0, 0x5c, 0x11,
0xb5, 0x10, 0x92, 0x03, 0x4e, 0x7d, 0x25, 0xb9, 0x4b, 0x49, 0x0e, 0x09, 0xc2, 0xe2, 0x82, 0x53,
0x76, 0x82, 0x4d, 0xc9, 0xee, 0x96, 0xec, 0x08, 0x45, 0x04, 0xbb, 0x44, 0xcb, 0x4e, 0x81, 0x05,
0x3c, 0x7d, 0x42, 0x72, 0xc3, 0x35, 0xbe, 0x09, 0xe0, 0x51, 0x9f, 0x96, 0x18, 0x67, 0x7e, 0x90,
0xee, 0x91, 0x71, 0x99, 0x88, 0x8f, 0xcb, 0x03, 0xb3, 0x2f, 0x1b, 0x39, 0x82, 0xe7, 0xa1, 0xbf,
0x3e, 0xc9, 0xd2, 0xbd, 0xf2, 0xed, 0x18, 0xac, 0x11, 0x63, 0x98, 0xd9, 0x86, 0xed, 0x64, 0x19,
0xac, 0x64, 0x65, 0xa1, 0x97, 0x50, 0xad, 0x97, 0xb6, 0x69, 0xb1, 0x62, 0xee, 0xb9, 0x5a, 0x90,
0x8b, 0xd0, 0xbf, 0xff, 0x5a, 0xe8, 0xac, 0xc4, 0xd0, 0x99, 0xa7, 0x9c, 0xca, 0xd3, 0x27, 0xb3,
0xf2, 0x9b, 0x7c, 0x8f, 0xa0, 0x73, 0xd9, 0x29, 0xea, 0x4c, 0xe7, 0x9b, 0x46, 0xb4, 0xf8, 0x8e,
0xad, 0x20, 0xa3, 0xd0, 0xcb, 0x9e, 0x71, 0x56, 0x8e, 0xdc, 0xac, 0x7d, 0x82, 0x38, 0x11, 0x98,
0x7b, 0x94, 0xca, 0xca, 0x6f, 0x3c, 0x09, 0x7d, 0x3a, 0x57, 0xd6, 0x76, 0x3d, 0xa6, 0x43, 0x16,
0x25, 0x61, 0x02, 0x27, 0x8b, 0x34, 0xe0, 0xf7, 0xdc, 0xbc, 0x53, 0x70, 0x58, 0x5e, 0x87, 0xad,
0x86, 0x26, 0xf4, 0xe6, 0x1d, 0x9f, 0xe5, 0xb8, 0xeb, 0xef, 0xca, 0xc8, 0xf5, 0x64, 0xf7, 0x09,
0xe4, 0x29, 0xf4, 0x8b, 0x2b, 0x29, 0x2c, 0x39, 0x42, 0x75, 0x34, 0x3e, 0x48, 0xed, 0xfb, 0x80,
0xac, 0xc1, 0x40, 0x44, 0xb2, 0xf6, 0xe4, 0x04, 0x74, 0x15, 0x04, 0x41, 0xd7, 0xc0, 0x5e, 0x19,
0x5d, 0xb1, 0x25, 0xab, 0xe8, 0x22, 0x0d, 0x3d, 0xea, 0xb3, 0x32, 0x7f, 0x20, 0xe4, 0x29, 0x1d,
0x11, 0x0a, 0x99, 0x85, 0x9e, 0xbb, 0x6c, 0xf7, 0xb1, 0x08, 0x95, 0x79, 0x93, 0x51, 0xf8, 0x26,
0x27, 0x84, 0xf4, 0x32, 0x74, 0xaf, 0xd2, 0x75, 0x56, 0x0c, 0xf0, 0x14, 0x74, 0x39, 0x9c, 0x95,
0x8c, 0xfa, 0x53, 0x52, 0xbd, 0x91, 0x97, 0x55, 0x3c, 0xe2, 0x40, 0xff, 0x7c, 0x3e, 0xaf, 0x4e,
0xb4, 0xef, 0x92, 0x29, 0xe8, 0x2e, 0x4a, 0x11, 0xd2, 0x29, 0xa6, 0xdc, 0x6b, 0xa9, 0x9a, 0x45,
0x4a, 0x70, 0x26, 0xcb, 0xbc, 0x22, 0xcd, 0xb1, 0x3f, 0x45, 0xdd, 0x22, 0xf4, 0xaf, 0x30, 0x7e,
0x44, 0x55, 0x64, 0x0e, 0x06, 0x22, 0x52, 0xc2, 0xe7, 0xcd, 0xe8, 0x8f, 0x75, 0xad, 0x41, 0xf0,
0x14, 0xf0, 0x22, 0x2b, 0x32, 0xae, 0xec, 0x3d, 0xc6, 0x76, 0x6c, 0xf6, 0x97, 0x49, 0xf8, 0xab,
0x29, 0x00, 0x0f, 0x99, 0xbf, 0xed, 0xe4, 0x18, 0xfe, 0x02, 0xc1, 0x70, 0x42, 0x53, 0x8b, 0xa7,
0x24, 0xc0, 0xe6, 0x2d, 0xaf, 0x95, 0xf0, 0xb8, 0x90, 0xff, 0xbd, 0xf7, 0xea, 0xd7, 0xe7, 0x1d,
0xb7, 0xc9, 0x65, 0xd1, 0x91, 0x07, 0xf6, 0xf6, 0xd5, 0x75, 0xc6, 0xe9, 0x55, 0x7b, 0x2f, 0x04,
0x5d, 0xb5, 0xc3, 0xb6, 0x9b, 0x85, 0xef, 0xcf, 0x5c, 0x63, 0xc3, 0x8b, 0x3f, 0x42, 0x70, 0x26,
0xae, 0x7d, 0xc0, 0x93, 0x52, 0x75, 0x93, 0x66, 0x38, 0x11, 0xdc, 0x75, 0x09, 0xee, 0x5f, 0xf8,
0x5a, 0x4b, 0xe0, 0x14, 0xbf, 0x8a, 0x5f, 0x20, 0x18, 0x8a, 0x7f, 0xa4, 0x31, 0x51, 0x39, 0xd5,
0xac, 0x3b, 0xb1, 0xa6, 0x9a, 0xee, 0x51, 0xc9, 0x42, 0xfe, 0x29, 0x11, 0xda, 0xb8, 0x35, 0xf7,
0xe1, 0x97, 0x08, 0x86, 0xe2, 0x5b, 0x6e, 0x0d, 0xad, 0x69, 0x3f, 0x9e, 0xe8, 0xaf, 0xdb, 0x12,
0xcd, 0x75, 0x3c, 0xd7, 0x8e, 0xbf, 0xec, 0x1d, 0xa1, 0xf3, 0x0a, 0xc2, 0xdf, 0x22, 0x48, 0x27,
0xb5, 0xc3, 0xf8, 0x7c, 0x62, 0x30, 0x23, 0xdd, 0xb2, 0xa5, 0xee, 0x8c, 0xe9, 0x2b, 0xc8, 0x96,
0xc4, 0xc5, 0x70, 0xae, 0x2d, 0x5c, 0x9e, 0x9b, 0x0f, 0xec, 0x3d, 0xdd, 0xa4, 0x56, 0xed, 0xb0,
0x4b, 0x0e, 0xec, 0xbd, 0x9a, 0x8e, 0xb9, 0x6a, 0x17, 0xdd, 0x8d, 0xe0, 0x0a, 0xc2, 0x3f, 0xa0,
0xf8, 0xd9, 0x4b, 0x37, 0xb2, 0xf8, 0x6f, 0x89, 0x36, 0xd4, 0x36, 0xd7, 0xd6, 0xf4, 0xc1, 0x1b,
0x75, 0x1e, 0x3c, 0x94, 0x16, 0xde, 0xc3, 0x77, 0x8f, 0xc3, 0x42, 0xdd, 0x41, 0xe3, 0x2f, 0x11,
0x8c, 0x24, 0x4e, 0x51, 0xf8, 0x82, 0x04, 0x77, 0xd0, 0x94, 0x95, 0x98, 0x2b, 0x4b, 0x12, 0xf1,
0x4d, 0xeb, 0x46, 0x5b, 0x88, 0x7d, 0xad, 0x16, 0x7f, 0x85, 0xc0, 0x4a, 0x9e, 0xc9, 0xf0, 0x45,
0xa9, 0xfd, 0xc0, 0xa1, 0xcd, 0x1a, 0xca, 0xa8, 0xc9, 0x3f, 0x63, 0x26, 0xff, 0xcc, 0x92, 0x98,
0xfc, 0xc9, 0xb2, 0x44, 0x79, 0xcb, 0xfa, 0x6f, 0x5b, 0x28, 0xb9, 0xd1, 0x8b, 0x3f, 0x43, 0x30,
0x54, 0x5b, 0x21, 0x4d, 0xbb, 0xa5, 0x2f, 0x5c, 0x3c, 0xd3, 0xc0, 0x8b, 0xef, 0xdd, 0x0c, 0x3a,
0xf2, 0xf7, 0x43, 0xa0, 0x33, 0xff, 0x59, 0x04, 0x73, 0x0d, 0x1d, 0x1f, 0xfe, 0x0d, 0xc1, 0xd8,
0x23, 0x2f, 0x1f, 0x03, 0xc0, 0x0c, 0x28, 0x97, 0x24, 0x80, 0xa6, 0x7b, 0x0e, 0xc0, 0xfa, 0x2e,
0x92, 0x60, 0xf7, 0xac, 0x8d, 0x56, 0xc0, 0xda, 0x7b, 0xf5, 0x60, 0x33, 0x15, 0x27, 0x5f, 0xb5,
0xb7, 0x95, 0xce, 0x38, 0xbe, 0x66, 0x55, 0x63, 0xec, 0xfc, 0x0e, 0xc1, 0x58, 0xbc, 0xa3, 0x8d,
0x9d, 0x47, 0x08, 0x46, 0x41, 0xda, 0xf7, 0x16, 0x59, 0x3d, 0x4e, 0xfb, 0x62, 0x8c, 0x78, 0x85,
0xe0, 0x74, 0xa4, 0x24, 0x84, 0xf4, 0x89, 0xfa, 0x62, 0x71, 0x48, 0xdc, 0xef, 0xab, 0xc0, 0x54,
0xf1, 0x6c, 0x6b, 0xc0, 0x05, 0xce, 0x37, 0x56, 0xf0, 0x52, 0xeb, 0xa7, 0x22, 0xd1, 0x33, 0xc1,
0xc2, 0xdf, 0x20, 0x18, 0x8d, 0xbe, 0x75, 0x75, 0x81, 0x09, 0xf0, 0x74, 0xc3, 0x73, 0x58, 0xbf,
0xc5, 0xd8, 0x79, 0xe9, 0x10, 0x3b, 0x75, 0xd9, 0x5c, 0x90, 0xa6, 0xdf, 0xc0, 0xff, 0x39, 0x82,
0x11, 0xf8, 0x13, 0x04, 0x83, 0x71, 0xda, 0x02, 0x7c, 0x2e, 0x11, 0x49, 0x08, 0x96, 0x34, 0xdb,
0xa2, 0x51, 0x5e, 0x93, 0x28, 0x33, 0xb8, 0xa5, 0x6b, 0x8e, 0xbf, 0x46, 0x30, 0x3c, 0xef, 0xe7,
0x36, 0x9d, 0xed, 0xc6, 0x9a, 0xa3, 0x7a, 0x8b, 0x04, 0xae, 0x81, 0x76, 0xbe, 0xf9, 0x26, 0x0d,
0x4e, 0xbf, 0xf9, 0xd6, 0x5c, 0x1b, 0x2e, 0xa4, 0x4a, 0xb6, 0x68, 0xdd, 0xfa, 0x22, 0xff, 0x2d,
0xe2, 0x61, 0x93, 0xca, 0x75, 0xff, 0x36, 0xea, 0x14, 0xae, 0x9f, 0x2a, 0xc9, 0x7d, 0x89, 0xe1,
0x0e, 0x5e, 0x69, 0xab, 0x4a, 0x53, 0x2d, 0x2e, 0xb0, 0xf7, 0xb6, 0xd8, 0xee, 0x8d, 0x99, 0x99,
0x2a, 0xfe, 0x10, 0x41, 0x6f, 0x38, 0x72, 0xe1, 0xc1, 0x30, 0x46, 0xd1, 0xe1, 0x4e, 0xbf, 0x6c,
0x0d, 0x93, 0x19, 0x59, 0x95, 0x68, 0x96, 0xf1, 0x62, 0x5b, 0x68, 0xe4, 0xf0, 0x66, 0xef, 0x89,
0xc1, 0x4f, 0x42, 0xf9, 0x18, 0x81, 0x15, 0xdb, 0xee, 0xa8, 0x39, 0x6c, 0xd0, 0xb8, 0xaa, 0x66,
0x16, 0xd1, 0xd8, 0x1a, 0x86, 0x8b, 0x96, 0x12, 0xbe, 0x11, 0x9b, 0x1a, 0x3d, 0x44, 0x63, 0x6b,
0xcd, 0xe7, 0xf3, 0xcd, 0x21, 0xd5, 0x0f, 0x7e, 0x89, 0x90, 0xee, 0x4a, 0x48, 0x4b, 0xe4, 0x28,
0x90, 0xe6, 0xf4, 0x54, 0x24, 0xe6, 0x94, 0x71, 0x3d, 0x07, 0x26, 0xc1, 0x1b, 0xd1, 0x7d, 0x4b,
0xe3, 0xb0, 0x78, 0x10, 0x44, 0xeb, 0x58, 0x20, 0xbe, 0x44, 0x30, 0xaa, 0x26, 0xb7, 0x78, 0x84,
0x3a, 0xfb, 0x1b, 0x87, 0xbb, 0x44, 0x78, 0x77, 0x24, 0xbc, 0x85, 0x99, 0xf9, 0x23, 0xc0, 0x93,
0xb9, 0x5f, 0x15, 0x37, 0x71, 0x24, 0xe6, 0x09, 0x69, 0x2f, 0xd9, 0x5a, 0x19, 0x07, 0x22, 0xa5,
0xa1, 0x26, 0xd7, 0x3e, 0x45, 0x30, 0x12, 0xc9, 0xb5, 0x58, 0x40, 0x87, 0x4e, 0xb5, 0xff, 0x4b,
0x40, 0x8b, 0xe4, 0x08, 0x80, 0xc2, 0x30, 0x7e, 0x8e, 0x60, 0xac, 0x2e, 0xd3, 0xea, 0xc0, 0xb5,
0x91, 0x68, 0x1a, 0xa0, 0x75, 0x1c, 0x00, 0x5f, 0x20, 0x38, 0x5b, 0x9b, 0x67, 0x35, 0xf8, 0x5a,
0x4f, 0x33, 0x3d, 0xaa, 0xcf, 0xdc, 0x6a, 0x1f, 0x9c, 0xca, 0xb2, 0xf5, 0x6e, 0xd9, 0x65, 0xff,
0xe3, 0xf7, 0x00, 0x00, 0x00, 0xff, 0xff, 0x63, 0x83, 0x4e, 0x73, 0xa2, 0x1b, 0x00, 0x00,
}
// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConnInterface
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion6
// 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.
type WorkflowServiceClient interface {
// Creates a Workflow
CreateWorkflowExecution(ctx context.Context, in *CreateWorkflowExecutionRequest, opts ...grpc.CallOption) (*WorkflowExecution, error)
GetWorkflowExecution(ctx context.Context, in *GetWorkflowExecutionRequest, opts ...grpc.CallOption) (*WorkflowExecution, error)
ListWorkflowExecutions(ctx context.Context, in *ListWorkflowExecutionsRequest, opts ...grpc.CallOption) (*ListWorkflowExecutionsResponse, error)
WatchWorkflowExecution(ctx context.Context, in *WatchWorkflowExecutionRequest, opts ...grpc.CallOption) (WorkflowService_WatchWorkflowExecutionClient, error)
GetWorkflowExecutionLogs(ctx context.Context, in *GetWorkflowExecutionLogsRequest, opts ...grpc.CallOption) (WorkflowService_GetWorkflowExecutionLogsClient, error)
GetWorkflowExecutionMetrics(ctx context.Context, in *GetWorkflowExecutionMetricsRequest, opts ...grpc.CallOption) (*GetWorkflowExecutionMetricsResponse, error)
ResubmitWorkflowExecution(ctx context.Context, in *ResubmitWorkflowExecutionRequest, opts ...grpc.CallOption) (*WorkflowExecution, error)
TerminateWorkflowExecution(ctx context.Context, in *TerminateWorkflowExecutionRequest, opts ...grpc.CallOption) (*empty.Empty, error)
CreateWorkflowTemplate(ctx context.Context, in *CreateWorkflowTemplateRequest, opts ...grpc.CallOption) (*WorkflowTemplate, error)
UpdateWorkflowTemplateVersion(ctx context.Context, in *UpdateWorkflowTemplateVersionRequest, opts ...grpc.CallOption) (*WorkflowTemplate, error)
CreateWorkflowTemplateVersion(ctx context.Context, in *CreateWorkflowTemplateRequest, opts ...grpc.CallOption) (*WorkflowTemplate, error)
GetWorkflowTemplate(ctx context.Context, in *GetWorkflowTemplateRequest, opts ...grpc.CallOption) (*WorkflowTemplate, error)
ListWorkflowTemplateVersions(ctx context.Context, in *ListWorkflowTemplateVersionsRequest, opts ...grpc.CallOption) (*ListWorkflowTemplateVersionsResponse, error)
ListWorkflowTemplates(ctx context.Context, in *ListWorkflowTemplatesRequest, opts ...grpc.CallOption) (*ListWorkflowTemplatesResponse, error)
ArchiveWorkflowTemplate(ctx context.Context, in *ArchiveWorkflowTemplateRequest, opts ...grpc.CallOption) (*ArchiveWorkflowTemplateResponse, error)
GetArtifact(ctx context.Context, in *GetArtifactRequest, opts ...grpc.CallOption) (*ArtifactResponse, error)
ListFiles(ctx context.Context, in *ListFilesRequest, opts ...grpc.CallOption) (*ListFilesResponse, error)
GetWorkflowExecutionLabels(ctx context.Context, in *GetLabelsRequest, opts ...grpc.CallOption) (*GetLabelsResponse, error)
AddWorkflowExecutionLabels(ctx context.Context, in *AddLabelsRequest, opts ...grpc.CallOption) (*GetLabelsResponse, error)
ReplaceWorkflowExecutionLabels(ctx context.Context, in *ReplaceLabelsRequest, opts ...grpc.CallOption) (*GetLabelsResponse, error)
DeleteWorkflowExecutionLabel(ctx context.Context, in *DeleteLabelRequest, opts ...grpc.CallOption) (*GetLabelsResponse, error)
GetWorkflowTemplateLabels(ctx context.Context, in *GetLabelsRequest, opts ...grpc.CallOption) (*GetLabelsResponse, error)
AddWorkflowTemplateLabels(ctx context.Context, in *AddLabelsRequest, opts ...grpc.CallOption) (*GetLabelsResponse, error)
ReplaceWorkflowTemplateLabels(ctx context.Context, in *ReplaceLabelsRequest, opts ...grpc.CallOption) (*GetLabelsResponse, error)
DeleteWorkflowTemplateLabel(ctx context.Context, in *DeleteLabelRequest, opts ...grpc.CallOption) (*GetLabelsResponse, error)
}
type workflowServiceClient struct {
cc grpc.ClientConnInterface
}
func NewWorkflowServiceClient(cc grpc.ClientConnInterface) WorkflowServiceClient {
return &workflowServiceClient{cc}
}
func (c *workflowServiceClient) CreateWorkflowExecution(ctx context.Context, in *CreateWorkflowExecutionRequest, opts ...grpc.CallOption) (*WorkflowExecution, error) {
out := new(WorkflowExecution)
err := c.cc.Invoke(ctx, "/api.WorkflowService/CreateWorkflowExecution", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *workflowServiceClient) GetWorkflowExecution(ctx context.Context, in *GetWorkflowExecutionRequest, opts ...grpc.CallOption) (*WorkflowExecution, error) {
out := new(WorkflowExecution)
err := c.cc.Invoke(ctx, "/api.WorkflowService/GetWorkflowExecution", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *workflowServiceClient) ListWorkflowExecutions(ctx context.Context, in *ListWorkflowExecutionsRequest, opts ...grpc.CallOption) (*ListWorkflowExecutionsResponse, error) {
out := new(ListWorkflowExecutionsResponse)
err := c.cc.Invoke(ctx, "/api.WorkflowService/ListWorkflowExecutions", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *workflowServiceClient) WatchWorkflowExecution(ctx context.Context, in *WatchWorkflowExecutionRequest, opts ...grpc.CallOption) (WorkflowService_WatchWorkflowExecutionClient, error) {
stream, err := c.cc.NewStream(ctx, &_WorkflowService_serviceDesc.Streams[0], "/api.WorkflowService/WatchWorkflowExecution", opts...)
if err != nil {
return nil, err
}
x := &workflowServiceWatchWorkflowExecutionClient{stream}
if err := x.ClientStream.SendMsg(in); err != nil {
return nil, err
}
if err := x.ClientStream.CloseSend(); err != nil {
return nil, err
}
return x, nil
}
type WorkflowService_WatchWorkflowExecutionClient interface {
Recv() (*WorkflowExecution, error)
grpc.ClientStream
}
type workflowServiceWatchWorkflowExecutionClient struct {
grpc.ClientStream
}
func (x *workflowServiceWatchWorkflowExecutionClient) Recv() (*WorkflowExecution, error) {
m := new(WorkflowExecution)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
func (c *workflowServiceClient) GetWorkflowExecutionLogs(ctx context.Context, in *GetWorkflowExecutionLogsRequest, opts ...grpc.CallOption) (WorkflowService_GetWorkflowExecutionLogsClient, error) {
stream, err := c.cc.NewStream(ctx, &_WorkflowService_serviceDesc.Streams[1], "/api.WorkflowService/GetWorkflowExecutionLogs", opts...)
if err != nil {
return nil, err
}
x := &workflowServiceGetWorkflowExecutionLogsClient{stream}
if err := x.ClientStream.SendMsg(in); err != nil {
return nil, err
}
if err := x.ClientStream.CloseSend(); err != nil {
return nil, err
}
return x, nil
}
type WorkflowService_GetWorkflowExecutionLogsClient interface {
Recv() (*LogEntry, error)
grpc.ClientStream
}
type workflowServiceGetWorkflowExecutionLogsClient struct {
grpc.ClientStream
}
func (x *workflowServiceGetWorkflowExecutionLogsClient) Recv() (*LogEntry, error) {
m := new(LogEntry)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
func (c *workflowServiceClient) GetWorkflowExecutionMetrics(ctx context.Context, in *GetWorkflowExecutionMetricsRequest, opts ...grpc.CallOption) (*GetWorkflowExecutionMetricsResponse, error) {
out := new(GetWorkflowExecutionMetricsResponse)
err := c.cc.Invoke(ctx, "/api.WorkflowService/GetWorkflowExecutionMetrics", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *workflowServiceClient) ResubmitWorkflowExecution(ctx context.Context, in *ResubmitWorkflowExecutionRequest, opts ...grpc.CallOption) (*WorkflowExecution, error) {
out := new(WorkflowExecution)
err := c.cc.Invoke(ctx, "/api.WorkflowService/ResubmitWorkflowExecution", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *workflowServiceClient) TerminateWorkflowExecution(ctx context.Context, in *TerminateWorkflowExecutionRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
out := new(empty.Empty)
err := c.cc.Invoke(ctx, "/api.WorkflowService/TerminateWorkflowExecution", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *workflowServiceClient) CreateWorkflowTemplate(ctx context.Context, in *CreateWorkflowTemplateRequest, opts ...grpc.CallOption) (*WorkflowTemplate, error) {
out := new(WorkflowTemplate)
err := c.cc.Invoke(ctx, "/api.WorkflowService/CreateWorkflowTemplate", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *workflowServiceClient) UpdateWorkflowTemplateVersion(ctx context.Context, in *UpdateWorkflowTemplateVersionRequest, opts ...grpc.CallOption) (*WorkflowTemplate, error) {
out := new(WorkflowTemplate)
err := c.cc.Invoke(ctx, "/api.WorkflowService/UpdateWorkflowTemplateVersion", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *workflowServiceClient) CreateWorkflowTemplateVersion(ctx context.Context, in *CreateWorkflowTemplateRequest, opts ...grpc.CallOption) (*WorkflowTemplate, error) {
out := new(WorkflowTemplate)
err := c.cc.Invoke(ctx, "/api.WorkflowService/CreateWorkflowTemplateVersion", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *workflowServiceClient) GetWorkflowTemplate(ctx context.Context, in *GetWorkflowTemplateRequest, opts ...grpc.CallOption) (*WorkflowTemplate, error) {
out := new(WorkflowTemplate)
err := c.cc.Invoke(ctx, "/api.WorkflowService/GetWorkflowTemplate", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *workflowServiceClient) ListWorkflowTemplateVersions(ctx context.Context, in *ListWorkflowTemplateVersionsRequest, opts ...grpc.CallOption) (*ListWorkflowTemplateVersionsResponse, error) {
out := new(ListWorkflowTemplateVersionsResponse)
err := c.cc.Invoke(ctx, "/api.WorkflowService/ListWorkflowTemplateVersions", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *workflowServiceClient) ListWorkflowTemplates(ctx context.Context, in *ListWorkflowTemplatesRequest, opts ...grpc.CallOption) (*ListWorkflowTemplatesResponse, error) {
out := new(ListWorkflowTemplatesResponse)
err := c.cc.Invoke(ctx, "/api.WorkflowService/ListWorkflowTemplates", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *workflowServiceClient) ArchiveWorkflowTemplate(ctx context.Context, in *ArchiveWorkflowTemplateRequest, opts ...grpc.CallOption) (*ArchiveWorkflowTemplateResponse, error) {
out := new(ArchiveWorkflowTemplateResponse)
err := c.cc.Invoke(ctx, "/api.WorkflowService/ArchiveWorkflowTemplate", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *workflowServiceClient) GetArtifact(ctx context.Context, in *GetArtifactRequest, opts ...grpc.CallOption) (*ArtifactResponse, error) {
out := new(ArtifactResponse)
err := c.cc.Invoke(ctx, "/api.WorkflowService/GetArtifact", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *workflowServiceClient) ListFiles(ctx context.Context, in *ListFilesRequest, opts ...grpc.CallOption) (*ListFilesResponse, error) {
out := new(ListFilesResponse)
err := c.cc.Invoke(ctx, "/api.WorkflowService/ListFiles", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *workflowServiceClient) GetWorkflowExecutionLabels(ctx context.Context, in *GetLabelsRequest, opts ...grpc.CallOption) (*GetLabelsResponse, error) {
out := new(GetLabelsResponse)
err := c.cc.Invoke(ctx, "/api.WorkflowService/GetWorkflowExecutionLabels", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *workflowServiceClient) AddWorkflowExecutionLabels(ctx context.Context, in *AddLabelsRequest, opts ...grpc.CallOption) (*GetLabelsResponse, error) {
out := new(GetLabelsResponse)
err := c.cc.Invoke(ctx, "/api.WorkflowService/AddWorkflowExecutionLabels", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *workflowServiceClient) ReplaceWorkflowExecutionLabels(ctx context.Context, in *ReplaceLabelsRequest, opts ...grpc.CallOption) (*GetLabelsResponse, error) {
out := new(GetLabelsResponse)
err := c.cc.Invoke(ctx, "/api.WorkflowService/ReplaceWorkflowExecutionLabels", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *workflowServiceClient) DeleteWorkflowExecutionLabel(ctx context.Context, in *DeleteLabelRequest, opts ...grpc.CallOption) (*GetLabelsResponse, error) {
out := new(GetLabelsResponse)
err := c.cc.Invoke(ctx, "/api.WorkflowService/DeleteWorkflowExecutionLabel", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *workflowServiceClient) GetWorkflowTemplateLabels(ctx context.Context, in *GetLabelsRequest, opts ...grpc.CallOption) (*GetLabelsResponse, error) {
out := new(GetLabelsResponse)
err := c.cc.Invoke(ctx, "/api.WorkflowService/GetWorkflowTemplateLabels", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *workflowServiceClient) AddWorkflowTemplateLabels(ctx context.Context, in *AddLabelsRequest, opts ...grpc.CallOption) (*GetLabelsResponse, error) {
out := new(GetLabelsResponse)
err := c.cc.Invoke(ctx, "/api.WorkflowService/AddWorkflowTemplateLabels", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *workflowServiceClient) ReplaceWorkflowTemplateLabels(ctx context.Context, in *ReplaceLabelsRequest, opts ...grpc.CallOption) (*GetLabelsResponse, error) {
out := new(GetLabelsResponse)
err := c.cc.Invoke(ctx, "/api.WorkflowService/ReplaceWorkflowTemplateLabels", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *workflowServiceClient) DeleteWorkflowTemplateLabel(ctx context.Context, in *DeleteLabelRequest, opts ...grpc.CallOption) (*GetLabelsResponse, error) {
out := new(GetLabelsResponse)
err := c.cc.Invoke(ctx, "/api.WorkflowService/DeleteWorkflowTemplateLabel", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// WorkflowServiceServer is the server API for WorkflowService service.
type WorkflowServiceServer interface {
// Creates a Workflow
CreateWorkflowExecution(context.Context, *CreateWorkflowExecutionRequest) (*WorkflowExecution, error)
GetWorkflowExecution(context.Context, *GetWorkflowExecutionRequest) (*WorkflowExecution, error)
ListWorkflowExecutions(context.Context, *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)
WatchWorkflowExecution(*WatchWorkflowExecutionRequest, WorkflowService_WatchWorkflowExecutionServer) error
GetWorkflowExecutionLogs(*GetWorkflowExecutionLogsRequest, WorkflowService_GetWorkflowExecutionLogsServer) error
GetWorkflowExecutionMetrics(context.Context, *GetWorkflowExecutionMetricsRequest) (*GetWorkflowExecutionMetricsResponse, error)
ResubmitWorkflowExecution(context.Context, *ResubmitWorkflowExecutionRequest) (*WorkflowExecution, error)
TerminateWorkflowExecution(context.Context, *TerminateWorkflowExecutionRequest) (*empty.Empty, error)
CreateWorkflowTemplate(context.Context, *CreateWorkflowTemplateRequest) (*WorkflowTemplate, error)
UpdateWorkflowTemplateVersion(context.Context, *UpdateWorkflowTemplateVersionRequest) (*WorkflowTemplate, error)
CreateWorkflowTemplateVersion(context.Context, *CreateWorkflowTemplateRequest) (*WorkflowTemplate, error)
GetWorkflowTemplate(context.Context, *GetWorkflowTemplateRequest) (*WorkflowTemplate, error)
ListWorkflowTemplateVersions(context.Context, *ListWorkflowTemplateVersionsRequest) (*ListWorkflowTemplateVersionsResponse, error)
ListWorkflowTemplates(context.Context, *ListWorkflowTemplatesRequest) (*ListWorkflowTemplatesResponse, error)
ArchiveWorkflowTemplate(context.Context, *ArchiveWorkflowTemplateRequest) (*ArchiveWorkflowTemplateResponse, error)
GetArtifact(context.Context, *GetArtifactRequest) (*ArtifactResponse, error)
ListFiles(context.Context, *ListFilesRequest) (*ListFilesResponse, error)
GetWorkflowExecutionLabels(context.Context, *GetLabelsRequest) (*GetLabelsResponse, error)
AddWorkflowExecutionLabels(context.Context, *AddLabelsRequest) (*GetLabelsResponse, error)
ReplaceWorkflowExecutionLabels(context.Context, *ReplaceLabelsRequest) (*GetLabelsResponse, error)
DeleteWorkflowExecutionLabel(context.Context, *DeleteLabelRequest) (*GetLabelsResponse, error)
GetWorkflowTemplateLabels(context.Context, *GetLabelsRequest) (*GetLabelsResponse, error)
AddWorkflowTemplateLabels(context.Context, *AddLabelsRequest) (*GetLabelsResponse, error)
ReplaceWorkflowTemplateLabels(context.Context, *ReplaceLabelsRequest) (*GetLabelsResponse, error)
DeleteWorkflowTemplateLabel(context.Context, *DeleteLabelRequest) (*GetLabelsResponse, error)
}
// UnimplementedWorkflowServiceServer can be embedded to have forward compatible implementations.
type UnimplementedWorkflowServiceServer struct {
}
func (*UnimplementedWorkflowServiceServer) CreateWorkflowExecution(ctx context.Context, req *CreateWorkflowExecutionRequest) (*WorkflowExecution, error) {
return nil, status.Errorf(codes.Unimplemented, "method CreateWorkflowExecution not implemented")
}
func (*UnimplementedWorkflowServiceServer) GetWorkflowExecution(ctx context.Context, req *GetWorkflowExecutionRequest) (*WorkflowExecution, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetWorkflowExecution not implemented")
}
func (*UnimplementedWorkflowServiceServer) ListWorkflowExecutions(ctx context.Context, req *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ListWorkflowExecutions not implemented")
}
func (*UnimplementedWorkflowServiceServer) WatchWorkflowExecution(req *WatchWorkflowExecutionRequest, srv WorkflowService_WatchWorkflowExecutionServer) error {
return status.Errorf(codes.Unimplemented, "method WatchWorkflowExecution not implemented")
}
func (*UnimplementedWorkflowServiceServer) GetWorkflowExecutionLogs(req *GetWorkflowExecutionLogsRequest, srv WorkflowService_GetWorkflowExecutionLogsServer) error {
return status.Errorf(codes.Unimplemented, "method GetWorkflowExecutionLogs not implemented")
}
func (*UnimplementedWorkflowServiceServer) GetWorkflowExecutionMetrics(ctx context.Context, req *GetWorkflowExecutionMetricsRequest) (*GetWorkflowExecutionMetricsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetWorkflowExecutionMetrics not implemented")
}
func (*UnimplementedWorkflowServiceServer) ResubmitWorkflowExecution(ctx context.Context, req *ResubmitWorkflowExecutionRequest) (*WorkflowExecution, error) {
return nil, status.Errorf(codes.Unimplemented, "method ResubmitWorkflowExecution not implemented")
}
func (*UnimplementedWorkflowServiceServer) TerminateWorkflowExecution(ctx context.Context, req *TerminateWorkflowExecutionRequest) (*empty.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method TerminateWorkflowExecution not implemented")
}
func (*UnimplementedWorkflowServiceServer) CreateWorkflowTemplate(ctx context.Context, req *CreateWorkflowTemplateRequest) (*WorkflowTemplate, error) {
return nil, status.Errorf(codes.Unimplemented, "method CreateWorkflowTemplate not implemented")
}
func (*UnimplementedWorkflowServiceServer) UpdateWorkflowTemplateVersion(ctx context.Context, req *UpdateWorkflowTemplateVersionRequest) (*WorkflowTemplate, error) {
return nil, status.Errorf(codes.Unimplemented, "method UpdateWorkflowTemplateVersion not implemented")
}
func (*UnimplementedWorkflowServiceServer) CreateWorkflowTemplateVersion(ctx context.Context, req *CreateWorkflowTemplateRequest) (*WorkflowTemplate, error) {
return nil, status.Errorf(codes.Unimplemented, "method CreateWorkflowTemplateVersion not implemented")
}
func (*UnimplementedWorkflowServiceServer) GetWorkflowTemplate(ctx context.Context, req *GetWorkflowTemplateRequest) (*WorkflowTemplate, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetWorkflowTemplate not implemented")
}
func (*UnimplementedWorkflowServiceServer) ListWorkflowTemplateVersions(ctx context.Context, req *ListWorkflowTemplateVersionsRequest) (*ListWorkflowTemplateVersionsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ListWorkflowTemplateVersions not implemented")
}
func (*UnimplementedWorkflowServiceServer) ListWorkflowTemplates(ctx context.Context, req *ListWorkflowTemplatesRequest) (*ListWorkflowTemplatesResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ListWorkflowTemplates not implemented")
}
func (*UnimplementedWorkflowServiceServer) ArchiveWorkflowTemplate(ctx context.Context, req *ArchiveWorkflowTemplateRequest) (*ArchiveWorkflowTemplateResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ArchiveWorkflowTemplate not implemented")
}
func (*UnimplementedWorkflowServiceServer) GetArtifact(ctx context.Context, req *GetArtifactRequest) (*ArtifactResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetArtifact not implemented")
}
func (*UnimplementedWorkflowServiceServer) ListFiles(ctx context.Context, req *ListFilesRequest) (*ListFilesResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ListFiles not implemented")
}
func (*UnimplementedWorkflowServiceServer) GetWorkflowExecutionLabels(ctx context.Context, req *GetLabelsRequest) (*GetLabelsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetWorkflowExecutionLabels not implemented")
}
func (*UnimplementedWorkflowServiceServer) AddWorkflowExecutionLabels(ctx context.Context, req *AddLabelsRequest) (*GetLabelsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method AddWorkflowExecutionLabels not implemented")
}
func (*UnimplementedWorkflowServiceServer) ReplaceWorkflowExecutionLabels(ctx context.Context, req *ReplaceLabelsRequest) (*GetLabelsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ReplaceWorkflowExecutionLabels not implemented")
}
func (*UnimplementedWorkflowServiceServer) DeleteWorkflowExecutionLabel(ctx context.Context, req *DeleteLabelRequest) (*GetLabelsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method DeleteWorkflowExecutionLabel not implemented")
}
func (*UnimplementedWorkflowServiceServer) GetWorkflowTemplateLabels(ctx context.Context, req *GetLabelsRequest) (*GetLabelsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetWorkflowTemplateLabels not implemented")
}
func (*UnimplementedWorkflowServiceServer) AddWorkflowTemplateLabels(ctx context.Context, req *AddLabelsRequest) (*GetLabelsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method AddWorkflowTemplateLabels not implemented")
}
func (*UnimplementedWorkflowServiceServer) ReplaceWorkflowTemplateLabels(ctx context.Context, req *ReplaceLabelsRequest) (*GetLabelsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ReplaceWorkflowTemplateLabels not implemented")
}
func (*UnimplementedWorkflowServiceServer) DeleteWorkflowTemplateLabel(ctx context.Context, req *DeleteLabelRequest) (*GetLabelsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method DeleteWorkflowTemplateLabel not implemented")
}
func RegisterWorkflowServiceServer(s *grpc.Server, srv WorkflowServiceServer) {
s.RegisterService(&_WorkflowService_serviceDesc, srv)
}
func _WorkflowService_CreateWorkflowExecution_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(CreateWorkflowExecutionRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(WorkflowServiceServer).CreateWorkflowExecution(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/api.WorkflowService/CreateWorkflowExecution",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(WorkflowServiceServer).CreateWorkflowExecution(ctx, req.(*CreateWorkflowExecutionRequest))
}
return interceptor(ctx, in, info, handler)
}
func _WorkflowService_GetWorkflowExecution_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetWorkflowExecutionRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(WorkflowServiceServer).GetWorkflowExecution(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/api.WorkflowService/GetWorkflowExecution",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(WorkflowServiceServer).GetWorkflowExecution(ctx, req.(*GetWorkflowExecutionRequest))
}
return interceptor(ctx, in, info, handler)
}
func _WorkflowService_ListWorkflowExecutions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ListWorkflowExecutionsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(WorkflowServiceServer).ListWorkflowExecutions(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/api.WorkflowService/ListWorkflowExecutions",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(WorkflowServiceServer).ListWorkflowExecutions(ctx, req.(*ListWorkflowExecutionsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _WorkflowService_WatchWorkflowExecution_Handler(srv interface{}, stream grpc.ServerStream) error {
m := new(WatchWorkflowExecutionRequest)
if err := stream.RecvMsg(m); err != nil {
return err
}
return srv.(WorkflowServiceServer).WatchWorkflowExecution(m, &workflowServiceWatchWorkflowExecutionServer{stream})
}
type WorkflowService_WatchWorkflowExecutionServer interface {
Send(*WorkflowExecution) error
grpc.ServerStream
}
type workflowServiceWatchWorkflowExecutionServer struct {
grpc.ServerStream
}
func (x *workflowServiceWatchWorkflowExecutionServer) Send(m *WorkflowExecution) error {
return x.ServerStream.SendMsg(m)
}
func _WorkflowService_GetWorkflowExecutionLogs_Handler(srv interface{}, stream grpc.ServerStream) error {
m := new(GetWorkflowExecutionLogsRequest)
if err := stream.RecvMsg(m); err != nil {
return err
}
return srv.(WorkflowServiceServer).GetWorkflowExecutionLogs(m, &workflowServiceGetWorkflowExecutionLogsServer{stream})
}
type WorkflowService_GetWorkflowExecutionLogsServer interface {
Send(*LogEntry) error
grpc.ServerStream
}
type workflowServiceGetWorkflowExecutionLogsServer struct {
grpc.ServerStream
}
func (x *workflowServiceGetWorkflowExecutionLogsServer) Send(m *LogEntry) error {
return x.ServerStream.SendMsg(m)
}
func _WorkflowService_GetWorkflowExecutionMetrics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetWorkflowExecutionMetricsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(WorkflowServiceServer).GetWorkflowExecutionMetrics(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/api.WorkflowService/GetWorkflowExecutionMetrics",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(WorkflowServiceServer).GetWorkflowExecutionMetrics(ctx, req.(*GetWorkflowExecutionMetricsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _WorkflowService_ResubmitWorkflowExecution_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ResubmitWorkflowExecutionRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(WorkflowServiceServer).ResubmitWorkflowExecution(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/api.WorkflowService/ResubmitWorkflowExecution",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(WorkflowServiceServer).ResubmitWorkflowExecution(ctx, req.(*ResubmitWorkflowExecutionRequest))
}
return interceptor(ctx, in, info, handler)
}
func _WorkflowService_TerminateWorkflowExecution_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(TerminateWorkflowExecutionRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(WorkflowServiceServer).TerminateWorkflowExecution(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/api.WorkflowService/TerminateWorkflowExecution",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(WorkflowServiceServer).TerminateWorkflowExecution(ctx, req.(*TerminateWorkflowExecutionRequest))
}
return interceptor(ctx, in, info, handler)
}
func _WorkflowService_CreateWorkflowTemplate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(CreateWorkflowTemplateRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(WorkflowServiceServer).CreateWorkflowTemplate(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/api.WorkflowService/CreateWorkflowTemplate",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(WorkflowServiceServer).CreateWorkflowTemplate(ctx, req.(*CreateWorkflowTemplateRequest))
}
return interceptor(ctx, in, info, handler)
}
func _WorkflowService_UpdateWorkflowTemplateVersion_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(UpdateWorkflowTemplateVersionRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(WorkflowServiceServer).UpdateWorkflowTemplateVersion(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/api.WorkflowService/UpdateWorkflowTemplateVersion",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(WorkflowServiceServer).UpdateWorkflowTemplateVersion(ctx, req.(*UpdateWorkflowTemplateVersionRequest))
}
return interceptor(ctx, in, info, handler)
}
func _WorkflowService_CreateWorkflowTemplateVersion_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(CreateWorkflowTemplateRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(WorkflowServiceServer).CreateWorkflowTemplateVersion(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/api.WorkflowService/CreateWorkflowTemplateVersion",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(WorkflowServiceServer).CreateWorkflowTemplateVersion(ctx, req.(*CreateWorkflowTemplateRequest))
}
return interceptor(ctx, in, info, handler)
}
func _WorkflowService_GetWorkflowTemplate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetWorkflowTemplateRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(WorkflowServiceServer).GetWorkflowTemplate(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/api.WorkflowService/GetWorkflowTemplate",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(WorkflowServiceServer).GetWorkflowTemplate(ctx, req.(*GetWorkflowTemplateRequest))
}
return interceptor(ctx, in, info, handler)
}
func _WorkflowService_ListWorkflowTemplateVersions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ListWorkflowTemplateVersionsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(WorkflowServiceServer).ListWorkflowTemplateVersions(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/api.WorkflowService/ListWorkflowTemplateVersions",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(WorkflowServiceServer).ListWorkflowTemplateVersions(ctx, req.(*ListWorkflowTemplateVersionsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _WorkflowService_ListWorkflowTemplates_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ListWorkflowTemplatesRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(WorkflowServiceServer).ListWorkflowTemplates(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/api.WorkflowService/ListWorkflowTemplates",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(WorkflowServiceServer).ListWorkflowTemplates(ctx, req.(*ListWorkflowTemplatesRequest))
}
return interceptor(ctx, in, info, handler)
}
func _WorkflowService_ArchiveWorkflowTemplate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ArchiveWorkflowTemplateRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(WorkflowServiceServer).ArchiveWorkflowTemplate(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/api.WorkflowService/ArchiveWorkflowTemplate",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(WorkflowServiceServer).ArchiveWorkflowTemplate(ctx, req.(*ArchiveWorkflowTemplateRequest))
}
return interceptor(ctx, in, info, handler)
}
func _WorkflowService_GetArtifact_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetArtifactRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(WorkflowServiceServer).GetArtifact(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/api.WorkflowService/GetArtifact",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(WorkflowServiceServer).GetArtifact(ctx, req.(*GetArtifactRequest))
}
return interceptor(ctx, in, info, handler)
}
func _WorkflowService_ListFiles_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ListFilesRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(WorkflowServiceServer).ListFiles(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/api.WorkflowService/ListFiles",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(WorkflowServiceServer).ListFiles(ctx, req.(*ListFilesRequest))
}
return interceptor(ctx, in, info, handler)
}
func _WorkflowService_GetWorkflowExecutionLabels_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetLabelsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(WorkflowServiceServer).GetWorkflowExecutionLabels(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/api.WorkflowService/GetWorkflowExecutionLabels",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(WorkflowServiceServer).GetWorkflowExecutionLabels(ctx, req.(*GetLabelsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _WorkflowService_AddWorkflowExecutionLabels_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(AddLabelsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(WorkflowServiceServer).AddWorkflowExecutionLabels(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/api.WorkflowService/AddWorkflowExecutionLabels",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(WorkflowServiceServer).AddWorkflowExecutionLabels(ctx, req.(*AddLabelsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _WorkflowService_ReplaceWorkflowExecutionLabels_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ReplaceLabelsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(WorkflowServiceServer).ReplaceWorkflowExecutionLabels(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/api.WorkflowService/ReplaceWorkflowExecutionLabels",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(WorkflowServiceServer).ReplaceWorkflowExecutionLabels(ctx, req.(*ReplaceLabelsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _WorkflowService_DeleteWorkflowExecutionLabel_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(DeleteLabelRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(WorkflowServiceServer).DeleteWorkflowExecutionLabel(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/api.WorkflowService/DeleteWorkflowExecutionLabel",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(WorkflowServiceServer).DeleteWorkflowExecutionLabel(ctx, req.(*DeleteLabelRequest))
}
return interceptor(ctx, in, info, handler)
}
func _WorkflowService_GetWorkflowTemplateLabels_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetLabelsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(WorkflowServiceServer).GetWorkflowTemplateLabels(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/api.WorkflowService/GetWorkflowTemplateLabels",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(WorkflowServiceServer).GetWorkflowTemplateLabels(ctx, req.(*GetLabelsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _WorkflowService_AddWorkflowTemplateLabels_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(AddLabelsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(WorkflowServiceServer).AddWorkflowTemplateLabels(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/api.WorkflowService/AddWorkflowTemplateLabels",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(WorkflowServiceServer).AddWorkflowTemplateLabels(ctx, req.(*AddLabelsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _WorkflowService_ReplaceWorkflowTemplateLabels_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ReplaceLabelsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(WorkflowServiceServer).ReplaceWorkflowTemplateLabels(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/api.WorkflowService/ReplaceWorkflowTemplateLabels",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(WorkflowServiceServer).ReplaceWorkflowTemplateLabels(ctx, req.(*ReplaceLabelsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _WorkflowService_DeleteWorkflowTemplateLabel_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(DeleteLabelRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(WorkflowServiceServer).DeleteWorkflowTemplateLabel(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/api.WorkflowService/DeleteWorkflowTemplateLabel",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(WorkflowServiceServer).DeleteWorkflowTemplateLabel(ctx, req.(*DeleteLabelRequest))
}
return interceptor(ctx, in, info, handler)
}
var _WorkflowService_serviceDesc = grpc.ServiceDesc{
ServiceName: "api.WorkflowService",
HandlerType: (*WorkflowServiceServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "CreateWorkflowExecution",
Handler: _WorkflowService_CreateWorkflowExecution_Handler,
},
{
MethodName: "GetWorkflowExecution",
Handler: _WorkflowService_GetWorkflowExecution_Handler,
},
{
MethodName: "ListWorkflowExecutions",
Handler: _WorkflowService_ListWorkflowExecutions_Handler,
},
{
MethodName: "GetWorkflowExecutionMetrics",
Handler: _WorkflowService_GetWorkflowExecutionMetrics_Handler,
},
{
MethodName: "ResubmitWorkflowExecution",
Handler: _WorkflowService_ResubmitWorkflowExecution_Handler,
},
{
MethodName: "TerminateWorkflowExecution",
Handler: _WorkflowService_TerminateWorkflowExecution_Handler,
},
{
MethodName: "CreateWorkflowTemplate",
Handler: _WorkflowService_CreateWorkflowTemplate_Handler,
},
{
MethodName: "UpdateWorkflowTemplateVersion",
Handler: _WorkflowService_UpdateWorkflowTemplateVersion_Handler,
},
{
MethodName: "CreateWorkflowTemplateVersion",
Handler: _WorkflowService_CreateWorkflowTemplateVersion_Handler,
},
{
MethodName: "GetWorkflowTemplate",
Handler: _WorkflowService_GetWorkflowTemplate_Handler,
},
{
MethodName: "ListWorkflowTemplateVersions",
Handler: _WorkflowService_ListWorkflowTemplateVersions_Handler,
},
{
MethodName: "ListWorkflowTemplates",
Handler: _WorkflowService_ListWorkflowTemplates_Handler,
},
{
MethodName: "ArchiveWorkflowTemplate",
Handler: _WorkflowService_ArchiveWorkflowTemplate_Handler,
},
{
MethodName: "GetArtifact",
Handler: _WorkflowService_GetArtifact_Handler,
},
{
MethodName: "ListFiles",
Handler: _WorkflowService_ListFiles_Handler,
},
{
MethodName: "GetWorkflowExecutionLabels",
Handler: _WorkflowService_GetWorkflowExecutionLabels_Handler,
},
{
MethodName: "AddWorkflowExecutionLabels",
Handler: _WorkflowService_AddWorkflowExecutionLabels_Handler,
},
{
MethodName: "ReplaceWorkflowExecutionLabels",
Handler: _WorkflowService_ReplaceWorkflowExecutionLabels_Handler,
},
{
MethodName: "DeleteWorkflowExecutionLabel",
Handler: _WorkflowService_DeleteWorkflowExecutionLabel_Handler,
},
{
MethodName: "GetWorkflowTemplateLabels",
Handler: _WorkflowService_GetWorkflowTemplateLabels_Handler,
},
{
MethodName: "AddWorkflowTemplateLabels",
Handler: _WorkflowService_AddWorkflowTemplateLabels_Handler,
},
{
MethodName: "ReplaceWorkflowTemplateLabels",
Handler: _WorkflowService_ReplaceWorkflowTemplateLabels_Handler,
},
{
MethodName: "DeleteWorkflowTemplateLabel",
Handler: _WorkflowService_DeleteWorkflowTemplateLabel_Handler,
},
},
Streams: []grpc.StreamDesc{
{
StreamName: "WatchWorkflowExecution",
Handler: _WorkflowService_WatchWorkflowExecution_Handler,
ServerStreams: true,
},
{
StreamName: "GetWorkflowExecutionLogs",
Handler: _WorkflowService_GetWorkflowExecutionLogs_Handler,
ServerStreams: true,
},
},
Metadata: "workflow.proto",
}
Reference in New Issue View Git Blame Copy Permalink