зеркало из https://github.com/github/vitess-gh.git
Update proto types to include warnings in workflow aggregations
Signed-off-by: Andrew Mason <amason@slack-corp.com>
This commit is contained in:
Andrew Mason
Родитель
cdfae90c36
Коммит
2f54aa6e84
|
|
@ -56,7 +56,7 @@ func (x Tablet_ServingState) String() string {
|
|||
}
|
||||
|
||||
func (Tablet_ServingState) EnumDescriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{3, 0}
|
||||
return fileDescriptor_609739e22a0a50b3, []int{4, 0}
|
||||
}
|
||||
|
||||
// Cluster represents information about a Vitess cluster.
|
||||
|
|
@ -115,6 +115,63 @@ func (m *Cluster) GetName() string {
|
|||
return ""
|
||||
}
|
||||
|
||||
type ClusterWorkflows struct {
|
||||
Workflows []*Workflow `protobuf:"bytes,1,rep,name=workflows,proto3" json:"workflows,omitempty"`
|
||||
// Warnings is a list of non-fatal errors encountered when fetching
|
||||
// workflows for a particular cluster.
|
||||
Warnings []string `protobuf:"bytes,2,rep,name=warnings,proto3" json:"warnings,omitempty"`
|
||||
XXX_NoUnkeyedLiteral struct{} `json:"-"`
|
||||
XXX_unrecognized []byte `json:"-"`
|
||||
XXX_sizecache int32 `json:"-"`
|
||||
}
|
||||
|
||||
func (m *ClusterWorkflows) Reset() { *m = ClusterWorkflows{} }
|
||||
func (m *ClusterWorkflows) String() string { return proto.CompactTextString(m) }
|
||||
func (*ClusterWorkflows) ProtoMessage() {}
|
||||
func (*ClusterWorkflows) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{1}
|
||||
}
|
||||
func (m *ClusterWorkflows) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
}
|
||||
func (m *ClusterWorkflows) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
if deterministic {
|
||||
return xxx_messageInfo_ClusterWorkflows.Marshal(b, m, deterministic)
|
||||
} else {
|
||||
b = b[:cap(b)]
|
||||
n, err := m.MarshalToSizedBuffer(b)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return b[:n], nil
|
||||
}
|
||||
}
|
||||
func (m *ClusterWorkflows) XXX_Merge(src proto.Message) {
|
||||
xxx_messageInfo_ClusterWorkflows.Merge(m, src)
|
||||
}
|
||||
func (m *ClusterWorkflows) XXX_Size() int {
|
||||
return m.Size()
|
||||
}
|
||||
func (m *ClusterWorkflows) XXX_DiscardUnknown() {
|
||||
xxx_messageInfo_ClusterWorkflows.DiscardUnknown(m)
|
||||
}
|
||||
|
||||
var xxx_messageInfo_ClusterWorkflows proto.InternalMessageInfo
|
||||
|
||||
func (m *ClusterWorkflows) GetWorkflows() []*Workflow {
|
||||
if m != nil {
|
||||
return m.Workflows
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *ClusterWorkflows) GetWarnings() []string {
|
||||
if m != nil {
|
||||
return m.Warnings
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
// Keyspace represents information about a keyspace in a particular Vitess
|
||||
// cluster.
|
||||
type Keyspace struct {
|
||||
|
|
@ -130,7 +187,7 @@ func (m *Keyspace) Reset() { *m = Keyspace{} }
|
|||
func (m *Keyspace) String() string { return proto.CompactTextString(m) }
|
||||
func (*Keyspace) ProtoMessage() {}
|
||||
func (*Keyspace) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{1}
|
||||
return fileDescriptor_609739e22a0a50b3, []int{2}
|
||||
}
|
||||
func (m *Keyspace) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
|
|
@ -193,7 +250,7 @@ func (m *Schema) Reset() { *m = Schema{} }
|
|||
func (m *Schema) String() string { return proto.CompactTextString(m) }
|
||||
func (*Schema) ProtoMessage() {}
|
||||
func (*Schema) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{2}
|
||||
return fileDescriptor_609739e22a0a50b3, []int{3}
|
||||
}
|
||||
func (m *Schema) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
|
|
@ -258,7 +315,7 @@ func (m *Tablet) Reset() { *m = Tablet{} }
|
|||
func (m *Tablet) String() string { return proto.CompactTextString(m) }
|
||||
func (*Tablet) ProtoMessage() {}
|
||||
func (*Tablet) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{3}
|
||||
return fileDescriptor_609739e22a0a50b3, []int{4}
|
||||
}
|
||||
func (m *Tablet) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
|
|
@ -323,7 +380,7 @@ func (m *VSchema) Reset() { *m = VSchema{} }
|
|||
func (m *VSchema) String() string { return proto.CompactTextString(m) }
|
||||
func (*VSchema) ProtoMessage() {}
|
||||
func (*VSchema) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{4}
|
||||
return fileDescriptor_609739e22a0a50b3, []int{5}
|
||||
}
|
||||
func (m *VSchema) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
|
|
@ -386,7 +443,7 @@ func (m *Vtctld) Reset() { *m = Vtctld{} }
|
|||
func (m *Vtctld) String() string { return proto.CompactTextString(m) }
|
||||
func (*Vtctld) ProtoMessage() {}
|
||||
func (*Vtctld) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{5}
|
||||
return fileDescriptor_609739e22a0a50b3, []int{6}
|
||||
}
|
||||
func (m *Vtctld) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
|
|
@ -452,7 +509,7 @@ func (m *VTGate) Reset() { *m = VTGate{} }
|
|||
func (m *VTGate) String() string { return proto.CompactTextString(m) }
|
||||
func (*VTGate) ProtoMessage() {}
|
||||
func (*VTGate) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{6}
|
||||
return fileDescriptor_609739e22a0a50b3, []int{7}
|
||||
}
|
||||
func (m *VTGate) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
|
|
@ -529,7 +586,7 @@ func (m *Workflow) Reset() { *m = Workflow{} }
|
|||
func (m *Workflow) String() string { return proto.CompactTextString(m) }
|
||||
func (*Workflow) ProtoMessage() {}
|
||||
func (*Workflow) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{7}
|
||||
return fileDescriptor_609739e22a0a50b3, []int{8}
|
||||
}
|
||||
func (m *Workflow) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
|
|
@ -591,7 +648,7 @@ func (m *FindSchemaRequest) Reset() { *m = FindSchemaRequest{} }
|
|||
func (m *FindSchemaRequest) String() string { return proto.CompactTextString(m) }
|
||||
func (*FindSchemaRequest) ProtoMessage() {}
|
||||
func (*FindSchemaRequest) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{8}
|
||||
return fileDescriptor_609739e22a0a50b3, []int{9}
|
||||
}
|
||||
func (m *FindSchemaRequest) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
|
|
@ -644,7 +701,7 @@ func (m *GetClustersRequest) Reset() { *m = GetClustersRequest{} }
|
|||
func (m *GetClustersRequest) String() string { return proto.CompactTextString(m) }
|
||||
func (*GetClustersRequest) ProtoMessage() {}
|
||||
func (*GetClustersRequest) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{9}
|
||||
return fileDescriptor_609739e22a0a50b3, []int{10}
|
||||
}
|
||||
func (m *GetClustersRequest) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
|
|
@ -684,7 +741,7 @@ func (m *GetClustersResponse) Reset() { *m = GetClustersResponse{} }
|
|||
func (m *GetClustersResponse) String() string { return proto.CompactTextString(m) }
|
||||
func (*GetClustersResponse) ProtoMessage() {}
|
||||
func (*GetClustersResponse) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{10}
|
||||
return fileDescriptor_609739e22a0a50b3, []int{11}
|
||||
}
|
||||
func (m *GetClustersResponse) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
|
|
@ -731,7 +788,7 @@ func (m *GetGatesRequest) Reset() { *m = GetGatesRequest{} }
|
|||
func (m *GetGatesRequest) String() string { return proto.CompactTextString(m) }
|
||||
func (*GetGatesRequest) ProtoMessage() {}
|
||||
func (*GetGatesRequest) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{11}
|
||||
return fileDescriptor_609739e22a0a50b3, []int{12}
|
||||
}
|
||||
func (m *GetGatesRequest) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
|
|
@ -778,7 +835,7 @@ func (m *GetGatesResponse) Reset() { *m = GetGatesResponse{} }
|
|||
func (m *GetGatesResponse) String() string { return proto.CompactTextString(m) }
|
||||
func (*GetGatesResponse) ProtoMessage() {}
|
||||
func (*GetGatesResponse) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{12}
|
||||
return fileDescriptor_609739e22a0a50b3, []int{13}
|
||||
}
|
||||
func (m *GetGatesResponse) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
|
|
@ -825,7 +882,7 @@ func (m *GetKeyspacesRequest) Reset() { *m = GetKeyspacesRequest{} }
|
|||
func (m *GetKeyspacesRequest) String() string { return proto.CompactTextString(m) }
|
||||
func (*GetKeyspacesRequest) ProtoMessage() {}
|
||||
func (*GetKeyspacesRequest) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{13}
|
||||
return fileDescriptor_609739e22a0a50b3, []int{14}
|
||||
}
|
||||
func (m *GetKeyspacesRequest) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
|
|
@ -872,7 +929,7 @@ func (m *GetKeyspacesResponse) Reset() { *m = GetKeyspacesResponse{} }
|
|||
func (m *GetKeyspacesResponse) String() string { return proto.CompactTextString(m) }
|
||||
func (*GetKeyspacesResponse) ProtoMessage() {}
|
||||
func (*GetKeyspacesResponse) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{14}
|
||||
return fileDescriptor_609739e22a0a50b3, []int{15}
|
||||
}
|
||||
func (m *GetKeyspacesResponse) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
|
|
@ -921,7 +978,7 @@ func (m *GetSchemaRequest) Reset() { *m = GetSchemaRequest{} }
|
|||
func (m *GetSchemaRequest) String() string { return proto.CompactTextString(m) }
|
||||
func (*GetSchemaRequest) ProtoMessage() {}
|
||||
func (*GetSchemaRequest) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{15}
|
||||
return fileDescriptor_609739e22a0a50b3, []int{16}
|
||||
}
|
||||
func (m *GetSchemaRequest) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
|
|
@ -982,7 +1039,7 @@ func (m *GetSchemasRequest) Reset() { *m = GetSchemasRequest{} }
|
|||
func (m *GetSchemasRequest) String() string { return proto.CompactTextString(m) }
|
||||
func (*GetSchemasRequest) ProtoMessage() {}
|
||||
func (*GetSchemasRequest) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{16}
|
||||
return fileDescriptor_609739e22a0a50b3, []int{17}
|
||||
}
|
||||
func (m *GetSchemasRequest) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
|
|
@ -1029,7 +1086,7 @@ func (m *GetSchemasResponse) Reset() { *m = GetSchemasResponse{} }
|
|||
func (m *GetSchemasResponse) String() string { return proto.CompactTextString(m) }
|
||||
func (*GetSchemasResponse) ProtoMessage() {}
|
||||
func (*GetSchemasResponse) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{17}
|
||||
return fileDescriptor_609739e22a0a50b3, []int{18}
|
||||
}
|
||||
func (m *GetSchemasResponse) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
|
|
@ -1080,7 +1137,7 @@ func (m *GetTabletRequest) Reset() { *m = GetTabletRequest{} }
|
|||
func (m *GetTabletRequest) String() string { return proto.CompactTextString(m) }
|
||||
func (*GetTabletRequest) ProtoMessage() {}
|
||||
func (*GetTabletRequest) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{18}
|
||||
return fileDescriptor_609739e22a0a50b3, []int{19}
|
||||
}
|
||||
func (m *GetTabletRequest) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
|
|
@ -1134,7 +1191,7 @@ func (m *GetTabletsRequest) Reset() { *m = GetTabletsRequest{} }
|
|||
func (m *GetTabletsRequest) String() string { return proto.CompactTextString(m) }
|
||||
func (*GetTabletsRequest) ProtoMessage() {}
|
||||
func (*GetTabletsRequest) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{19}
|
||||
return fileDescriptor_609739e22a0a50b3, []int{20}
|
||||
}
|
||||
func (m *GetTabletsRequest) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
|
|
@ -1181,7 +1238,7 @@ func (m *GetTabletsResponse) Reset() { *m = GetTabletsResponse{} }
|
|||
func (m *GetTabletsResponse) String() string { return proto.CompactTextString(m) }
|
||||
func (*GetTabletsResponse) ProtoMessage() {}
|
||||
func (*GetTabletsResponse) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{20}
|
||||
return fileDescriptor_609739e22a0a50b3, []int{21}
|
||||
}
|
||||
func (m *GetTabletsResponse) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
|
|
@ -1229,7 +1286,7 @@ func (m *GetVSchemaRequest) Reset() { *m = GetVSchemaRequest{} }
|
|||
func (m *GetVSchemaRequest) String() string { return proto.CompactTextString(m) }
|
||||
func (*GetVSchemaRequest) ProtoMessage() {}
|
||||
func (*GetVSchemaRequest) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{21}
|
||||
return fileDescriptor_609739e22a0a50b3, []int{22}
|
||||
}
|
||||
func (m *GetVSchemaRequest) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
|
|
@ -1283,7 +1340,7 @@ func (m *GetVSchemasRequest) Reset() { *m = GetVSchemasRequest{} }
|
|||
func (m *GetVSchemasRequest) String() string { return proto.CompactTextString(m) }
|
||||
func (*GetVSchemasRequest) ProtoMessage() {}
|
||||
func (*GetVSchemasRequest) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{22}
|
||||
return fileDescriptor_609739e22a0a50b3, []int{23}
|
||||
}
|
||||
func (m *GetVSchemasRequest) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
|
|
@ -1330,7 +1387,7 @@ func (m *GetVSchemasResponse) Reset() { *m = GetVSchemasResponse{} }
|
|||
func (m *GetVSchemasResponse) String() string { return proto.CompactTextString(m) }
|
||||
func (*GetVSchemasResponse) ProtoMessage() {}
|
||||
func (*GetVSchemasResponse) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{23}
|
||||
return fileDescriptor_609739e22a0a50b3, []int{24}
|
||||
}
|
||||
func (m *GetVSchemasResponse) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
|
|
@ -1380,7 +1437,7 @@ func (m *GetWorkflowRequest) Reset() { *m = GetWorkflowRequest{} }
|
|||
func (m *GetWorkflowRequest) String() string { return proto.CompactTextString(m) }
|
||||
func (*GetWorkflowRequest) ProtoMessage() {}
|
||||
func (*GetWorkflowRequest) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{24}
|
||||
return fileDescriptor_609739e22a0a50b3, []int{25}
|
||||
}
|
||||
func (m *GetWorkflowRequest) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
|
|
@ -1466,7 +1523,7 @@ func (m *GetWorkflowsRequest) Reset() { *m = GetWorkflowsRequest{} }
|
|||
func (m *GetWorkflowsRequest) String() string { return proto.CompactTextString(m) }
|
||||
func (*GetWorkflowsRequest) ProtoMessage() {}
|
||||
func (*GetWorkflowsRequest) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{25}
|
||||
return fileDescriptor_609739e22a0a50b3, []int{26}
|
||||
}
|
||||
func (m *GetWorkflowsRequest) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
|
|
@ -1524,7 +1581,7 @@ func (m *GetWorkflowsRequest) GetIgnoreKeyspaces() []string {
|
|||
}
|
||||
|
||||
type GetWorkflowsResponse struct {
|
||||
Workflows []*Workflow `protobuf:"bytes,1,rep,name=workflows,proto3" json:"workflows,omitempty"`
|
||||
WorkflowsByCluster map[string]*ClusterWorkflows `protobuf:"bytes,1,rep,name=workflows_by_cluster,json=workflowsByCluster,proto3" json:"workflows_by_cluster,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
|
||||
XXX_NoUnkeyedLiteral struct{} `json:"-"`
|
||||
XXX_unrecognized []byte `json:"-"`
|
||||
XXX_sizecache int32 `json:"-"`
|
||||
|
|
@ -1534,7 +1591,7 @@ func (m *GetWorkflowsResponse) Reset() { *m = GetWorkflowsResponse{} }
|
|||
func (m *GetWorkflowsResponse) String() string { return proto.CompactTextString(m) }
|
||||
func (*GetWorkflowsResponse) ProtoMessage() {}
|
||||
func (*GetWorkflowsResponse) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{26}
|
||||
return fileDescriptor_609739e22a0a50b3, []int{27}
|
||||
}
|
||||
func (m *GetWorkflowsResponse) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
|
|
@ -1563,9 +1620,9 @@ func (m *GetWorkflowsResponse) XXX_DiscardUnknown() {
|
|||
|
||||
var xxx_messageInfo_GetWorkflowsResponse proto.InternalMessageInfo
|
||||
|
||||
func (m *GetWorkflowsResponse) GetWorkflows() []*Workflow {
|
||||
func (m *GetWorkflowsResponse) GetWorkflowsByCluster() map[string]*ClusterWorkflows {
|
||||
if m != nil {
|
||||
return m.Workflows
|
||||
return m.WorkflowsByCluster
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
|
@ -1583,7 +1640,7 @@ func (m *VTExplainRequest) Reset() { *m = VTExplainRequest{} }
|
|||
func (m *VTExplainRequest) String() string { return proto.CompactTextString(m) }
|
||||
func (*VTExplainRequest) ProtoMessage() {}
|
||||
func (*VTExplainRequest) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{27}
|
||||
return fileDescriptor_609739e22a0a50b3, []int{28}
|
||||
}
|
||||
func (m *VTExplainRequest) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
|
|
@ -1644,7 +1701,7 @@ func (m *VTExplainResponse) Reset() { *m = VTExplainResponse{} }
|
|||
func (m *VTExplainResponse) String() string { return proto.CompactTextString(m) }
|
||||
func (*VTExplainResponse) ProtoMessage() {}
|
||||
func (*VTExplainResponse) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_609739e22a0a50b3, []int{28}
|
||||
return fileDescriptor_609739e22a0a50b3, []int{29}
|
||||
}
|
||||
func (m *VTExplainResponse) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
|
|
@ -1683,6 +1740,7 @@ func (m *VTExplainResponse) GetResponse() string {
|
|||
func init() {
|
||||
proto.RegisterEnum("vtadmin.Tablet_ServingState", Tablet_ServingState_name, Tablet_ServingState_value)
|
||||
proto.RegisterType((*Cluster)(nil), "vtadmin.Cluster")
|
||||
proto.RegisterType((*ClusterWorkflows)(nil), "vtadmin.ClusterWorkflows")
|
||||
proto.RegisterType((*Keyspace)(nil), "vtadmin.Keyspace")
|
||||
proto.RegisterMapType((map[string]*vtctldata.Shard)(nil), "vtadmin.Keyspace.ShardsEntry")
|
||||
proto.RegisterType((*Schema)(nil), "vtadmin.Schema")
|
||||
|
|
@ -1710,6 +1768,7 @@ func init() {
|
|||
proto.RegisterType((*GetWorkflowRequest)(nil), "vtadmin.GetWorkflowRequest")
|
||||
proto.RegisterType((*GetWorkflowsRequest)(nil), "vtadmin.GetWorkflowsRequest")
|
||||
proto.RegisterType((*GetWorkflowsResponse)(nil), "vtadmin.GetWorkflowsResponse")
|
||||
proto.RegisterMapType((map[string]*ClusterWorkflows)(nil), "vtadmin.GetWorkflowsResponse.WorkflowsByClusterEntry")
|
||||
proto.RegisterType((*VTExplainRequest)(nil), "vtadmin.VTExplainRequest")
|
||||
proto.RegisterType((*VTExplainResponse)(nil), "vtadmin.VTExplainResponse")
|
||||
}
|
||||
|
|
@ -1717,80 +1776,85 @@ func init() {
|
|||
func init() { proto.RegisterFile("vtadmin.proto", fileDescriptor_609739e22a0a50b3) }
|
||||
|
||||
var fileDescriptor_609739e22a0a50b3 = []byte{
|
||||
// 1165 bytes of a gzipped FileDescriptorProto
|
||||
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x57, 0xdd, 0x6e, 0x1b, 0x45,
|
||||
0x14, 0xf6, 0xda, 0x89, 0x7f, 0xce, 0xb6, 0xc9, 0x7a, 0x1a, 0x09, 0xb3, 0x4d, 0xd2, 0x68, 0x04,
|
||||
0x28, 0x45, 0xd4, 0x96, 0x0c, 0xad, 0x08, 0x20, 0x55, 0xa5, 0x09, 0x56, 0x1b, 0xe1, 0xa0, 0x4d,
|
||||
0xd8, 0x4a, 0xbd, 0xb1, 0xb6, 0xf6, 0x36, 0x59, 0x65, 0xb3, 0xeb, 0x7a, 0x26, 0x1b, 0x72, 0x0d,
|
||||
0x97, 0x5c, 0x23, 0x2e, 0xe1, 0x6d, 0xb8, 0x41, 0xe2, 0x11, 0x50, 0xb8, 0xe4, 0x25, 0xd0, 0xce,
|
||||
0xdf, 0xce, 0xee, 0x9a, 0xfc, 0x40, 0xef, 0x76, 0x66, 0xce, 0x9c, 0xf3, 0x9d, 0x73, 0xbe, 0xf3,
|
||||
0x8d, 0x0d, 0xb7, 0x13, 0xea, 0x4d, 0x4e, 0x82, 0xa8, 0x3b, 0x9d, 0xc5, 0x34, 0x46, 0x0d, 0xb1,
|
||||
0xb4, 0xdf, 0xa1, 0xde, 0xab, 0xd0, 0xa7, 0x27, 0x5e, 0xe4, 0x1d, 0xfa, 0xb3, 0x89, 0x47, 0x3d,
|
||||
0x6e, 0x61, 0x2f, 0xd1, 0x78, 0x1a, 0x6b, 0xeb, 0xdb, 0x09, 0x19, 0x1f, 0xf9, 0x27, 0x72, 0xb9,
|
||||
0x9c, 0xd0, 0x31, 0x0d, 0xb3, 0x73, 0xfc, 0x00, 0x1a, 0x4f, 0xc3, 0x53, 0x42, 0xfd, 0x19, 0x5a,
|
||||
0x82, 0x6a, 0x30, 0xe9, 0x18, 0x1b, 0xc6, 0x66, 0xcb, 0xa9, 0x06, 0x13, 0x84, 0x60, 0x21, 0xf2,
|
||||
0x4e, 0xfc, 0x4e, 0x95, 0xed, 0xb0, 0x6f, 0xfc, 0xb7, 0x01, 0xcd, 0x5d, 0xff, 0x9c, 0x4c, 0xbd,
|
||||
0xb1, 0x8f, 0x3e, 0x84, 0xc6, 0x98, 0xdf, 0x65, 0xb7, 0xcc, 0xbe, 0xd5, 0x95, 0x70, 0x85, 0x4f,
|
||||
0x47, 0x1a, 0xa0, 0x1e, 0x34, 0x8f, 0xc5, 0x3d, 0xe6, 0xd0, 0xec, 0xdf, 0xe9, 0x66, 0x58, 0xa4,
|
||||
0x4b, 0x47, 0x19, 0xa1, 0x87, 0x50, 0x27, 0x47, 0xde, 0x6c, 0x42, 0x3a, 0xb5, 0x8d, 0xda, 0xa6,
|
||||
0xd9, 0x5f, 0x53, 0xbe, 0xa5, 0x71, 0x77, 0x9f, 0x9d, 0xef, 0x44, 0x74, 0x76, 0xee, 0x08, 0x63,
|
||||
0x7b, 0x17, 0x4c, 0x6d, 0x1b, 0x59, 0x50, 0x3b, 0xf6, 0xcf, 0x45, 0x52, 0xe9, 0x27, 0xfa, 0x00,
|
||||
0x16, 0x13, 0x2f, 0x3c, 0x95, 0x28, 0x2c, 0x0d, 0x05, 0xbb, 0xe8, 0xf0, 0xe3, 0xcf, 0xaa, 0x9f,
|
||||
0x1a, 0xf8, 0x57, 0x03, 0xea, 0xfb, 0xac, 0x7c, 0x37, 0xca, 0xd5, 0x2e, 0xe4, 0xda, 0xd2, 0xd2,
|
||||
0xda, 0x83, 0x36, 0x6b, 0xdd, 0x68, 0xe2, 0xbf, 0x0e, 0xa2, 0x80, 0x06, 0x71, 0x24, 0x33, 0xc4,
|
||||
0xdd, 0x72, 0x53, 0x0f, 0xd2, 0x9d, 0x6d, 0x65, 0xea, 0x58, 0x34, 0xbf, 0x41, 0xf0, 0xef, 0x06,
|
||||
0xd4, 0x99, 0x15, 0xbd, 0x11, 0xc6, 0x4d, 0xa8, 0xf3, 0x68, 0xaa, 0x0e, 0x8a, 0x38, 0xdc, 0x9b,
|
||||
0x23, 0xce, 0x51, 0x1f, 0x16, 0x09, 0xf5, 0xa8, 0xdf, 0xa9, 0x6d, 0x18, 0x9b, 0x4b, 0xfd, 0x55,
|
||||
0xe5, 0x93, 0xdb, 0x75, 0xf7, 0xfd, 0x59, 0x12, 0x44, 0x87, 0xfb, 0xa9, 0x8d, 0xc3, 0x4d, 0xf1,
|
||||
0x16, 0xdc, 0xd2, 0xb7, 0x91, 0x09, 0x8d, 0x6f, 0x87, 0xbb, 0xc3, 0xbd, 0x17, 0x43, 0xab, 0x92,
|
||||
0x2e, 0xf6, 0x77, 0x1c, 0xf7, 0xd9, 0x70, 0x60, 0x19, 0x68, 0x19, 0xcc, 0xe1, 0xde, 0xc1, 0x48,
|
||||
0x6e, 0x54, 0xf1, 0x19, 0x34, 0xdc, 0xff, 0x50, 0xf3, 0x39, 0x64, 0x45, 0x1f, 0x41, 0x33, 0x19,
|
||||
0x71, 0xfa, 0x33, 0xf0, 0x66, 0xbf, 0xdd, 0x95, 0xe3, 0xa0, 0x18, 0xd7, 0x48, 0x78, 0x34, 0xfc,
|
||||
0x0d, 0xd4, 0x5d, 0x46, 0x85, 0xb4, 0x7f, 0x47, 0x31, 0xa1, 0xcc, 0x1f, 0x67, 0x8e, 0x5a, 0xeb,
|
||||
0x98, 0xaa, 0x57, 0x60, 0xc2, 0x3f, 0x19, 0x50, 0x77, 0x0f, 0x06, 0x69, 0x01, 0x2e, 0x73, 0x89,
|
||||
0x60, 0x61, 0x1a, 0xc7, 0xa1, 0x84, 0x9e, 0x7e, 0xa7, 0x7b, 0x63, 0x3f, 0x0c, 0x19, 0xec, 0x96,
|
||||
0xc3, 0xbe, 0xf5, 0xd0, 0x0b, 0x57, 0x95, 0x63, 0x15, 0x5a, 0x92, 0x72, 0xa4, 0xb3, 0xb8, 0x51,
|
||||
0xdb, 0x6c, 0x39, 0xd9, 0x06, 0xfe, 0xde, 0x80, 0xe6, 0x8b, 0x78, 0x76, 0xfc, 0x3a, 0x8c, 0xcf,
|
||||
0xde, 0x1a, 0xb3, 0x7b, 0xd0, 0x3c, 0x13, 0x3e, 0x45, 0xb5, 0xf5, 0x09, 0x97, 0xe1, 0x1c, 0x65,
|
||||
0x84, 0x9f, 0x43, 0xfb, 0xab, 0x20, 0x9a, 0xf0, 0xf2, 0x3b, 0xfe, 0x9b, 0x53, 0x9f, 0x50, 0xb4,
|
||||
0x02, 0x8b, 0x8c, 0x77, 0xa2, 0x4a, 0x7c, 0x81, 0xee, 0x81, 0x29, 0x20, 0x8c, 0x82, 0x09, 0xe9,
|
||||
0x54, 0x59, 0x42, 0x20, 0xb6, 0x9e, 0x4d, 0x08, 0x5e, 0x01, 0x34, 0xf0, 0xa9, 0xc0, 0x4b, 0x84,
|
||||
0x33, 0xfc, 0x14, 0xee, 0xe4, 0x76, 0xc9, 0x34, 0x8e, 0x08, 0xe3, 0x85, 0xb8, 0x4a, 0x3a, 0x06,
|
||||
0x1b, 0xbd, 0x72, 0xca, 0xca, 0x02, 0xf7, 0x61, 0x79, 0xe0, 0xd3, 0xb4, 0x8b, 0xd2, 0x6f, 0x11,
|
||||
0x8e, 0x51, 0x82, 0xb3, 0x05, 0x56, 0x76, 0x47, 0x44, 0x7d, 0x1f, 0x16, 0x0f, 0xd3, 0x0d, 0x11,
|
||||
0x72, 0x59, 0x85, 0xe4, 0x14, 0x71, 0xf8, 0x29, 0x7e, 0xc4, 0x30, 0x4b, 0x7a, 0x5e, 0x3f, 0xe4,
|
||||
0x00, 0x56, 0xf2, 0xf7, 0x44, 0xd8, 0x9e, 0xce, 0x04, 0x1e, 0xba, 0x5d, 0x92, 0x52, 0x9d, 0x1c,
|
||||
0x63, 0x86, 0x3d, 0xdf, 0x95, 0x35, 0x80, 0x2c, 0xba, 0x68, 0x4d, 0x4b, 0x05, 0xbf, 0x94, 0x16,
|
||||
0xaa, 0xa1, 0x35, 0xad, 0xa1, 0xf8, 0x13, 0x68, 0xab, 0x20, 0xd7, 0xcf, 0xf1, 0x31, 0xeb, 0xb2,
|
||||
0xba, 0x25, 0x32, 0xbc, 0x0f, 0x0d, 0x3e, 0xd4, 0xe5, 0xd2, 0x8a, 0x2c, 0xe4, 0x39, 0xde, 0x63,
|
||||
0xb9, 0x09, 0x81, 0x13, 0x51, 0x2f, 0x1b, 0xcd, 0x2b, 0x79, 0xc7, 0xf3, 0xe0, 0x0e, 0x6f, 0x9a,
|
||||
0x87, 0xba, 0x95, 0xe5, 0xc1, 0x25, 0xb7, 0x9c, 0x87, 0x40, 0x2c, 0xcf, 0xf1, 0x90, 0x85, 0x75,
|
||||
0xdf, 0x56, 0x93, 0xf0, 0x43, 0x06, 0xc8, 0xbd, 0x69, 0x3f, 0xb6, 0x19, 0x57, 0xdd, 0x62, 0x43,
|
||||
0x1e, 0x40, 0x4b, 0xea, 0x6e, 0x79, 0xc0, 0x24, 0xe8, 0xa6, 0xd0, 0x5d, 0x82, 0x7f, 0x30, 0x58,
|
||||
0x74, 0xa5, 0x10, 0xff, 0x9f, 0x73, 0xf2, 0x31, 0xa8, 0x69, 0x8f, 0xc1, 0x3d, 0x30, 0xbd, 0x31,
|
||||
0x0d, 0x12, 0x7f, 0x14, 0x47, 0xe1, 0x39, 0x53, 0xd0, 0xa6, 0x03, 0x7c, 0x6b, 0x2f, 0x0a, 0xcf,
|
||||
0xf1, 0x2f, 0x06, 0xcb, 0x46, 0xc2, 0xb8, 0x76, 0x15, 0x8a, 0x9e, 0xab, 0x45, 0xcf, 0x79, 0x31,
|
||||
0xae, 0x15, 0xc4, 0x18, 0xdd, 0x07, 0x2b, 0x38, 0x8c, 0xe2, 0x99, 0x3f, 0xca, 0x8c, 0x16, 0x98,
|
||||
0xd1, 0x32, 0xdf, 0x57, 0x33, 0x2d, 0x66, 0x5c, 0x43, 0x98, 0xcd, 0xb8, 0x54, 0xd5, 0xf2, 0x8c,
|
||||
0xab, 0xba, 0x66, 0x36, 0xf8, 0x25, 0x58, 0xee, 0xc1, 0xce, 0x77, 0xd3, 0xd0, 0x0b, 0x22, 0x99,
|
||||
0x67, 0x27, 0xff, 0x0e, 0xb4, 0xae, 0xa7, 0xfa, 0x16, 0xd4, 0xc8, 0x1b, 0xf9, 0x4e, 0xa5, 0x9f,
|
||||
0xb8, 0x07, 0x6d, 0xcd, 0xb7, 0x40, 0x68, 0x43, 0x73, 0x26, 0xbe, 0xe5, 0x90, 0xc9, 0x75, 0xff,
|
||||
0xc7, 0x06, 0x34, 0xdc, 0x83, 0x27, 0x29, 0x58, 0xf4, 0x39, 0x40, 0xf6, 0x26, 0x20, 0x5b, 0x25,
|
||||
0x51, 0x7a, 0x28, 0xec, 0xe2, 0x90, 0xe3, 0x0a, 0x7a, 0x0e, 0xa6, 0x26, 0xf7, 0xe8, 0xae, 0xb2,
|
||||
0x28, 0x3f, 0x0d, 0xf6, 0xea, 0xfc, 0x43, 0x0e, 0x09, 0x57, 0xd0, 0x13, 0x68, 0x4a, 0x05, 0x47,
|
||||
0x1d, 0xdd, 0x56, 0x7f, 0x08, 0xec, 0x77, 0xe7, 0x9c, 0x28, 0x17, 0x5f, 0xc3, 0x2d, 0x5d, 0x91,
|
||||
0x51, 0x2e, 0x64, 0x51, 0xe0, 0xed, 0xb5, 0x7f, 0x39, 0x55, 0xee, 0xb6, 0xa0, 0xa5, 0xc4, 0x0f,
|
||||
0xe5, 0x02, 0x5f, 0x59, 0x98, 0x01, 0x40, 0xa6, 0x9b, 0x5a, 0x55, 0x4b, 0x12, 0x6c, 0xdf, 0x9d,
|
||||
0x7b, 0x56, 0xc0, 0x20, 0x7e, 0x6e, 0xe6, 0x30, 0xe4, 0x34, 0xd5, 0x2e, 0x2a, 0x97, 0xc2, 0x20,
|
||||
0x34, 0x2f, 0x8f, 0x21, 0x2f, 0x9f, 0x79, 0x0c, 0x05, 0x91, 0xc4, 0x15, 0xf4, 0x05, 0x73, 0xe4,
|
||||
0x96, 0x28, 0x52, 0x12, 0x44, 0xbb, 0x24, 0x3a, 0x8a, 0x23, 0x52, 0xb2, 0xf2, 0x1c, 0x29, 0xe8,
|
||||
0x5f, 0x9e, 0x23, 0x6e, 0xb9, 0x1a, 0x8f, 0x99, 0x2f, 0xf5, 0x43, 0x2a, 0xe7, 0xab, 0xa0, 0x66,
|
||||
0x76, 0x79, 0x1e, 0x15, 0x43, 0xd4, 0x3c, 0xe7, 0x19, 0x52, 0x14, 0xa2, 0x3c, 0x43, 0x4a, 0x22,
|
||||
0x80, 0x2b, 0x68, 0x1b, 0x5a, 0x6a, 0xf2, 0xb4, 0xee, 0x14, 0x27, 0xdd, 0xb6, 0xe7, 0x1d, 0x49,
|
||||
0x2f, 0x5f, 0x3e, 0xfa, 0xed, 0x62, 0xdd, 0xf8, 0xe3, 0x62, 0xdd, 0xf8, 0xf3, 0x62, 0xdd, 0xf8,
|
||||
0xf9, 0xaf, 0xf5, 0xca, 0xcb, 0xf7, 0x92, 0x80, 0xfa, 0x84, 0x74, 0x83, 0xb8, 0xc7, 0xbf, 0x7a,
|
||||
0x87, 0x71, 0x2f, 0xa1, 0x3d, 0xf6, 0x0f, 0xb2, 0x27, 0x7c, 0xbd, 0xaa, 0xb3, 0xe5, 0xc7, 0xff,
|
||||
0x04, 0x00, 0x00, 0xff, 0xff, 0x61, 0xc6, 0xb3, 0x38, 0xb3, 0x0e, 0x00, 0x00,
|
||||
// 1244 bytes of a gzipped FileDescriptorProto
|
||||
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x57, 0xdd, 0x6f, 0xdb, 0x54,
|
||||
0x14, 0x8f, 0x93, 0x36, 0x89, 0x4f, 0xb6, 0xd5, 0xbd, 0xab, 0xb4, 0xcc, 0xfd, 0x58, 0x75, 0x05,
|
||||
0xa8, 0x43, 0x2c, 0x96, 0x02, 0x9d, 0x28, 0x20, 0x4d, 0xdb, 0x5a, 0xa2, 0xad, 0x22, 0x45, 0x6e,
|
||||
0xf1, 0xa4, 0xbd, 0x04, 0x37, 0xf1, 0x52, 0xab, 0xae, 0x9d, 0xc5, 0xb7, 0x29, 0x79, 0x86, 0x47,
|
||||
0x9e, 0x11, 0x8f, 0xf0, 0xdf, 0xf0, 0x82, 0xc4, 0x9f, 0x00, 0xe5, 0x91, 0x7f, 0x02, 0xf9, 0x7e,
|
||||
0xf9, 0xda, 0x4e, 0xbf, 0x60, 0x6f, 0xbe, 0xf7, 0x9e, 0x7b, 0xce, 0xef, 0x7c, 0xfd, 0xce, 0x35,
|
||||
0xdc, 0x9e, 0x10, 0x77, 0x70, 0xe2, 0x87, 0xad, 0xd1, 0x38, 0x22, 0x11, 0xaa, 0xf1, 0xa5, 0x79,
|
||||
0x8f, 0xb8, 0x87, 0x81, 0x47, 0x4e, 0xdc, 0xd0, 0x1d, 0x7a, 0xe3, 0x81, 0x4b, 0x5c, 0x26, 0x61,
|
||||
0xde, 0x21, 0xd1, 0x28, 0x52, 0xd6, 0xb7, 0x27, 0x71, 0xff, 0xc8, 0x3b, 0x11, 0xcb, 0x85, 0x09,
|
||||
0xe9, 0x93, 0x20, 0x3d, 0xc7, 0x8f, 0xa0, 0xf6, 0x3c, 0x38, 0x8d, 0x89, 0x37, 0x46, 0x77, 0xa0,
|
||||
0xec, 0x0f, 0x9a, 0xda, 0xba, 0xb6, 0xa1, 0xdb, 0x65, 0x7f, 0x80, 0x10, 0xcc, 0x85, 0xee, 0x89,
|
||||
0xd7, 0x2c, 0xd3, 0x1d, 0xfa, 0x8d, 0x7b, 0x60, 0x70, 0xf1, 0x57, 0xd1, 0xf8, 0xf8, 0x4d, 0x10,
|
||||
0x9d, 0xc5, 0xc8, 0x02, 0xfd, 0x4c, 0x2c, 0x9a, 0xda, 0x7a, 0x65, 0xa3, 0xd1, 0x5e, 0x6c, 0x09,
|
||||
0xdc, 0x42, 0xcc, 0x4e, 0x65, 0x90, 0x09, 0xf5, 0x33, 0x77, 0x1c, 0xfa, 0xe1, 0x30, 0x6e, 0x96,
|
||||
0xd7, 0x2b, 0x1b, 0xba, 0x2d, 0xd7, 0xf8, 0x1f, 0x0d, 0xea, 0xbb, 0xde, 0x34, 0x1e, 0xb9, 0x7d,
|
||||
0x0f, 0x7d, 0x08, 0xb5, 0x3e, 0xb3, 0x46, 0x61, 0x35, 0xda, 0x86, 0xd4, 0xcb, 0x51, 0xd8, 0x42,
|
||||
0x00, 0x59, 0x50, 0x3f, 0xe6, 0xf7, 0x28, 0xe2, 0x46, 0xfb, 0x6e, 0x2b, 0x75, 0x56, 0xa8, 0xb4,
|
||||
0xa5, 0x10, 0xda, 0x84, 0x6a, 0x7c, 0xe4, 0x8e, 0x07, 0x71, 0xb3, 0x42, 0x31, 0xaf, 0x4a, 0xdd,
|
||||
0x42, 0xb8, 0xb5, 0x4f, 0xcf, 0x77, 0x42, 0x32, 0x9e, 0xda, 0x5c, 0xd8, 0xdc, 0x85, 0x86, 0xb2,
|
||||
0x8d, 0x0c, 0xa8, 0x1c, 0x7b, 0x53, 0x1e, 0xb5, 0xe4, 0x13, 0x7d, 0x00, 0xf3, 0x13, 0x37, 0x38,
|
||||
0x15, 0x28, 0x0c, 0x05, 0x05, 0xbd, 0x68, 0xb3, 0xe3, 0xcf, 0xca, 0x9f, 0x6a, 0xf8, 0x57, 0x0d,
|
||||
0xaa, 0xfb, 0x34, 0x3f, 0x37, 0xf2, 0xd5, 0xcc, 0xf9, 0xaa, 0x2b, 0x6e, 0xed, 0xc1, 0x22, 0xad,
|
||||
0x8d, 0xde, 0xc0, 0x7b, 0xe3, 0x87, 0x3e, 0xf1, 0xa3, 0x50, 0x78, 0x88, 0x5b, 0xc5, 0xaa, 0x39,
|
||||
0x48, 0x76, 0xb6, 0xa5, 0xa8, 0x6d, 0x90, 0xec, 0x46, 0x8c, 0x7f, 0xd7, 0xa0, 0x4a, 0xa5, 0xc8,
|
||||
0x8d, 0x30, 0x6e, 0x40, 0x95, 0x59, 0x93, 0x71, 0x90, 0x95, 0xc9, 0xb4, 0xd9, 0xfc, 0x1c, 0xb5,
|
||||
0x61, 0x3e, 0x26, 0x2e, 0xf1, 0x9a, 0x95, 0x75, 0x6d, 0xe3, 0x4e, 0x7b, 0x45, 0xea, 0x64, 0x72,
|
||||
0xad, 0x7d, 0x6f, 0x3c, 0xf1, 0xc3, 0xe1, 0x7e, 0x22, 0x63, 0x33, 0x51, 0xbc, 0x05, 0xb7, 0xd4,
|
||||
0x6d, 0xd4, 0x80, 0xda, 0x37, 0xdd, 0xdd, 0xee, 0xde, 0xab, 0xae, 0x51, 0x4a, 0x16, 0xfb, 0x3b,
|
||||
0xb6, 0xf3, 0xa2, 0xdb, 0x31, 0x34, 0xb4, 0x00, 0x8d, 0xee, 0xde, 0x41, 0x4f, 0x6c, 0x94, 0xf1,
|
||||
0x19, 0xd4, 0x9c, 0xff, 0x10, 0xf3, 0x19, 0xdd, 0x80, 0x3e, 0x82, 0xfa, 0xa4, 0xc7, 0xfa, 0x8b,
|
||||
0x82, 0xa7, 0x85, 0xcf, 0xfb, 0x4d, 0x56, 0x5c, 0x6d, 0xc2, 0xac, 0xe1, 0xaf, 0xa1, 0xea, 0xd0,
|
||||
0x52, 0x48, 0xf2, 0x77, 0x14, 0xc5, 0x84, 0xea, 0x63, 0x95, 0x23, 0xd7, 0x2a, 0xa6, 0xf2, 0x15,
|
||||
0x98, 0xf0, 0x4f, 0x1a, 0x54, 0x9d, 0x83, 0x4e, 0x12, 0x80, 0xcb, 0x54, 0x22, 0x98, 0x1b, 0x45,
|
||||
0x51, 0x20, 0xa0, 0x27, 0xdf, 0xc9, 0x5e, 0xdf, 0x0b, 0x02, 0x0a, 0x5b, 0xb7, 0xe9, 0xb7, 0x6a,
|
||||
0x7a, 0xee, 0xaa, 0x70, 0xac, 0x80, 0x2e, 0x4a, 0x2e, 0x6e, 0xce, 0xd3, 0x26, 0x4e, 0x37, 0xf0,
|
||||
0xf7, 0x1a, 0xd4, 0x45, 0xe7, 0xbf, 0xb3, 0xca, 0xb6, 0xa0, 0x2e, 0x38, 0x84, 0x47, 0x5b, 0xed,
|
||||
0x70, 0x49, 0x34, 0x52, 0x08, 0xbf, 0x84, 0xc5, 0x2f, 0xfd, 0x70, 0xc0, 0xc2, 0x6f, 0x7b, 0x6f,
|
||||
0x4f, 0xbd, 0x98, 0xa0, 0x25, 0x98, 0xa7, 0x75, 0xc7, 0xa3, 0xc4, 0x16, 0xe8, 0x01, 0x34, 0x38,
|
||||
0x84, 0x9e, 0x3f, 0x10, 0xac, 0x04, 0x7c, 0xeb, 0xc5, 0x20, 0xc6, 0x4b, 0x80, 0x3a, 0x1e, 0xe1,
|
||||
0x78, 0x63, 0xae, 0x0c, 0x3f, 0x87, 0xbb, 0x99, 0xdd, 0x78, 0x14, 0x85, 0x31, 0xad, 0x0b, 0x7e,
|
||||
0x55, 0x10, 0x62, 0xd1, 0x65, 0x29, 0x81, 0xdb, 0xb0, 0xd0, 0xf1, 0x48, 0x92, 0x45, 0xa1, 0x37,
|
||||
0x0f, 0x47, 0x2b, 0xc0, 0xd9, 0x02, 0x23, 0xbd, 0xc3, 0xad, 0xbe, 0x0f, 0xf3, 0xc3, 0x64, 0x83,
|
||||
0x9b, 0x5c, 0x90, 0x26, 0x59, 0x89, 0xd8, 0xec, 0x14, 0x3f, 0xa6, 0x98, 0x45, 0x79, 0x5e, 0xdf,
|
||||
0x64, 0x07, 0x96, 0xb2, 0xf7, 0xb8, 0x59, 0x4b, 0xad, 0x84, 0x3c, 0xfd, 0xcb, 0x2e, 0x50, 0x8a,
|
||||
0xa3, 0x4f, 0xb1, 0x67, 0xb3, 0xb2, 0x0a, 0x90, 0x5a, 0xe7, 0xa9, 0xd1, 0xa5, 0xf1, 0x4b, 0xcb,
|
||||
0x42, 0x26, 0xb4, 0xa2, 0x24, 0x14, 0x7f, 0x02, 0x8b, 0xd2, 0xc8, 0xf5, 0x7d, 0x7c, 0x42, 0xb3,
|
||||
0x2c, 0x6f, 0x71, 0x0f, 0x1f, 0x42, 0x8d, 0x35, 0x75, 0x31, 0xb4, 0xdc, 0x0b, 0x71, 0x8e, 0xf7,
|
||||
0xa8, 0x6f, 0x9c, 0xe0, 0xb8, 0xd5, 0xcb, 0x5a, 0xf3, 0xca, 0xba, 0x63, 0x7e, 0x30, 0x85, 0x37,
|
||||
0xf5, 0x43, 0xde, 0x4a, 0xfd, 0x60, 0x94, 0x5b, 0xf4, 0x83, 0x23, 0x16, 0xe7, 0xb8, 0x4b, 0xcd,
|
||||
0x3a, 0xef, 0x2a, 0x49, 0x78, 0x93, 0x02, 0x72, 0x6e, 0x9a, 0x8f, 0x6d, 0x5a, 0xab, 0x4e, 0x3e,
|
||||
0x21, 0x8f, 0x40, 0x17, 0xbc, 0x5b, 0x6c, 0x30, 0x01, 0xba, 0xce, 0x79, 0x37, 0xc6, 0x3f, 0x68,
|
||||
0xd4, 0xba, 0x64, 0x88, 0xff, 0x5f, 0x73, 0x62, 0x18, 0x54, 0x94, 0x61, 0xf0, 0x00, 0x1a, 0x6e,
|
||||
0x9f, 0xf8, 0x13, 0xaf, 0x17, 0x85, 0xc1, 0x94, 0x32, 0x68, 0xdd, 0x06, 0xb6, 0xb5, 0x17, 0x06,
|
||||
0x53, 0xfc, 0x8b, 0x46, 0xbd, 0x91, 0x0f, 0xa7, 0xeb, 0x46, 0x21, 0xaf, 0xb9, 0x9c, 0xd7, 0x9c,
|
||||
0x25, 0xe3, 0x4a, 0x8e, 0x8c, 0xd1, 0x43, 0x30, 0xfc, 0x61, 0x18, 0x8d, 0xbd, 0x5e, 0x2a, 0x34,
|
||||
0x47, 0x85, 0x16, 0xd8, 0xbe, 0xec, 0x69, 0xfc, 0x97, 0x46, 0x9b, 0x5c, 0x81, 0xc8, 0x23, 0x3e,
|
||||
0x84, 0x25, 0xf9, 0x7e, 0xeb, 0x1d, 0x4e, 0x7b, 0x29, 0xa1, 0x27, 0xc1, 0xdf, 0x94, 0xc1, 0x9f,
|
||||
0x75, 0x59, 0x52, 0x73, 0xfc, 0x6c, 0xca, 0xd9, 0x8f, 0x3d, 0xa9, 0xd0, 0x59, 0xe1, 0xc0, 0xfc,
|
||||
0x16, 0xee, 0x5d, 0x20, 0x3e, 0xe3, 0xa9, 0x65, 0x65, 0x9f, 0x5a, 0xf7, 0xf3, 0x24, 0x9b, 0x42,
|
||||
0x51, 0xde, 0x5c, 0xaf, 0xc1, 0x70, 0x0e, 0x76, 0xbe, 0x1b, 0x05, 0xae, 0x1f, 0x8a, 0x14, 0x34,
|
||||
0xb3, 0x23, 0x4a, 0xbf, 0xde, 0x40, 0x32, 0xa0, 0x12, 0xbf, 0x15, 0x23, 0x34, 0xf9, 0xc4, 0x16,
|
||||
0x2c, 0x2a, 0xba, 0x79, 0xec, 0x4c, 0xa8, 0x8f, 0xf9, 0xb7, 0xe8, 0x7f, 0xb1, 0x6e, 0xff, 0x58,
|
||||
0x83, 0x9a, 0x73, 0xf0, 0x34, 0x01, 0x8d, 0x3e, 0x07, 0x48, 0xc7, 0x15, 0x32, 0xa5, 0x33, 0x85,
|
||||
0x19, 0x66, 0xe6, 0xf9, 0x07, 0x97, 0xd0, 0x4b, 0x68, 0x28, 0x93, 0x08, 0x2d, 0xab, 0x19, 0xc9,
|
||||
0x4d, 0x2d, 0x73, 0x65, 0xf6, 0x21, 0x83, 0x84, 0x4b, 0xe8, 0x29, 0xd4, 0xc5, 0x70, 0x41, 0x4d,
|
||||
0x55, 0x56, 0x9d, 0x51, 0xe6, 0xfd, 0x19, 0x27, 0x52, 0xc5, 0x57, 0x70, 0x4b, 0x1d, 0x16, 0x28,
|
||||
0x63, 0x32, 0x3f, 0x7b, 0xcc, 0xd5, 0x0b, 0x4e, 0xa5, 0xba, 0x2d, 0xd0, 0x25, 0x2f, 0xa3, 0x8c,
|
||||
0xe1, 0x2b, 0x03, 0xd3, 0x01, 0x48, 0x29, 0x5d, 0x89, 0x6a, 0x61, 0x3a, 0x98, 0xcb, 0x33, 0xcf,
|
||||
0x72, 0x18, 0xf8, 0x4b, 0x38, 0x83, 0x21, 0x43, 0xf7, 0x66, 0x9e, 0x54, 0x25, 0x06, 0x4e, 0xc7,
|
||||
0x59, 0x0c, 0x59, 0x66, 0xcf, 0x62, 0xc8, 0xf1, 0x37, 0x2e, 0xa1, 0x2f, 0xa8, 0x22, 0xa7, 0x50,
|
||||
0x22, 0x05, 0xae, 0x36, 0x0b, 0x7c, 0x28, 0x6b, 0x44, 0xb0, 0x69, 0xb6, 0x46, 0x72, 0xd4, 0x9c,
|
||||
0xad, 0x11, 0xa7, 0x18, 0x8d, 0x27, 0x54, 0x97, 0x7c, 0xe3, 0x2d, 0xcf, 0x62, 0x00, 0xa1, 0xab,
|
||||
0xf8, 0x37, 0x28, 0x2b, 0x24, 0xfd, 0x8b, 0x5c, 0xb9, 0x80, 0x43, 0x66, 0x54, 0x48, 0x81, 0x61,
|
||||
0x70, 0x09, 0x6d, 0x83, 0x2e, 0x3b, 0x4f, 0xc9, 0x4e, 0xbe, 0xd3, 0x4d, 0x73, 0xd6, 0x91, 0xd0,
|
||||
0xf2, 0xec, 0xf1, 0x6f, 0xe7, 0x6b, 0xda, 0x1f, 0xe7, 0x6b, 0xda, 0x9f, 0xe7, 0x6b, 0xda, 0xcf,
|
||||
0x7f, 0xaf, 0x95, 0x5e, 0xbf, 0x37, 0xf1, 0x89, 0x17, 0xc7, 0x2d, 0x3f, 0xb2, 0xd8, 0x97, 0x35,
|
||||
0x8c, 0xac, 0x09, 0xb1, 0xe8, 0xdf, 0xb3, 0xc5, 0x75, 0x1d, 0x56, 0xe9, 0xf2, 0xe3, 0x7f, 0x03,
|
||||
0x00, 0x00, 0xff, 0xff, 0xe0, 0x66, 0xc0, 0xf2, 0xaf, 0x0f, 0x00, 0x00,
|
||||
}
|
||||
|
||||
// Reference imports to suppress errors if they are not otherwise used.
|
||||
|
|
@ -2390,6 +2454,56 @@ func (m *Cluster) MarshalToSizedBuffer(dAtA []byte) (int, error) {
|
|||
return len(dAtA) - i, nil
|
||||
}
|
||||
|
||||
func (m *ClusterWorkflows) Marshal() (dAtA []byte, err error) {
|
||||
size := m.Size()
|
||||
dAtA = make([]byte, size)
|
||||
n, err := m.MarshalToSizedBuffer(dAtA[:size])
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return dAtA[:n], nil
|
||||
}
|
||||
|
||||
func (m *ClusterWorkflows) MarshalTo(dAtA []byte) (int, error) {
|
||||
size := m.Size()
|
||||
return m.MarshalToSizedBuffer(dAtA[:size])
|
||||
}
|
||||
|
||||
func (m *ClusterWorkflows) MarshalToSizedBuffer(dAtA []byte) (int, error) {
|
||||
i := len(dAtA)
|
||||
_ = i
|
||||
var l int
|
||||
_ = l
|
||||
if m.XXX_unrecognized != nil {
|
||||
i -= len(m.XXX_unrecognized)
|
||||
copy(dAtA[i:], m.XXX_unrecognized)
|
||||
}
|
||||
if len(m.Warnings) > 0 {
|
||||
for iNdEx := len(m.Warnings) - 1; iNdEx >= 0; iNdEx-- {
|
||||
i -= len(m.Warnings[iNdEx])
|
||||
copy(dAtA[i:], m.Warnings[iNdEx])
|
||||
i = encodeVarintVtadmin(dAtA, i, uint64(len(m.Warnings[iNdEx])))
|
||||
i--
|
||||
dAtA[i] = 0x12
|
||||
}
|
||||
}
|
||||
if len(m.Workflows) > 0 {
|
||||
for iNdEx := len(m.Workflows) - 1; iNdEx >= 0; iNdEx-- {
|
||||
{
|
||||
size, err := m.Workflows[iNdEx].MarshalToSizedBuffer(dAtA[:i])
|
||||
if err != nil {
|
||||
return 0, err
|
||||
}
|
||||
i -= size
|
||||
i = encodeVarintVtadmin(dAtA, i, uint64(size))
|
||||
}
|
||||
i--
|
||||
dAtA[i] = 0xa
|
||||
}
|
||||
}
|
||||
return len(dAtA) - i, nil
|
||||
}
|
||||
|
||||
func (m *Keyspace) Marshal() (dAtA []byte, err error) {
|
||||
size := m.Size()
|
||||
dAtA = make([]byte, size)
|
||||
|
|
@ -3588,10 +3702,13 @@ func (m *GetWorkflowsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) {
|
|||
i -= len(m.XXX_unrecognized)
|
||||
copy(dAtA[i:], m.XXX_unrecognized)
|
||||
}
|
||||
if len(m.Workflows) > 0 {
|
||||
for iNdEx := len(m.Workflows) - 1; iNdEx >= 0; iNdEx-- {
|
||||
if len(m.WorkflowsByCluster) > 0 {
|
||||
for k := range m.WorkflowsByCluster {
|
||||
v := m.WorkflowsByCluster[k]
|
||||
baseI := i
|
||||
if v != nil {
|
||||
{
|
||||
size, err := m.Workflows[iNdEx].MarshalToSizedBuffer(dAtA[:i])
|
||||
size, err := v.MarshalToSizedBuffer(dAtA[:i])
|
||||
if err != nil {
|
||||
return 0, err
|
||||
}
|
||||
|
|
@ -3599,6 +3716,15 @@ func (m *GetWorkflowsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) {
|
|||
i = encodeVarintVtadmin(dAtA, i, uint64(size))
|
||||
}
|
||||
i--
|
||||
dAtA[i] = 0x12
|
||||
}
|
||||
i -= len(k)
|
||||
copy(dAtA[i:], k)
|
||||
i = encodeVarintVtadmin(dAtA, i, uint64(len(k)))
|
||||
i--
|
||||
dAtA[i] = 0xa
|
||||
i = encodeVarintVtadmin(dAtA, i, uint64(baseI-i))
|
||||
i--
|
||||
dAtA[i] = 0xa
|
||||
}
|
||||
}
|
||||
|
|
@ -3718,6 +3844,30 @@ func (m *Cluster) Size() (n int) {
|
|||
return n
|
||||
}
|
||||
|
||||
func (m *ClusterWorkflows) Size() (n int) {
|
||||
if m == nil {
|
||||
return 0
|
||||
}
|
||||
var l int
|
||||
_ = l
|
||||
if len(m.Workflows) > 0 {
|
||||
for _, e := range m.Workflows {
|
||||
l = e.Size()
|
||||
n += 1 + l + sovVtadmin(uint64(l))
|
||||
}
|
||||
}
|
||||
if len(m.Warnings) > 0 {
|
||||
for _, s := range m.Warnings {
|
||||
l = len(s)
|
||||
n += 1 + l + sovVtadmin(uint64(l))
|
||||
}
|
||||
}
|
||||
if m.XXX_unrecognized != nil {
|
||||
n += len(m.XXX_unrecognized)
|
||||
}
|
||||
return n
|
||||
}
|
||||
|
||||
func (m *Keyspace) Size() (n int) {
|
||||
if m == nil {
|
||||
return 0
|
||||
|
|
@ -4266,10 +4416,17 @@ func (m *GetWorkflowsResponse) Size() (n int) {
|
|||
}
|
||||
var l int
|
||||
_ = l
|
||||
if len(m.Workflows) > 0 {
|
||||
for _, e := range m.Workflows {
|
||||
l = e.Size()
|
||||
n += 1 + l + sovVtadmin(uint64(l))
|
||||
if len(m.WorkflowsByCluster) > 0 {
|
||||
for k, v := range m.WorkflowsByCluster {
|
||||
_ = k
|
||||
_ = v
|
||||
l = 0
|
||||
if v != nil {
|
||||
l = v.Size()
|
||||
l += 1 + sovVtadmin(uint64(l))
|
||||
}
|
||||
mapEntrySize := 1 + len(k) + sovVtadmin(uint64(len(k))) + l
|
||||
n += mapEntrySize + 1 + sovVtadmin(uint64(mapEntrySize))
|
||||
}
|
||||
}
|
||||
if m.XXX_unrecognized != nil {
|
||||
|
|
@ -4442,6 +4599,126 @@ func (m *Cluster) Unmarshal(dAtA []byte) error {
|
|||
}
|
||||
return nil
|
||||
}
|
||||
func (m *ClusterWorkflows) Unmarshal(dAtA []byte) error {
|
||||
l := len(dAtA)
|
||||
iNdEx := 0
|
||||
for iNdEx < l {
|
||||
preIndex := iNdEx
|
||||
var wire uint64
|
||||
for shift := uint(0); ; shift += 7 {
|
||||
if shift >= 64 {
|
||||
return ErrIntOverflowVtadmin
|
||||
}
|
||||
if iNdEx >= l {
|
||||
return io.ErrUnexpectedEOF
|
||||
}
|
||||
b := dAtA[iNdEx]
|
||||
iNdEx++
|
||||
wire |= uint64(b&0x7F) << shift
|
||||
if b < 0x80 {
|
||||
break
|
||||
}
|
||||
}
|
||||
fieldNum := int32(wire >> 3)
|
||||
wireType := int(wire & 0x7)
|
||||
if wireType == 4 {
|
||||
return fmt.Errorf("proto: ClusterWorkflows: wiretype end group for non-group")
|
||||
}
|
||||
if fieldNum <= 0 {
|
||||
return fmt.Errorf("proto: ClusterWorkflows: illegal tag %d (wire type %d)", fieldNum, wire)
|
||||
}
|
||||
switch fieldNum {
|
||||
case 1:
|
||||
if wireType != 2 {
|
||||
return fmt.Errorf("proto: wrong wireType = %d for field Workflows", wireType)
|
||||
}
|
||||
var msglen int
|
||||
for shift := uint(0); ; shift += 7 {
|
||||
if shift >= 64 {
|
||||
return ErrIntOverflowVtadmin
|
||||
}
|
||||
if iNdEx >= l {
|
||||
return io.ErrUnexpectedEOF
|
||||
}
|
||||
b := dAtA[iNdEx]
|
||||
iNdEx++
|
||||
msglen |= int(b&0x7F) << shift
|
||||
if b < 0x80 {
|
||||
break
|
||||
}
|
||||
}
|
||||
if msglen < 0 {
|
||||
return ErrInvalidLengthVtadmin
|
||||
}
|
||||
postIndex := iNdEx + msglen
|
||||
if postIndex < 0 {
|
||||
return ErrInvalidLengthVtadmin
|
||||
}
|
||||
if postIndex > l {
|
||||
return io.ErrUnexpectedEOF
|
||||
}
|
||||
m.Workflows = append(m.Workflows, &Workflow{})
|
||||
if err := m.Workflows[len(m.Workflows)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
|
||||
return err
|
||||
}
|
||||
iNdEx = postIndex
|
||||
case 2:
|
||||
if wireType != 2 {
|
||||
return fmt.Errorf("proto: wrong wireType = %d for field Warnings", wireType)
|
||||
}
|
||||
var stringLen uint64
|
||||
for shift := uint(0); ; shift += 7 {
|
||||
if shift >= 64 {
|
||||
return ErrIntOverflowVtadmin
|
||||
}
|
||||
if iNdEx >= l {
|
||||
return io.ErrUnexpectedEOF
|
||||
}
|
||||
b := dAtA[iNdEx]
|
||||
iNdEx++
|
||||
stringLen |= uint64(b&0x7F) << shift
|
||||
if b < 0x80 {
|
||||
break
|
||||
}
|
||||
}
|
||||
intStringLen := int(stringLen)
|
||||
if intStringLen < 0 {
|
||||
return ErrInvalidLengthVtadmin
|
||||
}
|
||||
postIndex := iNdEx + intStringLen
|
||||
if postIndex < 0 {
|
||||
return ErrInvalidLengthVtadmin
|
||||
}
|
||||
if postIndex > l {
|
||||
return io.ErrUnexpectedEOF
|
||||
}
|
||||
m.Warnings = append(m.Warnings, string(dAtA[iNdEx:postIndex]))
|
||||
iNdEx = postIndex
|
||||
default:
|
||||
iNdEx = preIndex
|
||||
skippy, err := skipVtadmin(dAtA[iNdEx:])
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
if skippy < 0 {
|
||||
return ErrInvalidLengthVtadmin
|
||||
}
|
||||
if (iNdEx + skippy) < 0 {
|
||||
return ErrInvalidLengthVtadmin
|
||||
}
|
||||
if (iNdEx + skippy) > l {
|
||||
return io.ErrUnexpectedEOF
|
||||
}
|
||||
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
|
||||
iNdEx += skippy
|
||||
}
|
||||
}
|
||||
|
||||
if iNdEx > l {
|
||||
return io.ErrUnexpectedEOF
|
||||
}
|
||||
return nil
|
||||
}
|
||||
func (m *Keyspace) Unmarshal(dAtA []byte) error {
|
||||
l := len(dAtA)
|
||||
iNdEx := 0
|
||||
|
|
@ -7541,7 +7818,7 @@ func (m *GetWorkflowsResponse) Unmarshal(dAtA []byte) error {
|
|||
switch fieldNum {
|
||||
case 1:
|
||||
if wireType != 2 {
|
||||
return fmt.Errorf("proto: wrong wireType = %d for field Workflows", wireType)
|
||||
return fmt.Errorf("proto: wrong wireType = %d for field WorkflowsByCluster", wireType)
|
||||
}
|
||||
var msglen int
|
||||
for shift := uint(0); ; shift += 7 {
|
||||
|
|
@ -7568,10 +7845,105 @@ func (m *GetWorkflowsResponse) Unmarshal(dAtA []byte) error {
|
|||
if postIndex > l {
|
||||
return io.ErrUnexpectedEOF
|
||||
}
|
||||
m.Workflows = append(m.Workflows, &Workflow{})
|
||||
if err := m.Workflows[len(m.Workflows)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
|
||||
if m.WorkflowsByCluster == nil {
|
||||
m.WorkflowsByCluster = make(map[string]*ClusterWorkflows)
|
||||
}
|
||||
var mapkey string
|
||||
var mapvalue *ClusterWorkflows
|
||||
for iNdEx < postIndex {
|
||||
entryPreIndex := iNdEx
|
||||
var wire uint64
|
||||
for shift := uint(0); ; shift += 7 {
|
||||
if shift >= 64 {
|
||||
return ErrIntOverflowVtadmin
|
||||
}
|
||||
if iNdEx >= l {
|
||||
return io.ErrUnexpectedEOF
|
||||
}
|
||||
b := dAtA[iNdEx]
|
||||
iNdEx++
|
||||
wire |= uint64(b&0x7F) << shift
|
||||
if b < 0x80 {
|
||||
break
|
||||
}
|
||||
}
|
||||
fieldNum := int32(wire >> 3)
|
||||
if fieldNum == 1 {
|
||||
var stringLenmapkey uint64
|
||||
for shift := uint(0); ; shift += 7 {
|
||||
if shift >= 64 {
|
||||
return ErrIntOverflowVtadmin
|
||||
}
|
||||
if iNdEx >= l {
|
||||
return io.ErrUnexpectedEOF
|
||||
}
|
||||
b := dAtA[iNdEx]
|
||||
iNdEx++
|
||||
stringLenmapkey |= uint64(b&0x7F) << shift
|
||||
if b < 0x80 {
|
||||
break
|
||||
}
|
||||
}
|
||||
intStringLenmapkey := int(stringLenmapkey)
|
||||
if intStringLenmapkey < 0 {
|
||||
return ErrInvalidLengthVtadmin
|
||||
}
|
||||
postStringIndexmapkey := iNdEx + intStringLenmapkey
|
||||
if postStringIndexmapkey < 0 {
|
||||
return ErrInvalidLengthVtadmin
|
||||
}
|
||||
if postStringIndexmapkey > l {
|
||||
return io.ErrUnexpectedEOF
|
||||
}
|
||||
mapkey = string(dAtA[iNdEx:postStringIndexmapkey])
|
||||
iNdEx = postStringIndexmapkey
|
||||
} else if fieldNum == 2 {
|
||||
var mapmsglen int
|
||||
for shift := uint(0); ; shift += 7 {
|
||||
if shift >= 64 {
|
||||
return ErrIntOverflowVtadmin
|
||||
}
|
||||
if iNdEx >= l {
|
||||
return io.ErrUnexpectedEOF
|
||||
}
|
||||
b := dAtA[iNdEx]
|
||||
iNdEx++
|
||||
mapmsglen |= int(b&0x7F) << shift
|
||||
if b < 0x80 {
|
||||
break
|
||||
}
|
||||
}
|
||||
if mapmsglen < 0 {
|
||||
return ErrInvalidLengthVtadmin
|
||||
}
|
||||
postmsgIndex := iNdEx + mapmsglen
|
||||
if postmsgIndex < 0 {
|
||||
return ErrInvalidLengthVtadmin
|
||||
}
|
||||
if postmsgIndex > l {
|
||||
return io.ErrUnexpectedEOF
|
||||
}
|
||||
mapvalue = &ClusterWorkflows{}
|
||||
if err := mapvalue.Unmarshal(dAtA[iNdEx:postmsgIndex]); err != nil {
|
||||
return err
|
||||
}
|
||||
iNdEx = postmsgIndex
|
||||
} else {
|
||||
iNdEx = entryPreIndex
|
||||
skippy, err := skipVtadmin(dAtA[iNdEx:])
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
if skippy < 0 {
|
||||
return ErrInvalidLengthVtadmin
|
||||
}
|
||||
if (iNdEx + skippy) > postIndex {
|
||||
return io.ErrUnexpectedEOF
|
||||
}
|
||||
iNdEx += skippy
|
||||
}
|
||||
}
|
||||
m.WorkflowsByCluster[mapkey] = mapvalue
|
||||
iNdEx = postIndex
|
||||
default:
|
||||
iNdEx = preIndex
|
||||
|
|
|
|||
|
|
@ -76,6 +76,13 @@ message Cluster {
|
|||
string name = 2;
|
||||
}
|
||||
|
||||
message ClusterWorkflows {
|
||||
repeated Workflow workflows = 1;
|
||||
// Warnings is a list of non-fatal errors encountered when fetching
|
||||
// workflows for a particular cluster.
|
||||
repeated string warnings = 2;
|
||||
}
|
||||
|
||||
// Keyspace represents information about a keyspace in a particular Vitess
|
||||
// cluster.
|
||||
message Keyspace {
|
||||
|
|
@ -244,7 +251,7 @@ message GetWorkflowsRequest {
|
|||
}
|
||||
|
||||
message GetWorkflowsResponse {
|
||||
repeated Workflow workflows = 1;
|
||||
map <string, ClusterWorkflows> workflows_by_cluster = 1;
|
||||
}
|
||||
|
||||
message VTExplainRequest {
|
||||
|
|
|
|||
|
|
@ -395,6 +395,102 @@ export namespace vtadmin {
|
|||
public toJSON(): { [k: string]: any };
|
||||
}
|
||||
|
||||
/** Properties of a ClusterWorkflows. */
|
||||
interface IClusterWorkflows {
|
||||
|
||||
/** ClusterWorkflows workflows */
|
||||
workflows?: (vtadmin.IWorkflow[]|null);
|
||||
|
||||
/** ClusterWorkflows warnings */
|
||||
warnings?: (string[]|null);
|
||||
}
|
||||
|
||||
/** Represents a ClusterWorkflows. */
|
||||
class ClusterWorkflows implements IClusterWorkflows {
|
||||
|
||||
/**
|
||||
* Constructs a new ClusterWorkflows.
|
||||
* @param [properties] Properties to set
|
||||
*/
|
||||
constructor(properties?: vtadmin.IClusterWorkflows);
|
||||
|
||||
/** ClusterWorkflows workflows. */
|
||||
public workflows: vtadmin.IWorkflow[];
|
||||
|
||||
/** ClusterWorkflows warnings. */
|
||||
public warnings: string[];
|
||||
|
||||
/**
|
||||
* Creates a new ClusterWorkflows instance using the specified properties.
|
||||
* @param [properties] Properties to set
|
||||
* @returns ClusterWorkflows instance
|
||||
*/
|
||||
public static create(properties?: vtadmin.IClusterWorkflows): vtadmin.ClusterWorkflows;
|
||||
|
||||
/**
|
||||
* Encodes the specified ClusterWorkflows message. Does not implicitly {@link vtadmin.ClusterWorkflows.verify|verify} messages.
|
||||
* @param message ClusterWorkflows message or plain object to encode
|
||||
* @param [writer] Writer to encode to
|
||||
* @returns Writer
|
||||
*/
|
||||
public static encode(message: vtadmin.IClusterWorkflows, writer?: $protobuf.Writer): $protobuf.Writer;
|
||||
|
||||
/**
|
||||
* Encodes the specified ClusterWorkflows message, length delimited. Does not implicitly {@link vtadmin.ClusterWorkflows.verify|verify} messages.
|
||||
* @param message ClusterWorkflows message or plain object to encode
|
||||
* @param [writer] Writer to encode to
|
||||
* @returns Writer
|
||||
*/
|
||||
public static encodeDelimited(message: vtadmin.IClusterWorkflows, writer?: $protobuf.Writer): $protobuf.Writer;
|
||||
|
||||
/**
|
||||
* Decodes a ClusterWorkflows message from the specified reader or buffer.
|
||||
* @param reader Reader or buffer to decode from
|
||||
* @param [length] Message length if known beforehand
|
||||
* @returns ClusterWorkflows
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
public static decode(reader: ($protobuf.Reader|Uint8Array), length?: number): vtadmin.ClusterWorkflows;
|
||||
|
||||
/**
|
||||
* Decodes a ClusterWorkflows message from the specified reader or buffer, length delimited.
|
||||
* @param reader Reader or buffer to decode from
|
||||
* @returns ClusterWorkflows
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
public static decodeDelimited(reader: ($protobuf.Reader|Uint8Array)): vtadmin.ClusterWorkflows;
|
||||
|
||||
/**
|
||||
* Verifies a ClusterWorkflows message.
|
||||
* @param message Plain object to verify
|
||||
* @returns `null` if valid, otherwise the reason why it is not
|
||||
*/
|
||||
public static verify(message: { [k: string]: any }): (string|null);
|
||||
|
||||
/**
|
||||
* Creates a ClusterWorkflows message from a plain object. Also converts values to their respective internal types.
|
||||
* @param object Plain object
|
||||
* @returns ClusterWorkflows
|
||||
*/
|
||||
public static fromObject(object: { [k: string]: any }): vtadmin.ClusterWorkflows;
|
||||
|
||||
/**
|
||||
* Creates a plain object from a ClusterWorkflows message. Also converts values to other types if specified.
|
||||
* @param message ClusterWorkflows
|
||||
* @param [options] Conversion options
|
||||
* @returns Plain object
|
||||
*/
|
||||
public static toObject(message: vtadmin.ClusterWorkflows, options?: $protobuf.IConversionOptions): { [k: string]: any };
|
||||
|
||||
/**
|
||||
* Converts this ClusterWorkflows to JSON.
|
||||
* @returns JSON object
|
||||
*/
|
||||
public toJSON(): { [k: string]: any };
|
||||
}
|
||||
|
||||
/** Properties of a Keyspace. */
|
||||
interface IKeyspace {
|
||||
|
||||
|
|
@ -2808,8 +2904,8 @@ export namespace vtadmin {
|
|||
/** Properties of a GetWorkflowsResponse. */
|
||||
interface IGetWorkflowsResponse {
|
||||
|
||||
/** GetWorkflowsResponse workflows */
|
||||
workflows?: (vtadmin.IWorkflow[]|null);
|
||||
/** GetWorkflowsResponse workflows_by_cluster */
|
||||
workflows_by_cluster?: ({ [k: string]: vtadmin.IClusterWorkflows }|null);
|
||||
}
|
||||
|
||||
/** Represents a GetWorkflowsResponse. */
|
||||
|
|
@ -2821,8 +2917,8 @@ export namespace vtadmin {
|
|||
*/
|
||||
constructor(properties?: vtadmin.IGetWorkflowsResponse);
|
||||
|
||||
/** GetWorkflowsResponse workflows. */
|
||||
public workflows: vtadmin.IWorkflow[];
|
||||
/** GetWorkflowsResponse workflows_by_cluster. */
|
||||
public workflows_by_cluster: { [k: string]: vtadmin.IClusterWorkflows };
|
||||
|
||||
/**
|
||||
* Creates a new GetWorkflowsResponse instance using the specified properties.
|
||||
|
|
|
|||
|
|
@ -692,6 +692,253 @@ $root.vtadmin = (function() {
|
|||
return Cluster;
|
||||
})();
|
||||
|
||||
vtadmin.ClusterWorkflows = (function() {
|
||||
|
||||
/**
|
||||
* Properties of a ClusterWorkflows.
|
||||
* @memberof vtadmin
|
||||
* @interface IClusterWorkflows
|
||||
* @property {Array.<vtadmin.IWorkflow>|null} [workflows] ClusterWorkflows workflows
|
||||
* @property {Array.<string>|null} [warnings] ClusterWorkflows warnings
|
||||
*/
|
||||
|
||||
/**
|
||||
* Constructs a new ClusterWorkflows.
|
||||
* @memberof vtadmin
|
||||
* @classdesc Represents a ClusterWorkflows.
|
||||
* @implements IClusterWorkflows
|
||||
* @constructor
|
||||
* @param {vtadmin.IClusterWorkflows=} [properties] Properties to set
|
||||
*/
|
||||
function ClusterWorkflows(properties) {
|
||||
this.workflows = [];
|
||||
this.warnings = [];
|
||||
if (properties)
|
||||
for (var keys = Object.keys(properties), i = 0; i < keys.length; ++i)
|
||||
if (properties[keys[i]] != null)
|
||||
this[keys[i]] = properties[keys[i]];
|
||||
}
|
||||
|
||||
/**
|
||||
* ClusterWorkflows workflows.
|
||||
* @member {Array.<vtadmin.IWorkflow>} workflows
|
||||
* @memberof vtadmin.ClusterWorkflows
|
||||
* @instance
|
||||
*/
|
||||
ClusterWorkflows.prototype.workflows = $util.emptyArray;
|
||||
|
||||
/**
|
||||
* ClusterWorkflows warnings.
|
||||
* @member {Array.<string>} warnings
|
||||
* @memberof vtadmin.ClusterWorkflows
|
||||
* @instance
|
||||
*/
|
||||
ClusterWorkflows.prototype.warnings = $util.emptyArray;
|
||||
|
||||
/**
|
||||
* Creates a new ClusterWorkflows instance using the specified properties.
|
||||
* @function create
|
||||
* @memberof vtadmin.ClusterWorkflows
|
||||
* @static
|
||||
* @param {vtadmin.IClusterWorkflows=} [properties] Properties to set
|
||||
* @returns {vtadmin.ClusterWorkflows} ClusterWorkflows instance
|
||||
*/
|
||||
ClusterWorkflows.create = function create(properties) {
|
||||
return new ClusterWorkflows(properties);
|
||||
};
|
||||
|
||||
/**
|
||||
* Encodes the specified ClusterWorkflows message. Does not implicitly {@link vtadmin.ClusterWorkflows.verify|verify} messages.
|
||||
* @function encode
|
||||
* @memberof vtadmin.ClusterWorkflows
|
||||
* @static
|
||||
* @param {vtadmin.IClusterWorkflows} message ClusterWorkflows message or plain object to encode
|
||||
* @param {$protobuf.Writer} [writer] Writer to encode to
|
||||
* @returns {$protobuf.Writer} Writer
|
||||
*/
|
||||
ClusterWorkflows.encode = function encode(message, writer) {
|
||||
if (!writer)
|
||||
writer = $Writer.create();
|
||||
if (message.workflows != null && message.workflows.length)
|
||||
for (var i = 0; i < message.workflows.length; ++i)
|
||||
$root.vtadmin.Workflow.encode(message.workflows[i], writer.uint32(/* id 1, wireType 2 =*/10).fork()).ldelim();
|
||||
if (message.warnings != null && message.warnings.length)
|
||||
for (var i = 0; i < message.warnings.length; ++i)
|
||||
writer.uint32(/* id 2, wireType 2 =*/18).string(message.warnings[i]);
|
||||
return writer;
|
||||
};
|
||||
|
||||
/**
|
||||
* Encodes the specified ClusterWorkflows message, length delimited. Does not implicitly {@link vtadmin.ClusterWorkflows.verify|verify} messages.
|
||||
* @function encodeDelimited
|
||||
* @memberof vtadmin.ClusterWorkflows
|
||||
* @static
|
||||
* @param {vtadmin.IClusterWorkflows} message ClusterWorkflows message or plain object to encode
|
||||
* @param {$protobuf.Writer} [writer] Writer to encode to
|
||||
* @returns {$protobuf.Writer} Writer
|
||||
*/
|
||||
ClusterWorkflows.encodeDelimited = function encodeDelimited(message, writer) {
|
||||
return this.encode(message, writer).ldelim();
|
||||
};
|
||||
|
||||
/**
|
||||
* Decodes a ClusterWorkflows message from the specified reader or buffer.
|
||||
* @function decode
|
||||
* @memberof vtadmin.ClusterWorkflows
|
||||
* @static
|
||||
* @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
|
||||
* @param {number} [length] Message length if known beforehand
|
||||
* @returns {vtadmin.ClusterWorkflows} ClusterWorkflows
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
ClusterWorkflows.decode = function decode(reader, length) {
|
||||
if (!(reader instanceof $Reader))
|
||||
reader = $Reader.create(reader);
|
||||
var end = length === undefined ? reader.len : reader.pos + length, message = new $root.vtadmin.ClusterWorkflows();
|
||||
while (reader.pos < end) {
|
||||
var tag = reader.uint32();
|
||||
switch (tag >>> 3) {
|
||||
case 1:
|
||||
if (!(message.workflows && message.workflows.length))
|
||||
message.workflows = [];
|
||||
message.workflows.push($root.vtadmin.Workflow.decode(reader, reader.uint32()));
|
||||
break;
|
||||
case 2:
|
||||
if (!(message.warnings && message.warnings.length))
|
||||
message.warnings = [];
|
||||
message.warnings.push(reader.string());
|
||||
break;
|
||||
default:
|
||||
reader.skipType(tag & 7);
|
||||
break;
|
||||
}
|
||||
}
|
||||
return message;
|
||||
};
|
||||
|
||||
/**
|
||||
* Decodes a ClusterWorkflows message from the specified reader or buffer, length delimited.
|
||||
* @function decodeDelimited
|
||||
* @memberof vtadmin.ClusterWorkflows
|
||||
* @static
|
||||
* @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
|
||||
* @returns {vtadmin.ClusterWorkflows} ClusterWorkflows
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
ClusterWorkflows.decodeDelimited = function decodeDelimited(reader) {
|
||||
if (!(reader instanceof $Reader))
|
||||
reader = new $Reader(reader);
|
||||
return this.decode(reader, reader.uint32());
|
||||
};
|
||||
|
||||
/**
|
||||
* Verifies a ClusterWorkflows message.
|
||||
* @function verify
|
||||
* @memberof vtadmin.ClusterWorkflows
|
||||
* @static
|
||||
* @param {Object.<string,*>} message Plain object to verify
|
||||
* @returns {string|null} `null` if valid, otherwise the reason why it is not
|
||||
*/
|
||||
ClusterWorkflows.verify = function verify(message) {
|
||||
if (typeof message !== "object" || message === null)
|
||||
return "object expected";
|
||||
if (message.workflows != null && message.hasOwnProperty("workflows")) {
|
||||
if (!Array.isArray(message.workflows))
|
||||
return "workflows: array expected";
|
||||
for (var i = 0; i < message.workflows.length; ++i) {
|
||||
var error = $root.vtadmin.Workflow.verify(message.workflows[i]);
|
||||
if (error)
|
||||
return "workflows." + error;
|
||||
}
|
||||
}
|
||||
if (message.warnings != null && message.hasOwnProperty("warnings")) {
|
||||
if (!Array.isArray(message.warnings))
|
||||
return "warnings: array expected";
|
||||
for (var i = 0; i < message.warnings.length; ++i)
|
||||
if (!$util.isString(message.warnings[i]))
|
||||
return "warnings: string[] expected";
|
||||
}
|
||||
return null;
|
||||
};
|
||||
|
||||
/**
|
||||
* Creates a ClusterWorkflows message from a plain object. Also converts values to their respective internal types.
|
||||
* @function fromObject
|
||||
* @memberof vtadmin.ClusterWorkflows
|
||||
* @static
|
||||
* @param {Object.<string,*>} object Plain object
|
||||
* @returns {vtadmin.ClusterWorkflows} ClusterWorkflows
|
||||
*/
|
||||
ClusterWorkflows.fromObject = function fromObject(object) {
|
||||
if (object instanceof $root.vtadmin.ClusterWorkflows)
|
||||
return object;
|
||||
var message = new $root.vtadmin.ClusterWorkflows();
|
||||
if (object.workflows) {
|
||||
if (!Array.isArray(object.workflows))
|
||||
throw TypeError(".vtadmin.ClusterWorkflows.workflows: array expected");
|
||||
message.workflows = [];
|
||||
for (var i = 0; i < object.workflows.length; ++i) {
|
||||
if (typeof object.workflows[i] !== "object")
|
||||
throw TypeError(".vtadmin.ClusterWorkflows.workflows: object expected");
|
||||
message.workflows[i] = $root.vtadmin.Workflow.fromObject(object.workflows[i]);
|
||||
}
|
||||
}
|
||||
if (object.warnings) {
|
||||
if (!Array.isArray(object.warnings))
|
||||
throw TypeError(".vtadmin.ClusterWorkflows.warnings: array expected");
|
||||
message.warnings = [];
|
||||
for (var i = 0; i < object.warnings.length; ++i)
|
||||
message.warnings[i] = String(object.warnings[i]);
|
||||
}
|
||||
return message;
|
||||
};
|
||||
|
||||
/**
|
||||
* Creates a plain object from a ClusterWorkflows message. Also converts values to other types if specified.
|
||||
* @function toObject
|
||||
* @memberof vtadmin.ClusterWorkflows
|
||||
* @static
|
||||
* @param {vtadmin.ClusterWorkflows} message ClusterWorkflows
|
||||
* @param {$protobuf.IConversionOptions} [options] Conversion options
|
||||
* @returns {Object.<string,*>} Plain object
|
||||
*/
|
||||
ClusterWorkflows.toObject = function toObject(message, options) {
|
||||
if (!options)
|
||||
options = {};
|
||||
var object = {};
|
||||
if (options.arrays || options.defaults) {
|
||||
object.workflows = [];
|
||||
object.warnings = [];
|
||||
}
|
||||
if (message.workflows && message.workflows.length) {
|
||||
object.workflows = [];
|
||||
for (var j = 0; j < message.workflows.length; ++j)
|
||||
object.workflows[j] = $root.vtadmin.Workflow.toObject(message.workflows[j], options);
|
||||
}
|
||||
if (message.warnings && message.warnings.length) {
|
||||
object.warnings = [];
|
||||
for (var j = 0; j < message.warnings.length; ++j)
|
||||
object.warnings[j] = message.warnings[j];
|
||||
}
|
||||
return object;
|
||||
};
|
||||
|
||||
/**
|
||||
* Converts this ClusterWorkflows to JSON.
|
||||
* @function toJSON
|
||||
* @memberof vtadmin.ClusterWorkflows
|
||||
* @instance
|
||||
* @returns {Object.<string,*>} JSON object
|
||||
*/
|
||||
ClusterWorkflows.prototype.toJSON = function toJSON() {
|
||||
return this.constructor.toObject(this, $protobuf.util.toJSONOptions);
|
||||
};
|
||||
|
||||
return ClusterWorkflows;
|
||||
})();
|
||||
|
||||
vtadmin.Keyspace = (function() {
|
||||
|
||||
/**
|
||||
|
|
@ -6389,7 +6636,7 @@ $root.vtadmin = (function() {
|
|||
* Properties of a GetWorkflowsResponse.
|
||||
* @memberof vtadmin
|
||||
* @interface IGetWorkflowsResponse
|
||||
* @property {Array.<vtadmin.IWorkflow>|null} [workflows] GetWorkflowsResponse workflows
|
||||
* @property {Object.<string,vtadmin.IClusterWorkflows>|null} [workflows_by_cluster] GetWorkflowsResponse workflows_by_cluster
|
||||
*/
|
||||
|
||||
/**
|
||||
|
|
@ -6401,7 +6648,7 @@ $root.vtadmin = (function() {
|
|||
* @param {vtadmin.IGetWorkflowsResponse=} [properties] Properties to set
|
||||
*/
|
||||
function GetWorkflowsResponse(properties) {
|
||||
this.workflows = [];
|
||||
this.workflows_by_cluster = {};
|
||||
if (properties)
|
||||
for (var keys = Object.keys(properties), i = 0; i < keys.length; ++i)
|
||||
if (properties[keys[i]] != null)
|
||||
|
|
@ -6409,12 +6656,12 @@ $root.vtadmin = (function() {
|
|||
}
|
||||
|
||||
/**
|
||||
* GetWorkflowsResponse workflows.
|
||||
* @member {Array.<vtadmin.IWorkflow>} workflows
|
||||
* GetWorkflowsResponse workflows_by_cluster.
|
||||
* @member {Object.<string,vtadmin.IClusterWorkflows>} workflows_by_cluster
|
||||
* @memberof vtadmin.GetWorkflowsResponse
|
||||
* @instance
|
||||
*/
|
||||
GetWorkflowsResponse.prototype.workflows = $util.emptyArray;
|
||||
GetWorkflowsResponse.prototype.workflows_by_cluster = $util.emptyObject;
|
||||
|
||||
/**
|
||||
* Creates a new GetWorkflowsResponse instance using the specified properties.
|
||||
|
|
@ -6440,9 +6687,11 @@ $root.vtadmin = (function() {
|
|||
GetWorkflowsResponse.encode = function encode(message, writer) {
|
||||
if (!writer)
|
||||
writer = $Writer.create();
|
||||
if (message.workflows != null && message.workflows.length)
|
||||
for (var i = 0; i < message.workflows.length; ++i)
|
||||
$root.vtadmin.Workflow.encode(message.workflows[i], writer.uint32(/* id 1, wireType 2 =*/10).fork()).ldelim();
|
||||
if (message.workflows_by_cluster != null && Object.hasOwnProperty.call(message, "workflows_by_cluster"))
|
||||
for (var keys = Object.keys(message.workflows_by_cluster), i = 0; i < keys.length; ++i) {
|
||||
writer.uint32(/* id 1, wireType 2 =*/10).fork().uint32(/* id 1, wireType 2 =*/10).string(keys[i]);
|
||||
$root.vtadmin.ClusterWorkflows.encode(message.workflows_by_cluster[keys[i]], writer.uint32(/* id 2, wireType 2 =*/18).fork()).ldelim().ldelim();
|
||||
}
|
||||
return writer;
|
||||
};
|
||||
|
||||
|
|
@ -6473,14 +6722,31 @@ $root.vtadmin = (function() {
|
|||
GetWorkflowsResponse.decode = function decode(reader, length) {
|
||||
if (!(reader instanceof $Reader))
|
||||
reader = $Reader.create(reader);
|
||||
var end = length === undefined ? reader.len : reader.pos + length, message = new $root.vtadmin.GetWorkflowsResponse();
|
||||
var end = length === undefined ? reader.len : reader.pos + length, message = new $root.vtadmin.GetWorkflowsResponse(), key, value;
|
||||
while (reader.pos < end) {
|
||||
var tag = reader.uint32();
|
||||
switch (tag >>> 3) {
|
||||
case 1:
|
||||
if (!(message.workflows && message.workflows.length))
|
||||
message.workflows = [];
|
||||
message.workflows.push($root.vtadmin.Workflow.decode(reader, reader.uint32()));
|
||||
if (message.workflows_by_cluster === $util.emptyObject)
|
||||
message.workflows_by_cluster = {};
|
||||
var end2 = reader.uint32() + reader.pos;
|
||||
key = "";
|
||||
value = null;
|
||||
while (reader.pos < end2) {
|
||||
var tag2 = reader.uint32();
|
||||
switch (tag2 >>> 3) {
|
||||
case 1:
|
||||
key = reader.string();
|
||||
break;
|
||||
case 2:
|
||||
value = $root.vtadmin.ClusterWorkflows.decode(reader, reader.uint32());
|
||||
break;
|
||||
default:
|
||||
reader.skipType(tag2 & 7);
|
||||
break;
|
||||
}
|
||||
}
|
||||
message.workflows_by_cluster[key] = value;
|
||||
break;
|
||||
default:
|
||||
reader.skipType(tag & 7);
|
||||
|
|
@ -6517,13 +6783,14 @@ $root.vtadmin = (function() {
|
|||
GetWorkflowsResponse.verify = function verify(message) {
|
||||
if (typeof message !== "object" || message === null)
|
||||
return "object expected";
|
||||
if (message.workflows != null && message.hasOwnProperty("workflows")) {
|
||||
if (!Array.isArray(message.workflows))
|
||||
return "workflows: array expected";
|
||||
for (var i = 0; i < message.workflows.length; ++i) {
|
||||
var error = $root.vtadmin.Workflow.verify(message.workflows[i]);
|
||||
if (message.workflows_by_cluster != null && message.hasOwnProperty("workflows_by_cluster")) {
|
||||
if (!$util.isObject(message.workflows_by_cluster))
|
||||
return "workflows_by_cluster: object expected";
|
||||
var key = Object.keys(message.workflows_by_cluster);
|
||||
for (var i = 0; i < key.length; ++i) {
|
||||
var error = $root.vtadmin.ClusterWorkflows.verify(message.workflows_by_cluster[key[i]]);
|
||||
if (error)
|
||||
return "workflows." + error;
|
||||
return "workflows_by_cluster." + error;
|
||||
}
|
||||
}
|
||||
return null;
|
||||
|
|
@ -6541,14 +6808,14 @@ $root.vtadmin = (function() {
|
|||
if (object instanceof $root.vtadmin.GetWorkflowsResponse)
|
||||
return object;
|
||||
var message = new $root.vtadmin.GetWorkflowsResponse();
|
||||
if (object.workflows) {
|
||||
if (!Array.isArray(object.workflows))
|
||||
throw TypeError(".vtadmin.GetWorkflowsResponse.workflows: array expected");
|
||||
message.workflows = [];
|
||||
for (var i = 0; i < object.workflows.length; ++i) {
|
||||
if (typeof object.workflows[i] !== "object")
|
||||
throw TypeError(".vtadmin.GetWorkflowsResponse.workflows: object expected");
|
||||
message.workflows[i] = $root.vtadmin.Workflow.fromObject(object.workflows[i]);
|
||||
if (object.workflows_by_cluster) {
|
||||
if (typeof object.workflows_by_cluster !== "object")
|
||||
throw TypeError(".vtadmin.GetWorkflowsResponse.workflows_by_cluster: object expected");
|
||||
message.workflows_by_cluster = {};
|
||||
for (var keys = Object.keys(object.workflows_by_cluster), i = 0; i < keys.length; ++i) {
|
||||
if (typeof object.workflows_by_cluster[keys[i]] !== "object")
|
||||
throw TypeError(".vtadmin.GetWorkflowsResponse.workflows_by_cluster: object expected");
|
||||
message.workflows_by_cluster[keys[i]] = $root.vtadmin.ClusterWorkflows.fromObject(object.workflows_by_cluster[keys[i]]);
|
||||
}
|
||||
}
|
||||
return message;
|
||||
|
|
@ -6567,12 +6834,13 @@ $root.vtadmin = (function() {
|
|||
if (!options)
|
||||
options = {};
|
||||
var object = {};
|
||||
if (options.arrays || options.defaults)
|
||||
object.workflows = [];
|
||||
if (message.workflows && message.workflows.length) {
|
||||
object.workflows = [];
|
||||
for (var j = 0; j < message.workflows.length; ++j)
|
||||
object.workflows[j] = $root.vtadmin.Workflow.toObject(message.workflows[j], options);
|
||||
if (options.objects || options.defaults)
|
||||
object.workflows_by_cluster = {};
|
||||
var keys2;
|
||||
if (message.workflows_by_cluster && (keys2 = Object.keys(message.workflows_by_cluster)).length) {
|
||||
object.workflows_by_cluster = {};
|
||||
for (var j = 0; j < keys2.length; ++j)
|
||||
object.workflows_by_cluster[keys2[j]] = $root.vtadmin.ClusterWorkflows.toObject(message.workflows_by_cluster[keys2[j]], options);
|
||||
}
|
||||
return object;
|
||||
};
|
||||
|
|
|
|||
Загрузка…
Ссылка в новой задаче