Mercurial > lbo > hg > clusterconsensus
view example_clusterrpc/proto/consensus.pb.go @ 47:71b6822763da default tip
Fix more race conditions in Accept logic
author | Lewin Bormann <lbo@spheniscida.de> |
---|---|
date | Fri, 26 Jul 2019 12:10:39 +0200 |
parents | 7a6db8262f43 |
children |
line wrap: on
line source
// Code generated by protoc-gen-gogo. DO NOT EDIT. // source: consensus.proto package proto import ( fmt "fmt" github_com_gogo_protobuf_proto "github.com/gogo/protobuf/proto" proto "github.com/gogo/protobuf/proto" 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.GoGoProtoPackageIsVersion2 // please upgrade the proto package type Error struct { Error *string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"` Type *string `protobuf:"bytes,2,opt,name=type" json:"type,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *Error) Reset() { *m = Error{} } func (m *Error) String() string { return proto.CompactTextString(m) } func (*Error) ProtoMessage() {} func (*Error) Descriptor() ([]byte, []int) { return fileDescriptor_56f0f2c53b3de771, []int{0} } func (m *Error) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_Error.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *Error) XXX_Merge(src proto.Message) { xxx_messageInfo_Error.Merge(m, src) } func (m *Error) XXX_Size() int { return m.Size() } func (m *Error) XXX_DiscardUnknown() { xxx_messageInfo_Error.DiscardUnknown(m) } var xxx_messageInfo_Error proto.InternalMessageInfo func (m *Error) GetError() string { if m != nil && m.Error != nil { return *m.Error } return "" } func (m *Error) GetType() string { if m != nil && m.Type != nil { return *m.Type } return "" } type Change struct { Change []byte `protobuf:"bytes,1,opt,name=change" json:"change,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *Change) Reset() { *m = Change{} } func (m *Change) String() string { return proto.CompactTextString(m) } func (*Change) ProtoMessage() {} func (*Change) Descriptor() ([]byte, []int) { return fileDescriptor_56f0f2c53b3de771, []int{1} } func (m *Change) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *Change) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_Change.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *Change) XXX_Merge(src proto.Message) { xxx_messageInfo_Change.Merge(m, src) } func (m *Change) XXX_Size() int { return m.Size() } func (m *Change) XXX_DiscardUnknown() { xxx_messageInfo_Change.DiscardUnknown(m) } var xxx_messageInfo_Change proto.InternalMessageInfo func (m *Change) GetChange() []byte { if m != nil { return m.Change } return nil } type Member struct { Address *string `protobuf:"bytes,1,opt,name=address" json:"address,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *Member) Reset() { *m = Member{} } func (m *Member) String() string { return proto.CompactTextString(m) } func (*Member) ProtoMessage() {} func (*Member) Descriptor() ([]byte, []int) { return fileDescriptor_56f0f2c53b3de771, []int{2} } func (m *Member) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *Member) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_Member.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *Member) XXX_Merge(src proto.Message) { xxx_messageInfo_Member.Merge(m, src) } func (m *Member) XXX_Size() int { return m.Size() } func (m *Member) XXX_DiscardUnknown() { xxx_messageInfo_Member.DiscardUnknown(m) } var xxx_messageInfo_Member proto.InternalMessageInfo func (m *Member) GetAddress() string { if m != nil && m.Address != nil { return *m.Address } return "" } type Version struct { Instance *uint64 `protobuf:"varint,1,req,name=instance" json:"instance,omitempty"` Sequence *uint64 `protobuf:"varint,2,req,name=sequence" json:"sequence,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *Version) Reset() { *m = Version{} } func (m *Version) String() string { return proto.CompactTextString(m) } func (*Version) ProtoMessage() {} func (*Version) Descriptor() ([]byte, []int) { return fileDescriptor_56f0f2c53b3de771, []int{3} } func (m *Version) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *Version) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_Version.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *Version) XXX_Merge(src proto.Message) { xxx_messageInfo_Version.Merge(m, src) } func (m *Version) XXX_Size() int { return m.Size() } func (m *Version) XXX_DiscardUnknown() { xxx_messageInfo_Version.DiscardUnknown(m) } var xxx_messageInfo_Version proto.InternalMessageInfo func (m *Version) GetInstance() uint64 { if m != nil && m.Instance != nil { return *m.Instance } return 0 } func (m *Version) GetSequence() uint64 { if m != nil && m.Sequence != nil { return *m.Sequence } return 0 } type GenericResponse struct { Accepted *bool `protobuf:"varint,1,req,name=accepted" json:"accepted,omitempty"` Error *Error `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"` Instance *uint64 `protobuf:"varint,3,opt,name=instance" json:"instance,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *GenericResponse) Reset() { *m = GenericResponse{} } func (m *GenericResponse) String() string { return proto.CompactTextString(m) } func (*GenericResponse) ProtoMessage() {} func (*GenericResponse) Descriptor() ([]byte, []int) { return fileDescriptor_56f0f2c53b3de771, []int{4} } func (m *GenericResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *GenericResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_GenericResponse.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *GenericResponse) XXX_Merge(src proto.Message) { xxx_messageInfo_GenericResponse.Merge(m, src) } func (m *GenericResponse) XXX_Size() int { return m.Size() } func (m *GenericResponse) XXX_DiscardUnknown() { xxx_messageInfo_GenericResponse.DiscardUnknown(m) } var xxx_messageInfo_GenericResponse proto.InternalMessageInfo func (m *GenericResponse) GetAccepted() bool { if m != nil && m.Accepted != nil { return *m.Accepted } return false } func (m *GenericResponse) GetError() *Error { if m != nil { return m.Error } return nil } func (m *GenericResponse) GetInstance() uint64 { if m != nil && m.Instance != nil { return *m.Instance } return 0 } type PrepareRequest struct { Instance *uint64 `protobuf:"varint,1,req,name=instance" json:"instance,omitempty"` Master *Member `protobuf:"bytes,2,req,name=master" json:"master,omitempty"` Cluster *string `protobuf:"bytes,3,req,name=cluster" json:"cluster,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *PrepareRequest) Reset() { *m = PrepareRequest{} } func (m *PrepareRequest) String() string { return proto.CompactTextString(m) } func (*PrepareRequest) ProtoMessage() {} func (*PrepareRequest) Descriptor() ([]byte, []int) { return fileDescriptor_56f0f2c53b3de771, []int{5} } func (m *PrepareRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *PrepareRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_PrepareRequest.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *PrepareRequest) XXX_Merge(src proto.Message) { xxx_messageInfo_PrepareRequest.Merge(m, src) } func (m *PrepareRequest) XXX_Size() int { return m.Size() } func (m *PrepareRequest) XXX_DiscardUnknown() { xxx_messageInfo_PrepareRequest.DiscardUnknown(m) } var xxx_messageInfo_PrepareRequest proto.InternalMessageInfo func (m *PrepareRequest) GetInstance() uint64 { if m != nil && m.Instance != nil { return *m.Instance } return 0 } func (m *PrepareRequest) GetMaster() *Member { if m != nil { return m.Master } return nil } func (m *PrepareRequest) GetCluster() string { if m != nil && m.Cluster != nil { return *m.Cluster } return "" } type PrepareResponse struct { Instance *uint64 `protobuf:"varint,1,req,name=instance" json:"instance,omitempty"` Error *Error `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *PrepareResponse) Reset() { *m = PrepareResponse{} } func (m *PrepareResponse) String() string { return proto.CompactTextString(m) } func (*PrepareResponse) ProtoMessage() {} func (*PrepareResponse) Descriptor() ([]byte, []int) { return fileDescriptor_56f0f2c53b3de771, []int{6} } func (m *PrepareResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *PrepareResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_PrepareResponse.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *PrepareResponse) XXX_Merge(src proto.Message) { xxx_messageInfo_PrepareResponse.Merge(m, src) } func (m *PrepareResponse) XXX_Size() int { return m.Size() } func (m *PrepareResponse) XXX_DiscardUnknown() { xxx_messageInfo_PrepareResponse.DiscardUnknown(m) } var xxx_messageInfo_PrepareResponse proto.InternalMessageInfo func (m *PrepareResponse) GetInstance() uint64 { if m != nil && m.Instance != nil { return *m.Instance } return 0 } func (m *PrepareResponse) GetError() *Error { if m != nil { return m.Error } return nil } type AcceptRequest struct { Version *Version `protobuf:"bytes,1,req,name=version" json:"version,omitempty"` Changes []*Change `protobuf:"bytes,2,rep,name=changes" json:"changes,omitempty"` Cluster *string `protobuf:"bytes,3,req,name=cluster" json:"cluster,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *AcceptRequest) Reset() { *m = AcceptRequest{} } func (m *AcceptRequest) String() string { return proto.CompactTextString(m) } func (*AcceptRequest) ProtoMessage() {} func (*AcceptRequest) Descriptor() ([]byte, []int) { return fileDescriptor_56f0f2c53b3de771, []int{7} } func (m *AcceptRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *AcceptRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_AcceptRequest.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *AcceptRequest) XXX_Merge(src proto.Message) { xxx_messageInfo_AcceptRequest.Merge(m, src) } func (m *AcceptRequest) XXX_Size() int { return m.Size() } func (m *AcceptRequest) XXX_DiscardUnknown() { xxx_messageInfo_AcceptRequest.DiscardUnknown(m) } var xxx_messageInfo_AcceptRequest proto.InternalMessageInfo func (m *AcceptRequest) GetVersion() *Version { if m != nil { return m.Version } return nil } func (m *AcceptRequest) GetChanges() []*Change { if m != nil { return m.Changes } return nil } func (m *AcceptRequest) GetCluster() string { if m != nil && m.Cluster != nil { return *m.Cluster } return "" } type AddMemberRequest struct { Version *Version `protobuf:"bytes,1,req,name=version" json:"version,omitempty"` Member *Member `protobuf:"bytes,2,req,name=member" json:"member,omitempty"` Cluster *string `protobuf:"bytes,3,req,name=cluster" json:"cluster,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *AddMemberRequest) Reset() { *m = AddMemberRequest{} } func (m *AddMemberRequest) String() string { return proto.CompactTextString(m) } func (*AddMemberRequest) ProtoMessage() {} func (*AddMemberRequest) Descriptor() ([]byte, []int) { return fileDescriptor_56f0f2c53b3de771, []int{8} } func (m *AddMemberRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *AddMemberRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_AddMemberRequest.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *AddMemberRequest) XXX_Merge(src proto.Message) { xxx_messageInfo_AddMemberRequest.Merge(m, src) } func (m *AddMemberRequest) XXX_Size() int { return m.Size() } func (m *AddMemberRequest) XXX_DiscardUnknown() { xxx_messageInfo_AddMemberRequest.DiscardUnknown(m) } var xxx_messageInfo_AddMemberRequest proto.InternalMessageInfo func (m *AddMemberRequest) GetVersion() *Version { if m != nil { return m.Version } return nil } func (m *AddMemberRequest) GetMember() *Member { if m != nil { return m.Member } return nil } func (m *AddMemberRequest) GetCluster() string { if m != nil && m.Cluster != nil { return *m.Cluster } return "" } type RemoveMemberRequest struct { Version *Version `protobuf:"bytes,1,req,name=version" json:"version,omitempty"` Member *Member `protobuf:"bytes,2,req,name=member" json:"member,omitempty"` Cluster *string `protobuf:"bytes,3,req,name=cluster" json:"cluster,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *RemoveMemberRequest) Reset() { *m = RemoveMemberRequest{} } func (m *RemoveMemberRequest) String() string { return proto.CompactTextString(m) } func (*RemoveMemberRequest) ProtoMessage() {} func (*RemoveMemberRequest) Descriptor() ([]byte, []int) { return fileDescriptor_56f0f2c53b3de771, []int{9} } func (m *RemoveMemberRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *RemoveMemberRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_RemoveMemberRequest.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *RemoveMemberRequest) XXX_Merge(src proto.Message) { xxx_messageInfo_RemoveMemberRequest.Merge(m, src) } func (m *RemoveMemberRequest) XXX_Size() int { return m.Size() } func (m *RemoveMemberRequest) XXX_DiscardUnknown() { xxx_messageInfo_RemoveMemberRequest.DiscardUnknown(m) } var xxx_messageInfo_RemoveMemberRequest proto.InternalMessageInfo func (m *RemoveMemberRequest) GetVersion() *Version { if m != nil { return m.Version } return nil } func (m *RemoveMemberRequest) GetMember() *Member { if m != nil { return m.Member } return nil } func (m *RemoveMemberRequest) GetCluster() string { if m != nil && m.Cluster != nil { return *m.Cluster } return "" } type StartParticipation struct { Version *Version `protobuf:"bytes,1,req,name=version" json:"version,omitempty"` Cluster *string `protobuf:"bytes,2,req,name=cluster" json:"cluster,omitempty"` Self *Member `protobuf:"bytes,3,req,name=self" json:"self,omitempty"` Master *Member `protobuf:"bytes,4,req,name=master" json:"master,omitempty"` Members []*Member `protobuf:"bytes,5,rep,name=members" json:"members,omitempty"` Snapshot []byte `protobuf:"bytes,6,req,name=snapshot" json:"snapshot,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *StartParticipation) Reset() { *m = StartParticipation{} } func (m *StartParticipation) String() string { return proto.CompactTextString(m) } func (*StartParticipation) ProtoMessage() {} func (*StartParticipation) Descriptor() ([]byte, []int) { return fileDescriptor_56f0f2c53b3de771, []int{10} } func (m *StartParticipation) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *StartParticipation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_StartParticipation.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *StartParticipation) XXX_Merge(src proto.Message) { xxx_messageInfo_StartParticipation.Merge(m, src) } func (m *StartParticipation) XXX_Size() int { return m.Size() } func (m *StartParticipation) XXX_DiscardUnknown() { xxx_messageInfo_StartParticipation.DiscardUnknown(m) } var xxx_messageInfo_StartParticipation proto.InternalMessageInfo func (m *StartParticipation) GetVersion() *Version { if m != nil { return m.Version } return nil } func (m *StartParticipation) GetCluster() string { if m != nil && m.Cluster != nil { return *m.Cluster } return "" } func (m *StartParticipation) GetSelf() *Member { if m != nil { return m.Self } return nil } func (m *StartParticipation) GetMaster() *Member { if m != nil { return m.Master } return nil } func (m *StartParticipation) GetMembers() []*Member { if m != nil { return m.Members } return nil } func (m *StartParticipation) GetSnapshot() []byte { if m != nil { return m.Snapshot } return nil } type SubmitRequest struct { Changes []*Change `protobuf:"bytes,1,rep,name=changes" json:"changes,omitempty"` Cluster *string `protobuf:"bytes,2,req,name=cluster" json:"cluster,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *SubmitRequest) Reset() { *m = SubmitRequest{} } func (m *SubmitRequest) String() string { return proto.CompactTextString(m) } func (*SubmitRequest) ProtoMessage() {} func (*SubmitRequest) Descriptor() ([]byte, []int) { return fileDescriptor_56f0f2c53b3de771, []int{11} } func (m *SubmitRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *SubmitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_SubmitRequest.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *SubmitRequest) XXX_Merge(src proto.Message) { xxx_messageInfo_SubmitRequest.Merge(m, src) } func (m *SubmitRequest) XXX_Size() int { return m.Size() } func (m *SubmitRequest) XXX_DiscardUnknown() { xxx_messageInfo_SubmitRequest.DiscardUnknown(m) } var xxx_messageInfo_SubmitRequest proto.InternalMessageInfo func (m *SubmitRequest) GetChanges() []*Change { if m != nil { return m.Changes } return nil } func (m *SubmitRequest) GetCluster() string { if m != nil && m.Cluster != nil { return *m.Cluster } return "" } func init() { proto.RegisterType((*Error)(nil), "proto.Error") proto.RegisterType((*Change)(nil), "proto.Change") proto.RegisterType((*Member)(nil), "proto.Member") proto.RegisterType((*Version)(nil), "proto.Version") proto.RegisterType((*GenericResponse)(nil), "proto.GenericResponse") proto.RegisterType((*PrepareRequest)(nil), "proto.PrepareRequest") proto.RegisterType((*PrepareResponse)(nil), "proto.PrepareResponse") proto.RegisterType((*AcceptRequest)(nil), "proto.AcceptRequest") proto.RegisterType((*AddMemberRequest)(nil), "proto.AddMemberRequest") proto.RegisterType((*RemoveMemberRequest)(nil), "proto.RemoveMemberRequest") proto.RegisterType((*StartParticipation)(nil), "proto.StartParticipation") proto.RegisterType((*SubmitRequest)(nil), "proto.SubmitRequest") } func init() { proto.RegisterFile("consensus.proto", fileDescriptor_56f0f2c53b3de771) } var fileDescriptor_56f0f2c53b3de771 = []byte{ // 466 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xc4, 0x53, 0x5d, 0x8b, 0xd3, 0x40, 0x14, 0x65, 0xd2, 0x36, 0x59, 0x6f, 0xdb, 0xad, 0x8c, 0x22, 0xc1, 0x87, 0x12, 0x07, 0x64, 0xfb, 0xb4, 0x60, 0xff, 0x41, 0x15, 0xf1, 0x49, 0x58, 0x67, 0xc1, 0xf7, 0xd9, 0xe4, 0xea, 0x06, 0x36, 0x93, 0x38, 0x33, 0x5d, 0x10, 0x14, 0xfc, 0x79, 0x3e, 0xfa, 0x13, 0xa4, 0x2f, 0xfe, 0x0d, 0x99, 0xaf, 0x98, 0x22, 0x2d, 0xf5, 0xc9, 0xa7, 0xce, 0xe9, 0x99, 0xb9, 0xf7, 0x9c, 0x7b, 0x4f, 0x60, 0x51, 0xb6, 0x52, 0xa3, 0xd4, 0x5b, 0x7d, 0xd9, 0xa9, 0xd6, 0xb4, 0x74, 0xe2, 0x7e, 0xd8, 0x0b, 0x98, 0xbc, 0x56, 0xaa, 0x55, 0xf4, 0x31, 0x4c, 0xd0, 0x1e, 0x72, 0x52, 0x90, 0xd5, 0x03, 0xee, 0x01, 0xa5, 0x30, 0x36, 0x9f, 0x3b, 0xcc, 0x13, 0xf7, 0xa7, 0x3b, 0xb3, 0x02, 0xd2, 0x57, 0xb7, 0x42, 0x7e, 0x44, 0xfa, 0x04, 0xd2, 0xd2, 0x9d, 0xdc, 0xa3, 0x19, 0x0f, 0x88, 0x31, 0x48, 0xdf, 0x62, 0x73, 0x83, 0x8a, 0xe6, 0x90, 0x89, 0xaa, 0x52, 0xa8, 0x75, 0xa8, 0x1b, 0x21, 0xdb, 0x40, 0xf6, 0x1e, 0x95, 0xae, 0x5b, 0x49, 0x9f, 0xc2, 0x59, 0x2d, 0xb5, 0x11, 0xb2, 0xb4, 0x85, 0x92, 0xd5, 0x98, 0xf7, 0xd8, 0x72, 0x1a, 0x3f, 0x6d, 0xd1, 0x72, 0x89, 0xe7, 0x22, 0x66, 0x0d, 0x2c, 0xde, 0xa0, 0x44, 0x55, 0x97, 0x1c, 0x75, 0x67, 0xfd, 0xd9, 0xeb, 0xa2, 0x2c, 0xb1, 0x33, 0x58, 0xb9, 0x52, 0x67, 0xbc, 0xc7, 0x94, 0x45, 0x87, 0xd6, 0xcc, 0x74, 0x3d, 0xf3, 0x83, 0xb8, 0x74, 0xf6, 0xa3, 0xdf, 0xa1, 0x94, 0x51, 0x41, 0x86, 0x52, 0x58, 0x03, 0xe7, 0x57, 0x0a, 0x3b, 0xa1, 0x90, 0x5b, 0x05, 0xda, 0x1c, 0x15, 0xfe, 0x1c, 0xd2, 0x46, 0x68, 0x83, 0xca, 0xc9, 0x9e, 0xae, 0xe7, 0xa1, 0x9d, 0x1f, 0x0c, 0x0f, 0xa4, 0x1d, 0x50, 0x79, 0xb7, 0x75, 0xf7, 0x46, 0x45, 0x62, 0x07, 0x14, 0x20, 0x7b, 0x07, 0x8b, 0xbe, 0xdd, 0x1f, 0x77, 0x07, 0xfb, 0x9d, 0xe0, 0x8e, 0x7d, 0x81, 0xf9, 0xc6, 0x4d, 0x23, 0x1a, 0x58, 0x41, 0x76, 0xef, 0x97, 0xe0, 0xea, 0x4d, 0xd7, 0xe7, 0xe1, 0x59, 0x58, 0x0d, 0x8f, 0x34, 0xbd, 0x80, 0xcc, 0x2f, 0x57, 0xe7, 0x49, 0x31, 0x1a, 0xf8, 0xf1, 0x51, 0xe0, 0x91, 0x3d, 0x62, 0xe8, 0x2b, 0x3c, 0xdc, 0x54, 0x55, 0xf0, 0xff, 0xcf, 0x02, 0xec, 0x3c, 0xdd, 0xd3, 0x43, 0xf3, 0xec, 0x03, 0x77, 0xa0, 0xfd, 0x37, 0x02, 0x8f, 0x38, 0x36, 0xed, 0x3d, 0xfe, 0x37, 0x09, 0xbf, 0x08, 0xd0, 0x6b, 0x23, 0x94, 0xb9, 0x12, 0xca, 0xd4, 0x65, 0xdd, 0x09, 0x63, 0xeb, 0x9e, 0xae, 0x60, 0x50, 0x3a, 0xd9, 0x2b, 0x4d, 0x9f, 0xc1, 0x58, 0xe3, 0xdd, 0x07, 0xd7, 0xf1, 0x2f, 0x65, 0x8e, 0x1a, 0x24, 0x72, 0x7c, 0x2c, 0x91, 0x17, 0x90, 0x79, 0x23, 0x3a, 0x9f, 0xec, 0x6d, 0x3a, 0xdc, 0x8b, 0xac, 0xfb, 0x34, 0xa5, 0xe8, 0xf4, 0x6d, 0x6b, 0xf2, 0xb4, 0x48, 0x56, 0x33, 0xde, 0x63, 0xc6, 0x61, 0x7e, 0xbd, 0xbd, 0x69, 0xea, 0x3e, 0x69, 0x83, 0xfc, 0x90, 0x53, 0xf3, 0xb3, 0x6f, 0xf1, 0xe5, 0xec, 0xfb, 0x6e, 0x49, 0x7e, 0xec, 0x96, 0xe4, 0xe7, 0x6e, 0x49, 0x7e, 0x07, 0x00, 0x00, 0xff, 0xff, 0x7a, 0x7f, 0x09, 0x06, 0xd1, 0x04, 0x00, 0x00, } func (m *Error) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *Error) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Error != nil { dAtA[i] = 0xa i++ i = encodeVarintConsensus(dAtA, i, uint64(len(*m.Error))) i += copy(dAtA[i:], *m.Error) } if m.Type != nil { dAtA[i] = 0x12 i++ i = encodeVarintConsensus(dAtA, i, uint64(len(*m.Type))) i += copy(dAtA[i:], *m.Type) } if m.XXX_unrecognized != nil { i += copy(dAtA[i:], m.XXX_unrecognized) } return i, nil } func (m *Change) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *Change) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Change != nil { dAtA[i] = 0xa i++ i = encodeVarintConsensus(dAtA, i, uint64(len(m.Change))) i += copy(dAtA[i:], m.Change) } if m.XXX_unrecognized != nil { i += copy(dAtA[i:], m.XXX_unrecognized) } return i, nil } func (m *Member) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *Member) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Address != nil { dAtA[i] = 0xa i++ i = encodeVarintConsensus(dAtA, i, uint64(len(*m.Address))) i += copy(dAtA[i:], *m.Address) } if m.XXX_unrecognized != nil { i += copy(dAtA[i:], m.XXX_unrecognized) } return i, nil } func (m *Version) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *Version) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Instance == nil { return 0, github_com_gogo_protobuf_proto.NewRequiredNotSetError("instance") } else { dAtA[i] = 0x8 i++ i = encodeVarintConsensus(dAtA, i, uint64(*m.Instance)) } if m.Sequence == nil { return 0, github_com_gogo_protobuf_proto.NewRequiredNotSetError("sequence") } else { dAtA[i] = 0x10 i++ i = encodeVarintConsensus(dAtA, i, uint64(*m.Sequence)) } if m.XXX_unrecognized != nil { i += copy(dAtA[i:], m.XXX_unrecognized) } return i, nil } func (m *GenericResponse) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *GenericResponse) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Accepted == nil { return 0, github_com_gogo_protobuf_proto.NewRequiredNotSetError("accepted") } else { dAtA[i] = 0x8 i++ if *m.Accepted { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if m.Error != nil { dAtA[i] = 0x12 i++ i = encodeVarintConsensus(dAtA, i, uint64(m.Error.Size())) n1, err1 := m.Error.MarshalTo(dAtA[i:]) if err1 != nil { return 0, err1 } i += n1 } if m.Instance != nil { dAtA[i] = 0x18 i++ i = encodeVarintConsensus(dAtA, i, uint64(*m.Instance)) } if m.XXX_unrecognized != nil { i += copy(dAtA[i:], m.XXX_unrecognized) } return i, nil } func (m *PrepareRequest) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *PrepareRequest) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Instance == nil { return 0, github_com_gogo_protobuf_proto.NewRequiredNotSetError("instance") } else { dAtA[i] = 0x8 i++ i = encodeVarintConsensus(dAtA, i, uint64(*m.Instance)) } if m.Master == nil { return 0, github_com_gogo_protobuf_proto.NewRequiredNotSetError("master") } else { dAtA[i] = 0x12 i++ i = encodeVarintConsensus(dAtA, i, uint64(m.Master.Size())) n2, err2 := m.Master.MarshalTo(dAtA[i:]) if err2 != nil { return 0, err2 } i += n2 } if m.Cluster == nil { return 0, github_com_gogo_protobuf_proto.NewRequiredNotSetError("cluster") } else { dAtA[i] = 0x1a i++ i = encodeVarintConsensus(dAtA, i, uint64(len(*m.Cluster))) i += copy(dAtA[i:], *m.Cluster) } if m.XXX_unrecognized != nil { i += copy(dAtA[i:], m.XXX_unrecognized) } return i, nil } func (m *PrepareResponse) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *PrepareResponse) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Instance == nil { return 0, github_com_gogo_protobuf_proto.NewRequiredNotSetError("instance") } else { dAtA[i] = 0x8 i++ i = encodeVarintConsensus(dAtA, i, uint64(*m.Instance)) } if m.Error != nil { dAtA[i] = 0x12 i++ i = encodeVarintConsensus(dAtA, i, uint64(m.Error.Size())) n3, err3 := m.Error.MarshalTo(dAtA[i:]) if err3 != nil { return 0, err3 } i += n3 } if m.XXX_unrecognized != nil { i += copy(dAtA[i:], m.XXX_unrecognized) } return i, nil } func (m *AcceptRequest) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *AcceptRequest) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Version == nil { return 0, github_com_gogo_protobuf_proto.NewRequiredNotSetError("version") } else { dAtA[i] = 0xa i++ i = encodeVarintConsensus(dAtA, i, uint64(m.Version.Size())) n4, err4 := m.Version.MarshalTo(dAtA[i:]) if err4 != nil { return 0, err4 } i += n4 } if len(m.Changes) > 0 { for _, msg := range m.Changes { dAtA[i] = 0x12 i++ i = encodeVarintConsensus(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } if m.Cluster == nil { return 0, github_com_gogo_protobuf_proto.NewRequiredNotSetError("cluster") } else { dAtA[i] = 0x1a i++ i = encodeVarintConsensus(dAtA, i, uint64(len(*m.Cluster))) i += copy(dAtA[i:], *m.Cluster) } if m.XXX_unrecognized != nil { i += copy(dAtA[i:], m.XXX_unrecognized) } return i, nil } func (m *AddMemberRequest) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *AddMemberRequest) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Version == nil { return 0, github_com_gogo_protobuf_proto.NewRequiredNotSetError("version") } else { dAtA[i] = 0xa i++ i = encodeVarintConsensus(dAtA, i, uint64(m.Version.Size())) n5, err5 := m.Version.MarshalTo(dAtA[i:]) if err5 != nil { return 0, err5 } i += n5 } if m.Member == nil { return 0, github_com_gogo_protobuf_proto.NewRequiredNotSetError("member") } else { dAtA[i] = 0x12 i++ i = encodeVarintConsensus(dAtA, i, uint64(m.Member.Size())) n6, err6 := m.Member.MarshalTo(dAtA[i:]) if err6 != nil { return 0, err6 } i += n6 } if m.Cluster == nil { return 0, github_com_gogo_protobuf_proto.NewRequiredNotSetError("cluster") } else { dAtA[i] = 0x1a i++ i = encodeVarintConsensus(dAtA, i, uint64(len(*m.Cluster))) i += copy(dAtA[i:], *m.Cluster) } if m.XXX_unrecognized != nil { i += copy(dAtA[i:], m.XXX_unrecognized) } return i, nil } func (m *RemoveMemberRequest) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *RemoveMemberRequest) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Version == nil { return 0, github_com_gogo_protobuf_proto.NewRequiredNotSetError("version") } else { dAtA[i] = 0xa i++ i = encodeVarintConsensus(dAtA, i, uint64(m.Version.Size())) n7, err7 := m.Version.MarshalTo(dAtA[i:]) if err7 != nil { return 0, err7 } i += n7 } if m.Member == nil { return 0, github_com_gogo_protobuf_proto.NewRequiredNotSetError("member") } else { dAtA[i] = 0x12 i++ i = encodeVarintConsensus(dAtA, i, uint64(m.Member.Size())) n8, err8 := m.Member.MarshalTo(dAtA[i:]) if err8 != nil { return 0, err8 } i += n8 } if m.Cluster == nil { return 0, github_com_gogo_protobuf_proto.NewRequiredNotSetError("cluster") } else { dAtA[i] = 0x1a i++ i = encodeVarintConsensus(dAtA, i, uint64(len(*m.Cluster))) i += copy(dAtA[i:], *m.Cluster) } if m.XXX_unrecognized != nil { i += copy(dAtA[i:], m.XXX_unrecognized) } return i, nil } func (m *StartParticipation) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *StartParticipation) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Version == nil { return 0, github_com_gogo_protobuf_proto.NewRequiredNotSetError("version") } else { dAtA[i] = 0xa i++ i = encodeVarintConsensus(dAtA, i, uint64(m.Version.Size())) n9, err9 := m.Version.MarshalTo(dAtA[i:]) if err9 != nil { return 0, err9 } i += n9 } if m.Cluster == nil { return 0, github_com_gogo_protobuf_proto.NewRequiredNotSetError("cluster") } else { dAtA[i] = 0x12 i++ i = encodeVarintConsensus(dAtA, i, uint64(len(*m.Cluster))) i += copy(dAtA[i:], *m.Cluster) } if m.Self == nil { return 0, github_com_gogo_protobuf_proto.NewRequiredNotSetError("self") } else { dAtA[i] = 0x1a i++ i = encodeVarintConsensus(dAtA, i, uint64(m.Self.Size())) n10, err10 := m.Self.MarshalTo(dAtA[i:]) if err10 != nil { return 0, err10 } i += n10 } if m.Master == nil { return 0, github_com_gogo_protobuf_proto.NewRequiredNotSetError("master") } else { dAtA[i] = 0x22 i++ i = encodeVarintConsensus(dAtA, i, uint64(m.Master.Size())) n11, err11 := m.Master.MarshalTo(dAtA[i:]) if err11 != nil { return 0, err11 } i += n11 } if len(m.Members) > 0 { for _, msg := range m.Members { dAtA[i] = 0x2a i++ i = encodeVarintConsensus(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } if m.Snapshot == nil { return 0, github_com_gogo_protobuf_proto.NewRequiredNotSetError("snapshot") } else { dAtA[i] = 0x32 i++ i = encodeVarintConsensus(dAtA, i, uint64(len(m.Snapshot))) i += copy(dAtA[i:], m.Snapshot) } if m.XXX_unrecognized != nil { i += copy(dAtA[i:], m.XXX_unrecognized) } return i, nil } func (m *SubmitRequest) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *SubmitRequest) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.Changes) > 0 { for _, msg := range m.Changes { dAtA[i] = 0xa i++ i = encodeVarintConsensus(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } if m.Cluster == nil { return 0, github_com_gogo_protobuf_proto.NewRequiredNotSetError("cluster") } else { dAtA[i] = 0x12 i++ i = encodeVarintConsensus(dAtA, i, uint64(len(*m.Cluster))) i += copy(dAtA[i:], *m.Cluster) } if m.XXX_unrecognized != nil { i += copy(dAtA[i:], m.XXX_unrecognized) } return i, nil } func encodeVarintConsensus(dAtA []byte, offset int, v uint64) int { for v >= 1<<7 { dAtA[offset] = uint8(v&0x7f | 0x80) v >>= 7 offset++ } dAtA[offset] = uint8(v) return offset + 1 } func (m *Error) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.Error != nil { l = len(*m.Error) n += 1 + l + sovConsensus(uint64(l)) } if m.Type != nil { l = len(*m.Type) n += 1 + l + sovConsensus(uint64(l)) } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } return n } func (m *Change) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.Change != nil { l = len(m.Change) n += 1 + l + sovConsensus(uint64(l)) } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } return n } func (m *Member) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.Address != nil { l = len(*m.Address) n += 1 + l + sovConsensus(uint64(l)) } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } return n } func (m *Version) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.Instance != nil { n += 1 + sovConsensus(uint64(*m.Instance)) } if m.Sequence != nil { n += 1 + sovConsensus(uint64(*m.Sequence)) } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } return n } func (m *GenericResponse) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.Accepted != nil { n += 2 } if m.Error != nil { l = m.Error.Size() n += 1 + l + sovConsensus(uint64(l)) } if m.Instance != nil { n += 1 + sovConsensus(uint64(*m.Instance)) } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } return n } func (m *PrepareRequest) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.Instance != nil { n += 1 + sovConsensus(uint64(*m.Instance)) } if m.Master != nil { l = m.Master.Size() n += 1 + l + sovConsensus(uint64(l)) } if m.Cluster != nil { l = len(*m.Cluster) n += 1 + l + sovConsensus(uint64(l)) } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } return n } func (m *PrepareResponse) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.Instance != nil { n += 1 + sovConsensus(uint64(*m.Instance)) } if m.Error != nil { l = m.Error.Size() n += 1 + l + sovConsensus(uint64(l)) } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } return n } func (m *AcceptRequest) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.Version != nil { l = m.Version.Size() n += 1 + l + sovConsensus(uint64(l)) } if len(m.Changes) > 0 { for _, e := range m.Changes { l = e.Size() n += 1 + l + sovConsensus(uint64(l)) } } if m.Cluster != nil { l = len(*m.Cluster) n += 1 + l + sovConsensus(uint64(l)) } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } return n } func (m *AddMemberRequest) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.Version != nil { l = m.Version.Size() n += 1 + l + sovConsensus(uint64(l)) } if m.Member != nil { l = m.Member.Size() n += 1 + l + sovConsensus(uint64(l)) } if m.Cluster != nil { l = len(*m.Cluster) n += 1 + l + sovConsensus(uint64(l)) } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } return n } func (m *RemoveMemberRequest) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.Version != nil { l = m.Version.Size() n += 1 + l + sovConsensus(uint64(l)) } if m.Member != nil { l = m.Member.Size() n += 1 + l + sovConsensus(uint64(l)) } if m.Cluster != nil { l = len(*m.Cluster) n += 1 + l + sovConsensus(uint64(l)) } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } return n } func (m *StartParticipation) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.Version != nil { l = m.Version.Size() n += 1 + l + sovConsensus(uint64(l)) } if m.Cluster != nil { l = len(*m.Cluster) n += 1 + l + sovConsensus(uint64(l)) } if m.Self != nil { l = m.Self.Size() n += 1 + l + sovConsensus(uint64(l)) } if m.Master != nil { l = m.Master.Size() n += 1 + l + sovConsensus(uint64(l)) } if len(m.Members) > 0 { for _, e := range m.Members { l = e.Size() n += 1 + l + sovConsensus(uint64(l)) } } if m.Snapshot != nil { l = len(m.Snapshot) n += 1 + l + sovConsensus(uint64(l)) } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } return n } func (m *SubmitRequest) Size() (n int) { if m == nil { return 0 } var l int _ = l if len(m.Changes) > 0 { for _, e := range m.Changes { l = e.Size() n += 1 + l + sovConsensus(uint64(l)) } } if m.Cluster != nil { l = len(*m.Cluster) n += 1 + l + sovConsensus(uint64(l)) } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } return n } func sovConsensus(x uint64) (n int) { return (math_bits.Len64(x|1) + 6) / 7 } func sozConsensus(x uint64) (n int) { return sovConsensus(uint64((x << 1) ^ uint64((int64(x) >> 63)))) } func (m *Error) 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 ErrIntOverflowConsensus } 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: Error: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: Error: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Error", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } 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 ErrInvalidLengthConsensus } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthConsensus } if postIndex > l { return io.ErrUnexpectedEOF } s := string(dAtA[iNdEx:postIndex]) m.Error = &s iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Type", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } 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 ErrInvalidLengthConsensus } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthConsensus } if postIndex > l { return io.ErrUnexpectedEOF } s := string(dAtA[iNdEx:postIndex]) m.Type = &s iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipConsensus(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthConsensus } if (iNdEx + skippy) < 0 { return ErrInvalidLengthConsensus } 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 *Change) 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 ErrIntOverflowConsensus } 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: Change: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: Change: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Change", wireType) } var byteLen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ byteLen |= int(b&0x7F) << shift if b < 0x80 { break } } if byteLen < 0 { return ErrInvalidLengthConsensus } postIndex := iNdEx + byteLen if postIndex < 0 { return ErrInvalidLengthConsensus } if postIndex > l { return io.ErrUnexpectedEOF } m.Change = append(m.Change[:0], dAtA[iNdEx:postIndex]...) if m.Change == nil { m.Change = []byte{} } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipConsensus(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthConsensus } if (iNdEx + skippy) < 0 { return ErrInvalidLengthConsensus } 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 *Member) 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 ErrIntOverflowConsensus } 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: Member: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: Member: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Address", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } 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 ErrInvalidLengthConsensus } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthConsensus } if postIndex > l { return io.ErrUnexpectedEOF } s := string(dAtA[iNdEx:postIndex]) m.Address = &s iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipConsensus(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthConsensus } if (iNdEx + skippy) < 0 { return ErrInvalidLengthConsensus } 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 *Version) Unmarshal(dAtA []byte) error { var hasFields [1]uint64 l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } 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: Version: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: Version: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Instance", wireType) } var v uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= uint64(b&0x7F) << shift if b < 0x80 { break } } m.Instance = &v hasFields[0] |= uint64(0x00000001) case 2: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Sequence", wireType) } var v uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= uint64(b&0x7F) << shift if b < 0x80 { break } } m.Sequence = &v hasFields[0] |= uint64(0x00000002) default: iNdEx = preIndex skippy, err := skipConsensus(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthConsensus } if (iNdEx + skippy) < 0 { return ErrInvalidLengthConsensus } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) iNdEx += skippy } } if hasFields[0]&uint64(0x00000001) == 0 { return github_com_gogo_protobuf_proto.NewRequiredNotSetError("instance") } if hasFields[0]&uint64(0x00000002) == 0 { return github_com_gogo_protobuf_proto.NewRequiredNotSetError("sequence") } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *GenericResponse) Unmarshal(dAtA []byte) error { var hasFields [1]uint64 l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } 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: GenericResponse: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: GenericResponse: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Accepted", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= int(b&0x7F) << shift if b < 0x80 { break } } b := bool(v != 0) m.Accepted = &b hasFields[0] |= uint64(0x00000001) case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Error", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthConsensus } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthConsensus } if postIndex > l { return io.ErrUnexpectedEOF } if m.Error == nil { m.Error = &Error{} } if err := m.Error.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex case 3: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Instance", wireType) } var v uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= uint64(b&0x7F) << shift if b < 0x80 { break } } m.Instance = &v default: iNdEx = preIndex skippy, err := skipConsensus(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthConsensus } if (iNdEx + skippy) < 0 { return ErrInvalidLengthConsensus } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) iNdEx += skippy } } if hasFields[0]&uint64(0x00000001) == 0 { return github_com_gogo_protobuf_proto.NewRequiredNotSetError("accepted") } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *PrepareRequest) Unmarshal(dAtA []byte) error { var hasFields [1]uint64 l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } 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: PrepareRequest: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: PrepareRequest: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Instance", wireType) } var v uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= uint64(b&0x7F) << shift if b < 0x80 { break } } m.Instance = &v hasFields[0] |= uint64(0x00000001) case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Master", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthConsensus } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthConsensus } if postIndex > l { return io.ErrUnexpectedEOF } if m.Master == nil { m.Master = &Member{} } if err := m.Master.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex hasFields[0] |= uint64(0x00000002) case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Cluster", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } 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 ErrInvalidLengthConsensus } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthConsensus } if postIndex > l { return io.ErrUnexpectedEOF } s := string(dAtA[iNdEx:postIndex]) m.Cluster = &s iNdEx = postIndex hasFields[0] |= uint64(0x00000004) default: iNdEx = preIndex skippy, err := skipConsensus(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthConsensus } if (iNdEx + skippy) < 0 { return ErrInvalidLengthConsensus } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) iNdEx += skippy } } if hasFields[0]&uint64(0x00000001) == 0 { return github_com_gogo_protobuf_proto.NewRequiredNotSetError("instance") } if hasFields[0]&uint64(0x00000002) == 0 { return github_com_gogo_protobuf_proto.NewRequiredNotSetError("master") } if hasFields[0]&uint64(0x00000004) == 0 { return github_com_gogo_protobuf_proto.NewRequiredNotSetError("cluster") } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *PrepareResponse) Unmarshal(dAtA []byte) error { var hasFields [1]uint64 l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } 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: PrepareResponse: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: PrepareResponse: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Instance", wireType) } var v uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= uint64(b&0x7F) << shift if b < 0x80 { break } } m.Instance = &v hasFields[0] |= uint64(0x00000001) case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Error", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthConsensus } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthConsensus } if postIndex > l { return io.ErrUnexpectedEOF } if m.Error == nil { m.Error = &Error{} } if err := m.Error.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipConsensus(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthConsensus } if (iNdEx + skippy) < 0 { return ErrInvalidLengthConsensus } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) iNdEx += skippy } } if hasFields[0]&uint64(0x00000001) == 0 { return github_com_gogo_protobuf_proto.NewRequiredNotSetError("instance") } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *AcceptRequest) Unmarshal(dAtA []byte) error { var hasFields [1]uint64 l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } 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: AcceptRequest: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: AcceptRequest: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Version", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthConsensus } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthConsensus } if postIndex > l { return io.ErrUnexpectedEOF } if m.Version == nil { m.Version = &Version{} } if err := m.Version.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex hasFields[0] |= uint64(0x00000001) case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Changes", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthConsensus } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthConsensus } if postIndex > l { return io.ErrUnexpectedEOF } m.Changes = append(m.Changes, &Change{}) if err := m.Changes[len(m.Changes)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Cluster", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } 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 ErrInvalidLengthConsensus } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthConsensus } if postIndex > l { return io.ErrUnexpectedEOF } s := string(dAtA[iNdEx:postIndex]) m.Cluster = &s iNdEx = postIndex hasFields[0] |= uint64(0x00000002) default: iNdEx = preIndex skippy, err := skipConsensus(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthConsensus } if (iNdEx + skippy) < 0 { return ErrInvalidLengthConsensus } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) iNdEx += skippy } } if hasFields[0]&uint64(0x00000001) == 0 { return github_com_gogo_protobuf_proto.NewRequiredNotSetError("version") } if hasFields[0]&uint64(0x00000002) == 0 { return github_com_gogo_protobuf_proto.NewRequiredNotSetError("cluster") } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *AddMemberRequest) Unmarshal(dAtA []byte) error { var hasFields [1]uint64 l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } 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: AddMemberRequest: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: AddMemberRequest: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Version", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthConsensus } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthConsensus } if postIndex > l { return io.ErrUnexpectedEOF } if m.Version == nil { m.Version = &Version{} } if err := m.Version.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex hasFields[0] |= uint64(0x00000001) case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Member", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthConsensus } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthConsensus } if postIndex > l { return io.ErrUnexpectedEOF } if m.Member == nil { m.Member = &Member{} } if err := m.Member.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex hasFields[0] |= uint64(0x00000002) case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Cluster", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } 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 ErrInvalidLengthConsensus } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthConsensus } if postIndex > l { return io.ErrUnexpectedEOF } s := string(dAtA[iNdEx:postIndex]) m.Cluster = &s iNdEx = postIndex hasFields[0] |= uint64(0x00000004) default: iNdEx = preIndex skippy, err := skipConsensus(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthConsensus } if (iNdEx + skippy) < 0 { return ErrInvalidLengthConsensus } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) iNdEx += skippy } } if hasFields[0]&uint64(0x00000001) == 0 { return github_com_gogo_protobuf_proto.NewRequiredNotSetError("version") } if hasFields[0]&uint64(0x00000002) == 0 { return github_com_gogo_protobuf_proto.NewRequiredNotSetError("member") } if hasFields[0]&uint64(0x00000004) == 0 { return github_com_gogo_protobuf_proto.NewRequiredNotSetError("cluster") } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *RemoveMemberRequest) Unmarshal(dAtA []byte) error { var hasFields [1]uint64 l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } 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: RemoveMemberRequest: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: RemoveMemberRequest: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Version", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthConsensus } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthConsensus } if postIndex > l { return io.ErrUnexpectedEOF } if m.Version == nil { m.Version = &Version{} } if err := m.Version.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex hasFields[0] |= uint64(0x00000001) case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Member", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthConsensus } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthConsensus } if postIndex > l { return io.ErrUnexpectedEOF } if m.Member == nil { m.Member = &Member{} } if err := m.Member.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex hasFields[0] |= uint64(0x00000002) case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Cluster", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } 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 ErrInvalidLengthConsensus } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthConsensus } if postIndex > l { return io.ErrUnexpectedEOF } s := string(dAtA[iNdEx:postIndex]) m.Cluster = &s iNdEx = postIndex hasFields[0] |= uint64(0x00000004) default: iNdEx = preIndex skippy, err := skipConsensus(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthConsensus } if (iNdEx + skippy) < 0 { return ErrInvalidLengthConsensus } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) iNdEx += skippy } } if hasFields[0]&uint64(0x00000001) == 0 { return github_com_gogo_protobuf_proto.NewRequiredNotSetError("version") } if hasFields[0]&uint64(0x00000002) == 0 { return github_com_gogo_protobuf_proto.NewRequiredNotSetError("member") } if hasFields[0]&uint64(0x00000004) == 0 { return github_com_gogo_protobuf_proto.NewRequiredNotSetError("cluster") } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *StartParticipation) Unmarshal(dAtA []byte) error { var hasFields [1]uint64 l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } 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: StartParticipation: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: StartParticipation: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Version", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthConsensus } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthConsensus } if postIndex > l { return io.ErrUnexpectedEOF } if m.Version == nil { m.Version = &Version{} } if err := m.Version.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex hasFields[0] |= uint64(0x00000001) case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Cluster", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } 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 ErrInvalidLengthConsensus } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthConsensus } if postIndex > l { return io.ErrUnexpectedEOF } s := string(dAtA[iNdEx:postIndex]) m.Cluster = &s iNdEx = postIndex hasFields[0] |= uint64(0x00000002) case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Self", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthConsensus } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthConsensus } if postIndex > l { return io.ErrUnexpectedEOF } if m.Self == nil { m.Self = &Member{} } if err := m.Self.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex hasFields[0] |= uint64(0x00000004) case 4: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Master", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthConsensus } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthConsensus } if postIndex > l { return io.ErrUnexpectedEOF } if m.Master == nil { m.Master = &Member{} } if err := m.Master.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex hasFields[0] |= uint64(0x00000008) case 5: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Members", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthConsensus } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthConsensus } if postIndex > l { return io.ErrUnexpectedEOF } m.Members = append(m.Members, &Member{}) if err := m.Members[len(m.Members)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex case 6: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Snapshot", wireType) } var byteLen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ byteLen |= int(b&0x7F) << shift if b < 0x80 { break } } if byteLen < 0 { return ErrInvalidLengthConsensus } postIndex := iNdEx + byteLen if postIndex < 0 { return ErrInvalidLengthConsensus } if postIndex > l { return io.ErrUnexpectedEOF } m.Snapshot = append(m.Snapshot[:0], dAtA[iNdEx:postIndex]...) if m.Snapshot == nil { m.Snapshot = []byte{} } iNdEx = postIndex hasFields[0] |= uint64(0x00000010) default: iNdEx = preIndex skippy, err := skipConsensus(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthConsensus } if (iNdEx + skippy) < 0 { return ErrInvalidLengthConsensus } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) iNdEx += skippy } } if hasFields[0]&uint64(0x00000001) == 0 { return github_com_gogo_protobuf_proto.NewRequiredNotSetError("version") } if hasFields[0]&uint64(0x00000002) == 0 { return github_com_gogo_protobuf_proto.NewRequiredNotSetError("cluster") } if hasFields[0]&uint64(0x00000004) == 0 { return github_com_gogo_protobuf_proto.NewRequiredNotSetError("self") } if hasFields[0]&uint64(0x00000008) == 0 { return github_com_gogo_protobuf_proto.NewRequiredNotSetError("master") } if hasFields[0]&uint64(0x00000010) == 0 { return github_com_gogo_protobuf_proto.NewRequiredNotSetError("snapshot") } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *SubmitRequest) Unmarshal(dAtA []byte) error { var hasFields [1]uint64 l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } 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: SubmitRequest: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: SubmitRequest: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Changes", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthConsensus } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthConsensus } if postIndex > l { return io.ErrUnexpectedEOF } m.Changes = append(m.Changes, &Change{}) if err := m.Changes[len(m.Changes)-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 Cluster", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowConsensus } 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 ErrInvalidLengthConsensus } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthConsensus } if postIndex > l { return io.ErrUnexpectedEOF } s := string(dAtA[iNdEx:postIndex]) m.Cluster = &s iNdEx = postIndex hasFields[0] |= uint64(0x00000001) default: iNdEx = preIndex skippy, err := skipConsensus(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthConsensus } if (iNdEx + skippy) < 0 { return ErrInvalidLengthConsensus } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) iNdEx += skippy } } if hasFields[0]&uint64(0x00000001) == 0 { return github_com_gogo_protobuf_proto.NewRequiredNotSetError("cluster") } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func skipConsensus(dAtA []byte) (n int, err error) { l := len(dAtA) iNdEx := 0 for iNdEx < l { var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return 0, ErrIntOverflowConsensus } 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, ErrIntOverflowConsensus } if iNdEx >= l { return 0, io.ErrUnexpectedEOF } iNdEx++ if dAtA[iNdEx-1] < 0x80 { break } } return iNdEx, nil case 1: iNdEx += 8 return iNdEx, nil case 2: var length int for shift := uint(0); ; shift += 7 { if shift >= 64 { return 0, ErrIntOverflowConsensus } 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, ErrInvalidLengthConsensus } iNdEx += length if iNdEx < 0 { return 0, ErrInvalidLengthConsensus } return iNdEx, nil case 3: for { var innerWire uint64 var start int = iNdEx for shift := uint(0); ; shift += 7 { if shift >= 64 { return 0, ErrIntOverflowConsensus } if iNdEx >= l { return 0, io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ innerWire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } innerWireType := int(innerWire & 0x7) if innerWireType == 4 { break } next, err := skipConsensus(dAtA[start:]) if err != nil { return 0, err } iNdEx = start + next if iNdEx < 0 { return 0, ErrInvalidLengthConsensus } } return iNdEx, nil case 4: return iNdEx, nil case 5: iNdEx += 4 return iNdEx, nil default: return 0, fmt.Errorf("proto: illegal wireType %d", wireType) } } panic("unreachable") } var ( ErrInvalidLengthConsensus = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowConsensus = fmt.Errorf("proto: integer overflow") )