go/proto/api/v1/domain.pb.go (2,576 lines of code) (raw):
// The MIT License (MIT)
//
// Copyright (c) 2021 Uber Technologies, Inc.
//
// Permission is hereby granted, free of charge, to any person obtaining a copy
// of this software and associated documentation files (the "Software"), to deal
// in the Software without restriction, including without limitation the rights
// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
// copies of the Software, and to permit persons to whom the Software is
// furnished to do so, subject to the following conditions:
//
// The above copyright notice and this permission notice shall be included in all
// copies or substantial portions of the Software.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
// SOFTWARE.
// Code generated by protoc-gen-gogo. DO NOT EDIT.
// source: uber/cadence/api/v1/domain.proto
package apiv1
import (
fmt "fmt"
proto "github.com/gogo/protobuf/proto"
types "github.com/gogo/protobuf/types"
io "io"
math "math"
math_bits "math/bits"
)
// 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.GoGoProtoPackageIsVersion3 // please upgrade the proto package
type DomainStatus int32
const (
DomainStatus_DOMAIN_STATUS_INVALID DomainStatus = 0
DomainStatus_DOMAIN_STATUS_REGISTERED DomainStatus = 1
DomainStatus_DOMAIN_STATUS_DEPRECATED DomainStatus = 2
DomainStatus_DOMAIN_STATUS_DELETED DomainStatus = 3
)
var DomainStatus_name = map[int32]string{
0: "DOMAIN_STATUS_INVALID",
1: "DOMAIN_STATUS_REGISTERED",
2: "DOMAIN_STATUS_DEPRECATED",
3: "DOMAIN_STATUS_DELETED",
}
var DomainStatus_value = map[string]int32{
"DOMAIN_STATUS_INVALID": 0,
"DOMAIN_STATUS_REGISTERED": 1,
"DOMAIN_STATUS_DEPRECATED": 2,
"DOMAIN_STATUS_DELETED": 3,
}
func (x DomainStatus) String() string {
return proto.EnumName(DomainStatus_name, int32(x))
}
func (DomainStatus) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_824795d6ae7d8e2f, []int{0}
}
type ArchivalStatus int32
const (
ArchivalStatus_ARCHIVAL_STATUS_INVALID ArchivalStatus = 0
ArchivalStatus_ARCHIVAL_STATUS_DISABLED ArchivalStatus = 1
ArchivalStatus_ARCHIVAL_STATUS_ENABLED ArchivalStatus = 2
)
var ArchivalStatus_name = map[int32]string{
0: "ARCHIVAL_STATUS_INVALID",
1: "ARCHIVAL_STATUS_DISABLED",
2: "ARCHIVAL_STATUS_ENABLED",
}
var ArchivalStatus_value = map[string]int32{
"ARCHIVAL_STATUS_INVALID": 0,
"ARCHIVAL_STATUS_DISABLED": 1,
"ARCHIVAL_STATUS_ENABLED": 2,
}
func (x ArchivalStatus) String() string {
return proto.EnumName(ArchivalStatus_name, int32(x))
}
func (ArchivalStatus) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_824795d6ae7d8e2f, []int{1}
}
type Domain struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Status DomainStatus `protobuf:"varint,3,opt,name=status,proto3,enum=uber.cadence.api.v1.DomainStatus" json:"status,omitempty"`
Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
OwnerEmail string `protobuf:"bytes,5,opt,name=owner_email,json=ownerEmail,proto3" json:"owner_email,omitempty"`
Data map[string]string `protobuf:"bytes,6,rep,name=data,proto3" json:"data,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
WorkflowExecutionRetentionPeriod *types.Duration `protobuf:"bytes,7,opt,name=workflow_execution_retention_period,json=workflowExecutionRetentionPeriod,proto3" json:"workflow_execution_retention_period,omitempty"`
BadBinaries *BadBinaries `protobuf:"bytes,8,opt,name=bad_binaries,json=badBinaries,proto3" json:"bad_binaries,omitempty"`
HistoryArchivalStatus ArchivalStatus `protobuf:"varint,9,opt,name=history_archival_status,json=historyArchivalStatus,proto3,enum=uber.cadence.api.v1.ArchivalStatus" json:"history_archival_status,omitempty"`
HistoryArchivalUri string `protobuf:"bytes,10,opt,name=history_archival_uri,json=historyArchivalUri,proto3" json:"history_archival_uri,omitempty"`
VisibilityArchivalStatus ArchivalStatus `protobuf:"varint,11,opt,name=visibility_archival_status,json=visibilityArchivalStatus,proto3,enum=uber.cadence.api.v1.ArchivalStatus" json:"visibility_archival_status,omitempty"`
VisibilityArchivalUri string `protobuf:"bytes,12,opt,name=visibility_archival_uri,json=visibilityArchivalUri,proto3" json:"visibility_archival_uri,omitempty"`
ActiveClusterName string `protobuf:"bytes,13,opt,name=active_cluster_name,json=activeClusterName,proto3" json:"active_cluster_name,omitempty"`
Clusters []*ClusterReplicationConfiguration `protobuf:"bytes,14,rep,name=clusters,proto3" json:"clusters,omitempty"`
FailoverVersion int64 `protobuf:"varint,15,opt,name=failover_version,json=failoverVersion,proto3" json:"failover_version,omitempty"`
IsGlobalDomain bool `protobuf:"varint,16,opt,name=is_global_domain,json=isGlobalDomain,proto3" json:"is_global_domain,omitempty"`
FailoverInfo *FailoverInfo `protobuf:"bytes,17,opt,name=failover_info,json=failoverInfo,proto3" json:"failover_info,omitempty"`
IsolationGroups *IsolationGroupConfiguration `protobuf:"bytes,18,opt,name=isolation_groups,json=isolationGroups,proto3" json:"isolation_groups,omitempty"`
AsyncWorkflowConfig *AsyncWorkflowConfiguration `protobuf:"bytes,19,opt,name=async_workflow_config,json=asyncWorkflowConfig,proto3" json:"async_workflow_config,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Domain) Reset() { *m = Domain{} }
func (m *Domain) String() string { return proto.CompactTextString(m) }
func (*Domain) ProtoMessage() {}
func (*Domain) Descriptor() ([]byte, []int) {
return fileDescriptor_824795d6ae7d8e2f, []int{0}
}
func (m *Domain) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *Domain) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_Domain.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 *Domain) XXX_Merge(src proto.Message) {
xxx_messageInfo_Domain.Merge(m, src)
}
func (m *Domain) XXX_Size() int {
return m.Size()
}
func (m *Domain) XXX_DiscardUnknown() {
xxx_messageInfo_Domain.DiscardUnknown(m)
}
var xxx_messageInfo_Domain proto.InternalMessageInfo
func (m *Domain) GetId() string {
if m != nil {
return m.Id
}
return ""
}
func (m *Domain) GetName() string {
if m != nil {
return m.Name
}
return ""
}
func (m *Domain) GetStatus() DomainStatus {
if m != nil {
return m.Status
}
return DomainStatus_DOMAIN_STATUS_INVALID
}
func (m *Domain) GetDescription() string {
if m != nil {
return m.Description
}
return ""
}
func (m *Domain) GetOwnerEmail() string {
if m != nil {
return m.OwnerEmail
}
return ""
}
func (m *Domain) GetData() map[string]string {
if m != nil {
return m.Data
}
return nil
}
func (m *Domain) GetWorkflowExecutionRetentionPeriod() *types.Duration {
if m != nil {
return m.WorkflowExecutionRetentionPeriod
}
return nil
}
func (m *Domain) GetBadBinaries() *BadBinaries {
if m != nil {
return m.BadBinaries
}
return nil
}
func (m *Domain) GetHistoryArchivalStatus() ArchivalStatus {
if m != nil {
return m.HistoryArchivalStatus
}
return ArchivalStatus_ARCHIVAL_STATUS_INVALID
}
func (m *Domain) GetHistoryArchivalUri() string {
if m != nil {
return m.HistoryArchivalUri
}
return ""
}
func (m *Domain) GetVisibilityArchivalStatus() ArchivalStatus {
if m != nil {
return m.VisibilityArchivalStatus
}
return ArchivalStatus_ARCHIVAL_STATUS_INVALID
}
func (m *Domain) GetVisibilityArchivalUri() string {
if m != nil {
return m.VisibilityArchivalUri
}
return ""
}
func (m *Domain) GetActiveClusterName() string {
if m != nil {
return m.ActiveClusterName
}
return ""
}
func (m *Domain) GetClusters() []*ClusterReplicationConfiguration {
if m != nil {
return m.Clusters
}
return nil
}
func (m *Domain) GetFailoverVersion() int64 {
if m != nil {
return m.FailoverVersion
}
return 0
}
func (m *Domain) GetIsGlobalDomain() bool {
if m != nil {
return m.IsGlobalDomain
}
return false
}
func (m *Domain) GetFailoverInfo() *FailoverInfo {
if m != nil {
return m.FailoverInfo
}
return nil
}
func (m *Domain) GetIsolationGroups() *IsolationGroupConfiguration {
if m != nil {
return m.IsolationGroups
}
return nil
}
func (m *Domain) GetAsyncWorkflowConfig() *AsyncWorkflowConfiguration {
if m != nil {
return m.AsyncWorkflowConfig
}
return nil
}
type ClusterReplicationConfiguration struct {
ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ClusterReplicationConfiguration) Reset() { *m = ClusterReplicationConfiguration{} }
func (m *ClusterReplicationConfiguration) String() string { return proto.CompactTextString(m) }
func (*ClusterReplicationConfiguration) ProtoMessage() {}
func (*ClusterReplicationConfiguration) Descriptor() ([]byte, []int) {
return fileDescriptor_824795d6ae7d8e2f, []int{1}
}
func (m *ClusterReplicationConfiguration) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *ClusterReplicationConfiguration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_ClusterReplicationConfiguration.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 *ClusterReplicationConfiguration) XXX_Merge(src proto.Message) {
xxx_messageInfo_ClusterReplicationConfiguration.Merge(m, src)
}
func (m *ClusterReplicationConfiguration) XXX_Size() int {
return m.Size()
}
func (m *ClusterReplicationConfiguration) XXX_DiscardUnknown() {
xxx_messageInfo_ClusterReplicationConfiguration.DiscardUnknown(m)
}
var xxx_messageInfo_ClusterReplicationConfiguration proto.InternalMessageInfo
func (m *ClusterReplicationConfiguration) GetClusterName() string {
if m != nil {
return m.ClusterName
}
return ""
}
type BadBinaries struct {
Binaries map[string]*BadBinaryInfo `protobuf:"bytes,1,rep,name=binaries,proto3" json:"binaries,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:"-"`
}
func (m *BadBinaries) Reset() { *m = BadBinaries{} }
func (m *BadBinaries) String() string { return proto.CompactTextString(m) }
func (*BadBinaries) ProtoMessage() {}
func (*BadBinaries) Descriptor() ([]byte, []int) {
return fileDescriptor_824795d6ae7d8e2f, []int{2}
}
func (m *BadBinaries) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *BadBinaries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_BadBinaries.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 *BadBinaries) XXX_Merge(src proto.Message) {
xxx_messageInfo_BadBinaries.Merge(m, src)
}
func (m *BadBinaries) XXX_Size() int {
return m.Size()
}
func (m *BadBinaries) XXX_DiscardUnknown() {
xxx_messageInfo_BadBinaries.DiscardUnknown(m)
}
var xxx_messageInfo_BadBinaries proto.InternalMessageInfo
func (m *BadBinaries) GetBinaries() map[string]*BadBinaryInfo {
if m != nil {
return m.Binaries
}
return nil
}
type BadBinaryInfo struct {
Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"`
Operator string `protobuf:"bytes,2,opt,name=operator,proto3" json:"operator,omitempty"`
CreatedTime *types.Timestamp `protobuf:"bytes,3,opt,name=created_time,json=createdTime,proto3" json:"created_time,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *BadBinaryInfo) Reset() { *m = BadBinaryInfo{} }
func (m *BadBinaryInfo) String() string { return proto.CompactTextString(m) }
func (*BadBinaryInfo) ProtoMessage() {}
func (*BadBinaryInfo) Descriptor() ([]byte, []int) {
return fileDescriptor_824795d6ae7d8e2f, []int{3}
}
func (m *BadBinaryInfo) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *BadBinaryInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_BadBinaryInfo.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 *BadBinaryInfo) XXX_Merge(src proto.Message) {
xxx_messageInfo_BadBinaryInfo.Merge(m, src)
}
func (m *BadBinaryInfo) XXX_Size() int {
return m.Size()
}
func (m *BadBinaryInfo) XXX_DiscardUnknown() {
xxx_messageInfo_BadBinaryInfo.DiscardUnknown(m)
}
var xxx_messageInfo_BadBinaryInfo proto.InternalMessageInfo
func (m *BadBinaryInfo) GetReason() string {
if m != nil {
return m.Reason
}
return ""
}
func (m *BadBinaryInfo) GetOperator() string {
if m != nil {
return m.Operator
}
return ""
}
func (m *BadBinaryInfo) GetCreatedTime() *types.Timestamp {
if m != nil {
return m.CreatedTime
}
return nil
}
type FailoverInfo struct {
FailoverVersion int64 `protobuf:"varint,1,opt,name=failover_version,json=failoverVersion,proto3" json:"failover_version,omitempty"`
FailoverStartTimestamp *types.Timestamp `protobuf:"bytes,2,opt,name=failover_start_timestamp,json=failoverStartTimestamp,proto3" json:"failover_start_timestamp,omitempty"`
FailoverExpireTimestamp *types.Timestamp `protobuf:"bytes,3,opt,name=failover_expire_timestamp,json=failoverExpireTimestamp,proto3" json:"failover_expire_timestamp,omitempty"`
CompletedShardCount int32 `protobuf:"varint,4,opt,name=completed_shard_count,json=completedShardCount,proto3" json:"completed_shard_count,omitempty"`
PendingShards []int32 `protobuf:"varint,5,rep,packed,name=pending_shards,json=pendingShards,proto3" json:"pending_shards,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *FailoverInfo) Reset() { *m = FailoverInfo{} }
func (m *FailoverInfo) String() string { return proto.CompactTextString(m) }
func (*FailoverInfo) ProtoMessage() {}
func (*FailoverInfo) Descriptor() ([]byte, []int) {
return fileDescriptor_824795d6ae7d8e2f, []int{4}
}
func (m *FailoverInfo) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *FailoverInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_FailoverInfo.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 *FailoverInfo) XXX_Merge(src proto.Message) {
xxx_messageInfo_FailoverInfo.Merge(m, src)
}
func (m *FailoverInfo) XXX_Size() int {
return m.Size()
}
func (m *FailoverInfo) XXX_DiscardUnknown() {
xxx_messageInfo_FailoverInfo.DiscardUnknown(m)
}
var xxx_messageInfo_FailoverInfo proto.InternalMessageInfo
func (m *FailoverInfo) GetFailoverVersion() int64 {
if m != nil {
return m.FailoverVersion
}
return 0
}
func (m *FailoverInfo) GetFailoverStartTimestamp() *types.Timestamp {
if m != nil {
return m.FailoverStartTimestamp
}
return nil
}
func (m *FailoverInfo) GetFailoverExpireTimestamp() *types.Timestamp {
if m != nil {
return m.FailoverExpireTimestamp
}
return nil
}
func (m *FailoverInfo) GetCompletedShardCount() int32 {
if m != nil {
return m.CompletedShardCount
}
return 0
}
func (m *FailoverInfo) GetPendingShards() []int32 {
if m != nil {
return m.PendingShards
}
return nil
}
func init() {
proto.RegisterEnum("uber.cadence.api.v1.DomainStatus", DomainStatus_name, DomainStatus_value)
proto.RegisterEnum("uber.cadence.api.v1.ArchivalStatus", ArchivalStatus_name, ArchivalStatus_value)
proto.RegisterType((*Domain)(nil), "uber.cadence.api.v1.Domain")
proto.RegisterMapType((map[string]string)(nil), "uber.cadence.api.v1.Domain.DataEntry")
proto.RegisterType((*ClusterReplicationConfiguration)(nil), "uber.cadence.api.v1.ClusterReplicationConfiguration")
proto.RegisterType((*BadBinaries)(nil), "uber.cadence.api.v1.BadBinaries")
proto.RegisterMapType((map[string]*BadBinaryInfo)(nil), "uber.cadence.api.v1.BadBinaries.BinariesEntry")
proto.RegisterType((*BadBinaryInfo)(nil), "uber.cadence.api.v1.BadBinaryInfo")
proto.RegisterType((*FailoverInfo)(nil), "uber.cadence.api.v1.FailoverInfo")
}
func init() { proto.RegisterFile("uber/cadence/api/v1/domain.proto", fileDescriptor_824795d6ae7d8e2f) }
var fileDescriptor_824795d6ae7d8e2f = []byte{
// 1062 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x56, 0x41, 0x6f, 0xdb, 0x46,
0x13, 0xfd, 0x28, 0xc5, 0xfe, 0xec, 0xa1, 0x2c, 0x2b, 0xeb, 0x38, 0xa6, 0xd5, 0xc2, 0x66, 0x1c,
0x04, 0x50, 0x03, 0x94, 0x8a, 0xd5, 0xa2, 0x4d, 0x5a, 0xf4, 0x20, 0x8b, 0x8c, 0xab, 0xc2, 0x75,
0x0d, 0x4a, 0x71, 0x81, 0xe6, 0x40, 0xac, 0xc8, 0x95, 0xb4, 0x08, 0xc5, 0x25, 0x96, 0xa4, 0x1c,
0xdf, 0x8a, 0xfe, 0xac, 0x1e, 0x7b, 0xea, 0xb1, 0xc7, 0x1e, 0x0b, 0xff, 0x92, 0x82, 0xcb, 0x25,
0x2d, 0x59, 0x84, 0xdd, 0xdb, 0xee, 0xcc, 0x7b, 0x6f, 0x66, 0x87, 0x33, 0xbb, 0x04, 0x3d, 0x19,
0x11, 0xde, 0x76, 0xb1, 0x47, 0x02, 0x97, 0xb4, 0x71, 0x48, 0xdb, 0xf3, 0xe3, 0xb6, 0xc7, 0x66,
0x98, 0x06, 0x46, 0xc8, 0x59, 0xcc, 0xd0, 0x4e, 0x8a, 0x30, 0x24, 0xc2, 0xc0, 0x21, 0x35, 0xe6,
0xc7, 0xcd, 0x83, 0x09, 0x63, 0x13, 0x9f, 0xb4, 0x05, 0x64, 0x94, 0x8c, 0xdb, 0x5e, 0xc2, 0x71,
0x4c, 0x99, 0x24, 0x35, 0x0f, 0xef, 0xfa, 0x63, 0x3a, 0x23, 0x51, 0x8c, 0x67, 0xa1, 0x04, 0x94,
0xc6, 0x75, 0xd9, 0x6c, 0x96, 0x4b, 0x1c, 0xfd, 0xbd, 0x09, 0xeb, 0xa6, 0x48, 0x04, 0xd5, 0xa1,
0x42, 0x3d, 0x4d, 0xd1, 0x95, 0xd6, 0xa6, 0x5d, 0xa1, 0x1e, 0x42, 0xf0, 0x28, 0xc0, 0x33, 0xa2,
0x55, 0x84, 0x45, 0xac, 0xd1, 0x1b, 0x58, 0x8f, 0x62, 0x1c, 0x27, 0x91, 0x56, 0xd5, 0x95, 0x56,
0xbd, 0xf3, 0xcc, 0x28, 0xc9, 0xdb, 0xc8, 0x04, 0x07, 0x02, 0x68, 0x4b, 0x02, 0xd2, 0x41, 0xf5,
0x48, 0xe4, 0x72, 0x1a, 0xa6, 0x27, 0xd0, 0x1e, 0x09, 0xd5, 0x45, 0x13, 0x3a, 0x04, 0x95, 0x5d,
0x05, 0x84, 0x3b, 0x64, 0x86, 0xa9, 0xaf, 0xad, 0x09, 0x04, 0x08, 0x93, 0x95, 0x5a, 0xd0, 0x1b,
0x78, 0xe4, 0xe1, 0x18, 0x6b, 0xeb, 0x7a, 0xb5, 0xa5, 0x76, 0x5e, 0xdc, 0x13, 0xdb, 0x30, 0x71,
0x8c, 0xad, 0x20, 0xe6, 0xd7, 0xb6, 0xa0, 0xa0, 0x29, 0x3c, 0xbf, 0x62, 0xfc, 0xc3, 0xd8, 0x67,
0x57, 0x0e, 0xf9, 0x48, 0xdc, 0x24, 0x8d, 0xe8, 0x70, 0x12, 0x93, 0x40, 0xac, 0x42, 0xc2, 0x29,
0xf3, 0xb4, 0xff, 0xeb, 0x4a, 0x4b, 0xed, 0xec, 0x1b, 0x59, 0x61, 0x8d, 0xbc, 0xb0, 0x86, 0x29,
0x0b, 0x6f, 0xeb, 0xb9, 0x8a, 0x95, 0x8b, 0xd8, 0xb9, 0xc6, 0x85, 0x90, 0x40, 0x3d, 0xa8, 0x8d,
0xb0, 0xe7, 0x8c, 0x68, 0x80, 0x39, 0x25, 0x91, 0xb6, 0x21, 0x24, 0xf5, 0xd2, 0x64, 0x4f, 0xb0,
0x77, 0x22, 0x71, 0xb6, 0x3a, 0xba, 0xdd, 0xa0, 0xf7, 0xb0, 0x37, 0xa5, 0x51, 0xcc, 0xf8, 0xb5,
0x83, 0xb9, 0x3b, 0xa5, 0x73, 0xec, 0x3b, 0xb2, 0xf0, 0x9b, 0xa2, 0xf0, 0xcf, 0x4b, 0xf5, 0xba,
0x12, 0x2b, 0x4b, 0xbf, 0x2b, 0x35, 0x96, 0xcd, 0xe8, 0x15, 0x3c, 0x59, 0x11, 0x4f, 0x38, 0xd5,
0x40, 0x14, 0x1c, 0xdd, 0x21, 0xbd, 0xe3, 0x14, 0x61, 0x68, 0xce, 0x69, 0x44, 0x47, 0xd4, 0xa7,
0xf1, 0x6a, 0x46, 0xea, 0x7f, 0xcf, 0x48, 0xbb, 0x95, 0xb9, 0x93, 0xd4, 0x57, 0xb0, 0x57, 0x16,
0x22, 0xcd, 0xab, 0x26, 0xf2, 0xda, 0x5d, 0xa5, 0xa6, 0xa9, 0x19, 0xb0, 0x83, 0xdd, 0x98, 0xce,
0x89, 0xe3, 0xfa, 0x49, 0x14, 0x13, 0xee, 0x88, 0xa6, 0xdd, 0x12, 0x9c, 0xc7, 0x99, 0xab, 0x97,
0x79, 0xce, 0xd3, 0x0e, 0xbe, 0x80, 0x0d, 0x09, 0x8c, 0xb4, 0xba, 0xe8, 0xa3, 0x2f, 0x4b, 0x13,
0x97, 0x1c, 0x9b, 0x84, 0x3e, 0x75, 0xc5, 0xb7, 0xef, 0xb1, 0x60, 0x4c, 0x27, 0x79, 0x23, 0x14,
0x2a, 0xe8, 0x33, 0x68, 0x8c, 0x31, 0xf5, 0xd9, 0x9c, 0x70, 0x67, 0x4e, 0x78, 0x94, 0x76, 0xf7,
0xb6, 0xae, 0xb4, 0xaa, 0xf6, 0x76, 0x6e, 0xbf, 0xcc, 0xcc, 0xa8, 0x05, 0x0d, 0x1a, 0x39, 0x13,
0x9f, 0x8d, 0xb0, 0xef, 0x64, 0xf3, 0xaf, 0x35, 0x74, 0xa5, 0xb5, 0x61, 0xd7, 0x69, 0x74, 0x2a,
0xcc, 0x72, 0x18, 0xdf, 0xc2, 0x56, 0x21, 0x4a, 0x83, 0x31, 0xd3, 0x1e, 0x8b, 0x36, 0x2a, 0x9f,
0xb7, 0xb7, 0x12, 0xd9, 0x0f, 0xc6, 0xcc, 0xae, 0x8d, 0x17, 0x76, 0xe8, 0x7d, 0x1a, 0x91, 0xf9,
0x22, 0x67, 0x67, 0xc2, 0x59, 0x12, 0x46, 0x1a, 0x12, 0x52, 0xaf, 0x4a, 0xa5, 0xfa, 0x39, 0xf8,
0x34, 0xc5, 0x2e, 0x1f, 0x79, 0x9b, 0x2e, 0x39, 0x23, 0xe4, 0xc2, 0x2e, 0x8e, 0xae, 0x03, 0xd7,
0x29, 0x46, 0xcb, 0x15, 0x04, 0x6d, 0x47, 0x44, 0x68, 0x97, 0x77, 0x44, 0xca, 0xf8, 0x59, 0x12,
0x96, 0x03, 0xec, 0xe0, 0x55, 0x5f, 0xf3, 0x6b, 0xd8, 0x2c, 0x86, 0x19, 0x35, 0xa0, 0xfa, 0x81,
0x5c, 0xcb, 0x4b, 0x2a, 0x5d, 0xa2, 0x27, 0xb0, 0x36, 0xc7, 0x7e, 0x92, 0x5f, 0x53, 0xd9, 0xe6,
0x9b, 0xca, 0x6b, 0xe5, 0xc8, 0x84, 0xc3, 0x07, 0x3e, 0x22, 0x7a, 0x06, 0xb5, 0xa5, 0xae, 0xc9,
0x74, 0x55, 0xf7, 0xb6, 0x5f, 0x8e, 0x7e, 0x57, 0x40, 0x5d, 0x18, 0x53, 0xf4, 0x03, 0x6c, 0x14,
0xa3, 0xad, 0x88, 0xfe, 0x31, 0x1e, 0x1a, 0x6d, 0x23, 0x5f, 0x64, 0x17, 0x52, 0xc1, 0x6f, 0x3a,
0xb0, 0xb5, 0xe4, 0x2a, 0x39, 0xde, 0xeb, 0xc5, 0xe3, 0xa9, 0x9d, 0xa3, 0x7b, 0x63, 0x5d, 0x8b,
0x06, 0x58, 0x28, 0xc1, 0x6f, 0x0a, 0x6c, 0x2d, 0x39, 0xd1, 0x53, 0x58, 0xe7, 0x04, 0x47, 0x2c,
0x90, 0x41, 0xe4, 0x0e, 0x35, 0x61, 0x83, 0x85, 0x84, 0xe3, 0x98, 0x71, 0x59, 0xc9, 0x62, 0x8f,
0xbe, 0x83, 0x9a, 0xcb, 0x09, 0x8e, 0x89, 0xe7, 0xa4, 0x0f, 0x8c, 0xb8, 0xfa, 0xd5, 0x4e, 0x73,
0xe5, 0x92, 0x1c, 0xe6, 0xaf, 0x8f, 0xad, 0x4a, 0x7c, 0x6a, 0x39, 0xfa, 0xa3, 0x02, 0xb5, 0xc5,
0x0e, 0x2d, 0x1d, 0x18, 0xa5, 0x7c, 0x60, 0x86, 0xa0, 0x15, 0xd0, 0x28, 0xc6, 0x3c, 0x76, 0x8a,
0x27, 0x4e, 0x56, 0xe4, 0xbe, 0x34, 0x9e, 0xe6, 0xdc, 0x41, 0x4a, 0x2d, 0xec, 0xe8, 0x12, 0xf6,
0x0b, 0x55, 0xf2, 0x31, 0xa4, 0x9c, 0x2c, 0xc8, 0x3e, 0x7c, 0xba, 0xbd, 0x9c, 0x6c, 0x09, 0xee,
0xad, 0x6e, 0x07, 0x76, 0x5d, 0x36, 0x0b, 0x7d, 0x92, 0x96, 0x2a, 0x9a, 0x62, 0xee, 0x39, 0x2e,
0x4b, 0x82, 0x58, 0x3c, 0x76, 0x6b, 0xf6, 0x4e, 0xe1, 0x1c, 0xa4, 0xbe, 0x5e, 0xea, 0x42, 0x2f,
0xa0, 0x1e, 0x92, 0xc0, 0xa3, 0xc1, 0x24, 0x63, 0x44, 0xda, 0x9a, 0x5e, 0x6d, 0xad, 0xd9, 0x5b,
0xd2, 0x2a, 0xa0, 0xd1, 0xcb, 0x5f, 0x15, 0xa8, 0x2d, 0x3e, 0xab, 0x68, 0x1f, 0x76, 0xcd, 0x9f,
0x7e, 0xec, 0xf6, 0xcf, 0x9d, 0xc1, 0xb0, 0x3b, 0x7c, 0x37, 0x70, 0xfa, 0xe7, 0x97, 0xdd, 0xb3,
0xbe, 0xd9, 0xf8, 0x1f, 0xfa, 0x14, 0xb4, 0x65, 0x97, 0x6d, 0x9d, 0xf6, 0x07, 0x43, 0xcb, 0xb6,
0xcc, 0x86, 0xb2, 0xea, 0x35, 0xad, 0x0b, 0xdb, 0xea, 0x75, 0x87, 0x96, 0xd9, 0xa8, 0xac, 0xca,
0x9a, 0xd6, 0x99, 0x95, 0xba, 0xaa, 0x2f, 0xa7, 0x50, 0xbf, 0x73, 0x67, 0x7f, 0x02, 0x7b, 0x5d,
0xbb, 0xf7, 0x7d, 0xff, 0xb2, 0x7b, 0x56, 0x9a, 0xc5, 0x5d, 0xa7, 0xd9, 0x1f, 0x74, 0x4f, 0xce,
0x44, 0x16, 0x25, 0x54, 0xeb, 0x3c, 0x73, 0x56, 0x4e, 0x26, 0x7f, 0xde, 0x1c, 0x28, 0x7f, 0xdd,
0x1c, 0x28, 0xff, 0xdc, 0x1c, 0x28, 0xb0, 0xe7, 0xb2, 0x59, 0x59, 0xdb, 0x9f, 0xa8, 0x59, 0x41,
0x2e, 0xd2, 0x2f, 0x74, 0xa1, 0xfc, 0x72, 0x3c, 0xa1, 0xf1, 0x34, 0x19, 0x19, 0x2e, 0x9b, 0xb5,
0x17, 0xff, 0x7b, 0x3e, 0xa7, 0x9e, 0xdf, 0x9e, 0xb0, 0xec, 0x2f, 0x49, 0xfe, 0x04, 0x7d, 0x8b,
0x43, 0x3a, 0x3f, 0x1e, 0xad, 0x0b, 0xdb, 0x17, 0xff, 0x06, 0x00, 0x00, 0xff, 0xff, 0xdc, 0xb4,
0xf5, 0x87, 0xa0, 0x09, 0x00, 0x00,
}
func (m *Domain) 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 *Domain) MarshalTo(dAtA []byte) (int, error) {
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *Domain) 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 m.AsyncWorkflowConfig != nil {
{
size, err := m.AsyncWorkflowConfig.MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintDomain(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0x1
i--
dAtA[i] = 0x9a
}
if m.IsolationGroups != nil {
{
size, err := m.IsolationGroups.MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintDomain(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0x1
i--
dAtA[i] = 0x92
}
if m.FailoverInfo != nil {
{
size, err := m.FailoverInfo.MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintDomain(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0x1
i--
dAtA[i] = 0x8a
}
if m.IsGlobalDomain {
i--
if m.IsGlobalDomain {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i--
dAtA[i] = 0x1
i--
dAtA[i] = 0x80
}
if m.FailoverVersion != 0 {
i = encodeVarintDomain(dAtA, i, uint64(m.FailoverVersion))
i--
dAtA[i] = 0x78
}
if len(m.Clusters) > 0 {
for iNdEx := len(m.Clusters) - 1; iNdEx >= 0; iNdEx-- {
{
size, err := m.Clusters[iNdEx].MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintDomain(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0x72
}
}
if len(m.ActiveClusterName) > 0 {
i -= len(m.ActiveClusterName)
copy(dAtA[i:], m.ActiveClusterName)
i = encodeVarintDomain(dAtA, i, uint64(len(m.ActiveClusterName)))
i--
dAtA[i] = 0x6a
}
if len(m.VisibilityArchivalUri) > 0 {
i -= len(m.VisibilityArchivalUri)
copy(dAtA[i:], m.VisibilityArchivalUri)
i = encodeVarintDomain(dAtA, i, uint64(len(m.VisibilityArchivalUri)))
i--
dAtA[i] = 0x62
}
if m.VisibilityArchivalStatus != 0 {
i = encodeVarintDomain(dAtA, i, uint64(m.VisibilityArchivalStatus))
i--
dAtA[i] = 0x58
}
if len(m.HistoryArchivalUri) > 0 {
i -= len(m.HistoryArchivalUri)
copy(dAtA[i:], m.HistoryArchivalUri)
i = encodeVarintDomain(dAtA, i, uint64(len(m.HistoryArchivalUri)))
i--
dAtA[i] = 0x52
}
if m.HistoryArchivalStatus != 0 {
i = encodeVarintDomain(dAtA, i, uint64(m.HistoryArchivalStatus))
i--
dAtA[i] = 0x48
}
if m.BadBinaries != nil {
{
size, err := m.BadBinaries.MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintDomain(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0x42
}
if m.WorkflowExecutionRetentionPeriod != nil {
{
size, err := m.WorkflowExecutionRetentionPeriod.MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintDomain(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0x3a
}
if len(m.Data) > 0 {
for k := range m.Data {
v := m.Data[k]
baseI := i
i -= len(v)
copy(dAtA[i:], v)
i = encodeVarintDomain(dAtA, i, uint64(len(v)))
i--
dAtA[i] = 0x12
i -= len(k)
copy(dAtA[i:], k)
i = encodeVarintDomain(dAtA, i, uint64(len(k)))
i--
dAtA[i] = 0xa
i = encodeVarintDomain(dAtA, i, uint64(baseI-i))
i--
dAtA[i] = 0x32
}
}
if len(m.OwnerEmail) > 0 {
i -= len(m.OwnerEmail)
copy(dAtA[i:], m.OwnerEmail)
i = encodeVarintDomain(dAtA, i, uint64(len(m.OwnerEmail)))
i--
dAtA[i] = 0x2a
}
if len(m.Description) > 0 {
i -= len(m.Description)
copy(dAtA[i:], m.Description)
i = encodeVarintDomain(dAtA, i, uint64(len(m.Description)))
i--
dAtA[i] = 0x22
}
if m.Status != 0 {
i = encodeVarintDomain(dAtA, i, uint64(m.Status))
i--
dAtA[i] = 0x18
}
if len(m.Name) > 0 {
i -= len(m.Name)
copy(dAtA[i:], m.Name)
i = encodeVarintDomain(dAtA, i, uint64(len(m.Name)))
i--
dAtA[i] = 0x12
}
if len(m.Id) > 0 {
i -= len(m.Id)
copy(dAtA[i:], m.Id)
i = encodeVarintDomain(dAtA, i, uint64(len(m.Id)))
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
}
func (m *ClusterReplicationConfiguration) 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 *ClusterReplicationConfiguration) MarshalTo(dAtA []byte) (int, error) {
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *ClusterReplicationConfiguration) 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.ClusterName) > 0 {
i -= len(m.ClusterName)
copy(dAtA[i:], m.ClusterName)
i = encodeVarintDomain(dAtA, i, uint64(len(m.ClusterName)))
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
}
func (m *BadBinaries) 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 *BadBinaries) MarshalTo(dAtA []byte) (int, error) {
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *BadBinaries) 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.Binaries) > 0 {
for k := range m.Binaries {
v := m.Binaries[k]
baseI := i
if v != nil {
{
size, err := v.MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintDomain(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0x12
}
i -= len(k)
copy(dAtA[i:], k)
i = encodeVarintDomain(dAtA, i, uint64(len(k)))
i--
dAtA[i] = 0xa
i = encodeVarintDomain(dAtA, i, uint64(baseI-i))
i--
dAtA[i] = 0xa
}
}
return len(dAtA) - i, nil
}
func (m *BadBinaryInfo) 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 *BadBinaryInfo) MarshalTo(dAtA []byte) (int, error) {
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *BadBinaryInfo) 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 m.CreatedTime != nil {
{
size, err := m.CreatedTime.MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintDomain(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0x1a
}
if len(m.Operator) > 0 {
i -= len(m.Operator)
copy(dAtA[i:], m.Operator)
i = encodeVarintDomain(dAtA, i, uint64(len(m.Operator)))
i--
dAtA[i] = 0x12
}
if len(m.Reason) > 0 {
i -= len(m.Reason)
copy(dAtA[i:], m.Reason)
i = encodeVarintDomain(dAtA, i, uint64(len(m.Reason)))
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
}
func (m *FailoverInfo) 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 *FailoverInfo) MarshalTo(dAtA []byte) (int, error) {
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *FailoverInfo) 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.PendingShards) > 0 {
dAtA9 := make([]byte, len(m.PendingShards)*10)
var j8 int
for _, num1 := range m.PendingShards {
num := uint64(num1)
for num >= 1<<7 {
dAtA9[j8] = uint8(uint64(num)&0x7f | 0x80)
num >>= 7
j8++
}
dAtA9[j8] = uint8(num)
j8++
}
i -= j8
copy(dAtA[i:], dAtA9[:j8])
i = encodeVarintDomain(dAtA, i, uint64(j8))
i--
dAtA[i] = 0x2a
}
if m.CompletedShardCount != 0 {
i = encodeVarintDomain(dAtA, i, uint64(m.CompletedShardCount))
i--
dAtA[i] = 0x20
}
if m.FailoverExpireTimestamp != nil {
{
size, err := m.FailoverExpireTimestamp.MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintDomain(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0x1a
}
if m.FailoverStartTimestamp != nil {
{
size, err := m.FailoverStartTimestamp.MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintDomain(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0x12
}
if m.FailoverVersion != 0 {
i = encodeVarintDomain(dAtA, i, uint64(m.FailoverVersion))
i--
dAtA[i] = 0x8
}
return len(dAtA) - i, nil
}
func encodeVarintDomain(dAtA []byte, offset int, v uint64) int {
offset -= sovDomain(v)
base := offset
for v >= 1<<7 {
dAtA[offset] = uint8(v&0x7f | 0x80)
v >>= 7
offset++
}
dAtA[offset] = uint8(v)
return base
}
func (m *Domain) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
l = len(m.Id)
if l > 0 {
n += 1 + l + sovDomain(uint64(l))
}
l = len(m.Name)
if l > 0 {
n += 1 + l + sovDomain(uint64(l))
}
if m.Status != 0 {
n += 1 + sovDomain(uint64(m.Status))
}
l = len(m.Description)
if l > 0 {
n += 1 + l + sovDomain(uint64(l))
}
l = len(m.OwnerEmail)
if l > 0 {
n += 1 + l + sovDomain(uint64(l))
}
if len(m.Data) > 0 {
for k, v := range m.Data {
_ = k
_ = v
mapEntrySize := 1 + len(k) + sovDomain(uint64(len(k))) + 1 + len(v) + sovDomain(uint64(len(v)))
n += mapEntrySize + 1 + sovDomain(uint64(mapEntrySize))
}
}
if m.WorkflowExecutionRetentionPeriod != nil {
l = m.WorkflowExecutionRetentionPeriod.Size()
n += 1 + l + sovDomain(uint64(l))
}
if m.BadBinaries != nil {
l = m.BadBinaries.Size()
n += 1 + l + sovDomain(uint64(l))
}
if m.HistoryArchivalStatus != 0 {
n += 1 + sovDomain(uint64(m.HistoryArchivalStatus))
}
l = len(m.HistoryArchivalUri)
if l > 0 {
n += 1 + l + sovDomain(uint64(l))
}
if m.VisibilityArchivalStatus != 0 {
n += 1 + sovDomain(uint64(m.VisibilityArchivalStatus))
}
l = len(m.VisibilityArchivalUri)
if l > 0 {
n += 1 + l + sovDomain(uint64(l))
}
l = len(m.ActiveClusterName)
if l > 0 {
n += 1 + l + sovDomain(uint64(l))
}
if len(m.Clusters) > 0 {
for _, e := range m.Clusters {
l = e.Size()
n += 1 + l + sovDomain(uint64(l))
}
}
if m.FailoverVersion != 0 {
n += 1 + sovDomain(uint64(m.FailoverVersion))
}
if m.IsGlobalDomain {
n += 3
}
if m.FailoverInfo != nil {
l = m.FailoverInfo.Size()
n += 2 + l + sovDomain(uint64(l))
}
if m.IsolationGroups != nil {
l = m.IsolationGroups.Size()
n += 2 + l + sovDomain(uint64(l))
}
if m.AsyncWorkflowConfig != nil {
l = m.AsyncWorkflowConfig.Size()
n += 2 + l + sovDomain(uint64(l))
}
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *ClusterReplicationConfiguration) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
l = len(m.ClusterName)
if l > 0 {
n += 1 + l + sovDomain(uint64(l))
}
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *BadBinaries) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if len(m.Binaries) > 0 {
for k, v := range m.Binaries {
_ = k
_ = v
l = 0
if v != nil {
l = v.Size()
l += 1 + sovDomain(uint64(l))
}
mapEntrySize := 1 + len(k) + sovDomain(uint64(len(k))) + l
n += mapEntrySize + 1 + sovDomain(uint64(mapEntrySize))
}
}
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *BadBinaryInfo) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
l = len(m.Reason)
if l > 0 {
n += 1 + l + sovDomain(uint64(l))
}
l = len(m.Operator)
if l > 0 {
n += 1 + l + sovDomain(uint64(l))
}
if m.CreatedTime != nil {
l = m.CreatedTime.Size()
n += 1 + l + sovDomain(uint64(l))
}
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *FailoverInfo) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if m.FailoverVersion != 0 {
n += 1 + sovDomain(uint64(m.FailoverVersion))
}
if m.FailoverStartTimestamp != nil {
l = m.FailoverStartTimestamp.Size()
n += 1 + l + sovDomain(uint64(l))
}
if m.FailoverExpireTimestamp != nil {
l = m.FailoverExpireTimestamp.Size()
n += 1 + l + sovDomain(uint64(l))
}
if m.CompletedShardCount != 0 {
n += 1 + sovDomain(uint64(m.CompletedShardCount))
}
if len(m.PendingShards) > 0 {
l = 0
for _, e := range m.PendingShards {
l += sovDomain(uint64(e))
}
n += 1 + sovDomain(uint64(l)) + l
}
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func sovDomain(x uint64) (n int) {
return (math_bits.Len64(x|1) + 6) / 7
}
func sozDomain(x uint64) (n int) {
return sovDomain(uint64((x << 1) ^ uint64((int64(x) >> 63))))
}
func (m *Domain) 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 ErrIntOverflowDomain
}
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: Domain: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: Domain: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Id", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
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 ErrInvalidLengthDomain
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthDomain
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Id = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Name", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
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 ErrInvalidLengthDomain
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthDomain
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Name = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 3:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Status", wireType)
}
m.Status = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Status |= DomainStatus(b&0x7F) << shift
if b < 0x80 {
break
}
}
case 4:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Description", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
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 ErrInvalidLengthDomain
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthDomain
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Description = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 5:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field OwnerEmail", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
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 ErrInvalidLengthDomain
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthDomain
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.OwnerEmail = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 6:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Data", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthDomain
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthDomain
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Data == nil {
m.Data = make(map[string]string)
}
var mapkey string
var mapvalue string
for iNdEx < postIndex {
entryPreIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
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 ErrIntOverflowDomain
}
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 ErrInvalidLengthDomain
}
postStringIndexmapkey := iNdEx + intStringLenmapkey
if postStringIndexmapkey < 0 {
return ErrInvalidLengthDomain
}
if postStringIndexmapkey > l {
return io.ErrUnexpectedEOF
}
mapkey = string(dAtA[iNdEx:postStringIndexmapkey])
iNdEx = postStringIndexmapkey
} else if fieldNum == 2 {
var stringLenmapvalue uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLenmapvalue |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
intStringLenmapvalue := int(stringLenmapvalue)
if intStringLenmapvalue < 0 {
return ErrInvalidLengthDomain
}
postStringIndexmapvalue := iNdEx + intStringLenmapvalue
if postStringIndexmapvalue < 0 {
return ErrInvalidLengthDomain
}
if postStringIndexmapvalue > l {
return io.ErrUnexpectedEOF
}
mapvalue = string(dAtA[iNdEx:postStringIndexmapvalue])
iNdEx = postStringIndexmapvalue
} else {
iNdEx = entryPreIndex
skippy, err := skipDomain(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthDomain
}
if (iNdEx + skippy) > postIndex {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
m.Data[mapkey] = mapvalue
iNdEx = postIndex
case 7:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field WorkflowExecutionRetentionPeriod", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthDomain
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthDomain
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.WorkflowExecutionRetentionPeriod == nil {
m.WorkflowExecutionRetentionPeriod = &types.Duration{}
}
if err := m.WorkflowExecutionRetentionPeriod.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 8:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field BadBinaries", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthDomain
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthDomain
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.BadBinaries == nil {
m.BadBinaries = &BadBinaries{}
}
if err := m.BadBinaries.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 9:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field HistoryArchivalStatus", wireType)
}
m.HistoryArchivalStatus = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.HistoryArchivalStatus |= ArchivalStatus(b&0x7F) << shift
if b < 0x80 {
break
}
}
case 10:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field HistoryArchivalUri", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
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 ErrInvalidLengthDomain
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthDomain
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.HistoryArchivalUri = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 11:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field VisibilityArchivalStatus", wireType)
}
m.VisibilityArchivalStatus = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.VisibilityArchivalStatus |= ArchivalStatus(b&0x7F) << shift
if b < 0x80 {
break
}
}
case 12:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field VisibilityArchivalUri", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
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 ErrInvalidLengthDomain
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthDomain
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.VisibilityArchivalUri = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 13:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ActiveClusterName", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
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 ErrInvalidLengthDomain
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthDomain
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.ActiveClusterName = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 14:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Clusters", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthDomain
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthDomain
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Clusters = append(m.Clusters, &ClusterReplicationConfiguration{})
if err := m.Clusters[len(m.Clusters)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 15:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field FailoverVersion", wireType)
}
m.FailoverVersion = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.FailoverVersion |= int64(b&0x7F) << shift
if b < 0x80 {
break
}
}
case 16:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field IsGlobalDomain", wireType)
}
var v int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
v |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
m.IsGlobalDomain = bool(v != 0)
case 17:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field FailoverInfo", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthDomain
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthDomain
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.FailoverInfo == nil {
m.FailoverInfo = &FailoverInfo{}
}
if err := m.FailoverInfo.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 18:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field IsolationGroups", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthDomain
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthDomain
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.IsolationGroups == nil {
m.IsolationGroups = &IsolationGroupConfiguration{}
}
if err := m.IsolationGroups.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 19:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field AsyncWorkflowConfig", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthDomain
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthDomain
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.AsyncWorkflowConfig == nil {
m.AsyncWorkflowConfig = &AsyncWorkflowConfiguration{}
}
if err := m.AsyncWorkflowConfig.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipDomain(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthDomain
}
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 *ClusterReplicationConfiguration) 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 ErrIntOverflowDomain
}
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: ClusterReplicationConfiguration: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: ClusterReplicationConfiguration: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ClusterName", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
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 ErrInvalidLengthDomain
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthDomain
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.ClusterName = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipDomain(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthDomain
}
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 *BadBinaries) 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 ErrIntOverflowDomain
}
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: BadBinaries: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: BadBinaries: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Binaries", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthDomain
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthDomain
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Binaries == nil {
m.Binaries = make(map[string]*BadBinaryInfo)
}
var mapkey string
var mapvalue *BadBinaryInfo
for iNdEx < postIndex {
entryPreIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
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 ErrIntOverflowDomain
}
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 ErrInvalidLengthDomain
}
postStringIndexmapkey := iNdEx + intStringLenmapkey
if postStringIndexmapkey < 0 {
return ErrInvalidLengthDomain
}
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 ErrIntOverflowDomain
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
mapmsglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if mapmsglen < 0 {
return ErrInvalidLengthDomain
}
postmsgIndex := iNdEx + mapmsglen
if postmsgIndex < 0 {
return ErrInvalidLengthDomain
}
if postmsgIndex > l {
return io.ErrUnexpectedEOF
}
mapvalue = &BadBinaryInfo{}
if err := mapvalue.Unmarshal(dAtA[iNdEx:postmsgIndex]); err != nil {
return err
}
iNdEx = postmsgIndex
} else {
iNdEx = entryPreIndex
skippy, err := skipDomain(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthDomain
}
if (iNdEx + skippy) > postIndex {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
m.Binaries[mapkey] = mapvalue
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipDomain(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthDomain
}
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 *BadBinaryInfo) 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 ErrIntOverflowDomain
}
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: BadBinaryInfo: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: BadBinaryInfo: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Reason", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
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 ErrInvalidLengthDomain
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthDomain
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Reason = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Operator", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
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 ErrInvalidLengthDomain
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthDomain
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Operator = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 3:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field CreatedTime", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthDomain
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthDomain
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.CreatedTime == nil {
m.CreatedTime = &types.Timestamp{}
}
if err := m.CreatedTime.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipDomain(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthDomain
}
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 *FailoverInfo) 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 ErrIntOverflowDomain
}
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: FailoverInfo: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: FailoverInfo: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field FailoverVersion", wireType)
}
m.FailoverVersion = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.FailoverVersion |= int64(b&0x7F) << shift
if b < 0x80 {
break
}
}
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field FailoverStartTimestamp", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthDomain
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthDomain
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.FailoverStartTimestamp == nil {
m.FailoverStartTimestamp = &types.Timestamp{}
}
if err := m.FailoverStartTimestamp.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 3:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field FailoverExpireTimestamp", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthDomain
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthDomain
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.FailoverExpireTimestamp == nil {
m.FailoverExpireTimestamp = &types.Timestamp{}
}
if err := m.FailoverExpireTimestamp.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 4:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field CompletedShardCount", wireType)
}
m.CompletedShardCount = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.CompletedShardCount |= int32(b&0x7F) << shift
if b < 0x80 {
break
}
}
case 5:
if wireType == 0 {
var v int32
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
v |= int32(b&0x7F) << shift
if b < 0x80 {
break
}
}
m.PendingShards = append(m.PendingShards, v)
} else if wireType == 2 {
var packedLen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
packedLen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if packedLen < 0 {
return ErrInvalidLengthDomain
}
postIndex := iNdEx + packedLen
if postIndex < 0 {
return ErrInvalidLengthDomain
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
var elementCount int
var count int
for _, integer := range dAtA[iNdEx:postIndex] {
if integer < 128 {
count++
}
}
elementCount = count
if elementCount != 0 && len(m.PendingShards) == 0 {
m.PendingShards = make([]int32, 0, elementCount)
}
for iNdEx < postIndex {
var v int32
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDomain
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
v |= int32(b&0x7F) << shift
if b < 0x80 {
break
}
}
m.PendingShards = append(m.PendingShards, v)
}
} else {
return fmt.Errorf("proto: wrong wireType = %d for field PendingShards", wireType)
}
default:
iNdEx = preIndex
skippy, err := skipDomain(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthDomain
}
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 skipDomain(dAtA []byte) (n int, err error) {
l := len(dAtA)
iNdEx := 0
depth := 0
for iNdEx < l {
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowDomain
}
if iNdEx >= l {
return 0, io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
wireType := int(wire & 0x7)
switch wireType {
case 0:
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowDomain
}
if iNdEx >= l {
return 0, io.ErrUnexpectedEOF
}
iNdEx++
if dAtA[iNdEx-1] < 0x80 {
break
}
}
case 1:
iNdEx += 8
case 2:
var length int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowDomain
}
if iNdEx >= l {
return 0, io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
length |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if length < 0 {
return 0, ErrInvalidLengthDomain
}
iNdEx += length
case 3:
depth++
case 4:
if depth == 0 {
return 0, ErrUnexpectedEndOfGroupDomain
}
depth--
case 5:
iNdEx += 4
default:
return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
}
if iNdEx < 0 {
return 0, ErrInvalidLengthDomain
}
if depth == 0 {
return iNdEx, nil
}
}
return 0, io.ErrUnexpectedEOF
}
var (
ErrInvalidLengthDomain = fmt.Errorf("proto: negative length found during unmarshaling")
ErrIntOverflowDomain = fmt.Errorf("proto: integer overflow")
ErrUnexpectedEndOfGroupDomain = fmt.Errorf("proto: unexpected end of group")
)