nodesyncproto

Dec 4, 2023

Changes in this version

type PartitionSyncRange

+ Elements bool

+ func (m *PartitionSyncRange) GetElements() bool

May 23, 2023

Changes in this version

+ var ErrCodes_name = map[int32]string

+ var ErrCodes_value = map[string]int32

+ var ErrExpectedCoordinator = errGroup.Register(errors.New("this request should be sent by coordinator"), ...)

+ var ErrIntOverflowNodesync = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthNodesync = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpected = errGroup.Register(errors.New("unexpected error"), uint64(ErrCodes_Unexpected))

+ var ErrUnexpectedEndOfGroupNodesync = fmt.Errorf("proto: unexpected end of group")

+ func DRPCRegisterNodeSync(mux drpc.Mux, impl DRPCNodeSyncServer) error

+ type ColdSyncRequest struct

+ SpaceId string

+ func (*ColdSyncRequest) Descriptor() ([]byte, []int)

+ func (*ColdSyncRequest) ProtoMessage()

+ func (m *ColdSyncRequest) GetSpaceId() string

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

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

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

+ func (m *ColdSyncRequest) Reset()

+ func (m *ColdSyncRequest) Size() (n int)

+ func (m *ColdSyncRequest) String() string

+ func (m *ColdSyncRequest) Unmarshal(dAtA []byte) error

+ func (m *ColdSyncRequest) XXX_DiscardUnknown()

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

+ func (m *ColdSyncRequest) XXX_Merge(src proto.Message)

+ func (m *ColdSyncRequest) XXX_Size() int

+ func (m *ColdSyncRequest) XXX_Unmarshal(b []byte) error

+ type ColdSyncResponse struct

+ Crc32 uint32

+ Data []byte

+ Filename string

+ func (*ColdSyncResponse) Descriptor() ([]byte, []int)

+ func (*ColdSyncResponse) ProtoMessage()

+ func (m *ColdSyncResponse) GetCrc32() uint32

+ func (m *ColdSyncResponse) GetData() []byte

+ func (m *ColdSyncResponse) GetFilename() string

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

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

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

+ func (m *ColdSyncResponse) Reset()

+ func (m *ColdSyncResponse) Size() (n int)

+ func (m *ColdSyncResponse) String() string

+ func (m *ColdSyncResponse) Unmarshal(dAtA []byte) error

+ func (m *ColdSyncResponse) XXX_DiscardUnknown()

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

+ func (m *ColdSyncResponse) XXX_Merge(src proto.Message)

+ func (m *ColdSyncResponse) XXX_Size() int

+ func (m *ColdSyncResponse) XXX_Unmarshal(b []byte) error

+ type DRPCNodeSyncClient interface

+ ColdSync func(ctx context.Context, in *ColdSyncRequest) (DRPCNodeSync_ColdSyncClient, error)

+ DRPCConn func() drpc.Conn

+ PartitionSync func(ctx context.Context, in *PartitionSyncRequest) (*PartitionSyncResponse, error)

+ SpaceDelete func(ctx context.Context, in *SpaceDeleteRequest) (*SpaceDeleteResponse, error)

+ func NewDRPCNodeSyncClient(cc drpc.Conn) DRPCNodeSyncClient

+ type DRPCNodeSyncDescription struct

+ func (DRPCNodeSyncDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool)

+ func (DRPCNodeSyncDescription) NumMethods() int

+ type DRPCNodeSyncServer interface

+ ColdSync func(*ColdSyncRequest, DRPCNodeSync_ColdSyncStream) error

+ PartitionSync func(context.Context, *PartitionSyncRequest) (*PartitionSyncResponse, error)

+ SpaceDelete func(context.Context, *SpaceDeleteRequest) (*SpaceDeleteResponse, error)

+ type DRPCNodeSyncUnimplementedServer struct

+ func (s *DRPCNodeSyncUnimplementedServer) ColdSync(*ColdSyncRequest, DRPCNodeSync_ColdSyncStream) error

+ func (s *DRPCNodeSyncUnimplementedServer) PartitionSync(context.Context, *PartitionSyncRequest) (*PartitionSyncResponse, error)

+ func (s *DRPCNodeSyncUnimplementedServer) SpaceDelete(context.Context, *SpaceDeleteRequest) (*SpaceDeleteResponse, error)

+ type DRPCNodeSync_ColdSyncClient interface

+ Recv func() (*ColdSyncResponse, error)

+ type DRPCNodeSync_ColdSyncStream interface

+ Send func(*ColdSyncResponse) error

+ type DRPCNodeSync_PartitionSyncStream interface

+ SendAndClose func(*PartitionSyncResponse) error

+ type DRPCNodeSync_SpaceDeleteStream interface

+ SendAndClose func(*SpaceDeleteResponse) error

+ type ErrCodes int32

+ const ErrCodes_ErrorOffset

+ const ErrCodes_ExpectedCoordinator

+ const ErrCodes_Unexpected

+ func (ErrCodes) EnumDescriptor() ([]byte, []int)

+ func (x ErrCodes) String() string

+ type PartitionSyncRange struct

+ From uint64

+ Limit uint32

+ To uint64

+ func (*PartitionSyncRange) Descriptor() ([]byte, []int)

+ func (*PartitionSyncRange) ProtoMessage()

+ func (m *PartitionSyncRange) GetFrom() uint64

+ func (m *PartitionSyncRange) GetLimit() uint32

+ func (m *PartitionSyncRange) GetTo() uint64

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

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

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

+ func (m *PartitionSyncRange) Reset()

+ func (m *PartitionSyncRange) Size() (n int)

+ func (m *PartitionSyncRange) String() string

+ func (m *PartitionSyncRange) Unmarshal(dAtA []byte) error

+ func (m *PartitionSyncRange) XXX_DiscardUnknown()

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

+ func (m *PartitionSyncRange) XXX_Merge(src proto.Message)

+ func (m *PartitionSyncRange) XXX_Size() int

+ func (m *PartitionSyncRange) XXX_Unmarshal(b []byte) error

+ type PartitionSyncRequest struct

+ PartitionId uint64

+ Ranges []*PartitionSyncRange

+ func (*PartitionSyncRequest) Descriptor() ([]byte, []int)

+ func (*PartitionSyncRequest) ProtoMessage()

+ func (m *PartitionSyncRequest) GetPartitionId() uint64

+ func (m *PartitionSyncRequest) GetRanges() []*PartitionSyncRange

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

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

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

+ func (m *PartitionSyncRequest) Reset()

+ func (m *PartitionSyncRequest) Size() (n int)

+ func (m *PartitionSyncRequest) String() string

+ func (m *PartitionSyncRequest) Unmarshal(dAtA []byte) error

+ func (m *PartitionSyncRequest) XXX_DiscardUnknown()

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

+ func (m *PartitionSyncRequest) XXX_Merge(src proto.Message)

+ func (m *PartitionSyncRequest) XXX_Size() int

+ func (m *PartitionSyncRequest) XXX_Unmarshal(b []byte) error

+ type PartitionSyncResponse struct

+ Results []*PartitionSyncResult

+ func (*PartitionSyncResponse) Descriptor() ([]byte, []int)

+ func (*PartitionSyncResponse) ProtoMessage()

+ func (m *PartitionSyncResponse) GetResults() []*PartitionSyncResult

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

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

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

+ func (m *PartitionSyncResponse) Reset()

+ func (m *PartitionSyncResponse) Size() (n int)

+ func (m *PartitionSyncResponse) String() string

+ func (m *PartitionSyncResponse) Unmarshal(dAtA []byte) error

+ func (m *PartitionSyncResponse) XXX_DiscardUnknown()

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

+ func (m *PartitionSyncResponse) XXX_Merge(src proto.Message)

+ func (m *PartitionSyncResponse) XXX_Size() int

+ func (m *PartitionSyncResponse) XXX_Unmarshal(b []byte) error

+ type PartitionSyncResult struct

+ Count uint32

+ Elements []*PartitionSyncResultElement

+ Hash []byte

+ func (*PartitionSyncResult) Descriptor() ([]byte, []int)

+ func (*PartitionSyncResult) ProtoMessage()

+ func (m *PartitionSyncResult) GetCount() uint32

+ func (m *PartitionSyncResult) GetElements() []*PartitionSyncResultElement

+ func (m *PartitionSyncResult) GetHash() []byte

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

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

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

+ func (m *PartitionSyncResult) Reset()

+ func (m *PartitionSyncResult) Size() (n int)

+ func (m *PartitionSyncResult) String() string

+ func (m *PartitionSyncResult) Unmarshal(dAtA []byte) error

+ func (m *PartitionSyncResult) XXX_DiscardUnknown()

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

+ func (m *PartitionSyncResult) XXX_Merge(src proto.Message)

+ func (m *PartitionSyncResult) XXX_Size() int

+ func (m *PartitionSyncResult) XXX_Unmarshal(b []byte) error

+ type PartitionSyncResultElement struct

+ Head string

+ Id string

+ func (*PartitionSyncResultElement) Descriptor() ([]byte, []int)

+ func (*PartitionSyncResultElement) ProtoMessage()

+ func (m *PartitionSyncResultElement) GetHead() string

+ func (m *PartitionSyncResultElement) GetId() string

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

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

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

+ func (m *PartitionSyncResultElement) Reset()

+ func (m *PartitionSyncResultElement) Size() (n int)

+ func (m *PartitionSyncResultElement) String() string

+ func (m *PartitionSyncResultElement) Unmarshal(dAtA []byte) error

+ func (m *PartitionSyncResultElement) XXX_DiscardUnknown()

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

+ func (m *PartitionSyncResultElement) XXX_Merge(src proto.Message)

+ func (m *PartitionSyncResultElement) XXX_Size() int

+ func (m *PartitionSyncResultElement) XXX_Unmarshal(b []byte) error

+ type SpaceDeleteRequest struct

+ ChangeId string

+ DeleteChange []byte

+ SpaceId string

+ func (*SpaceDeleteRequest) Descriptor() ([]byte, []int)

+ func (*SpaceDeleteRequest) ProtoMessage()

+ func (m *SpaceDeleteRequest) GetChangeId() string

+ func (m *SpaceDeleteRequest) GetDeleteChange() []byte

+ func (m *SpaceDeleteRequest) GetSpaceId() string

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

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

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

+ func (m *SpaceDeleteRequest) Reset()

+ func (m *SpaceDeleteRequest) Size() (n int)

+ func (m *SpaceDeleteRequest) String() string

+ func (m *SpaceDeleteRequest) Unmarshal(dAtA []byte) error

+ func (m *SpaceDeleteRequest) XXX_DiscardUnknown()

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

+ func (m *SpaceDeleteRequest) XXX_Merge(src proto.Message)

+ func (m *SpaceDeleteRequest) XXX_Size() int

+ func (m *SpaceDeleteRequest) XXX_Unmarshal(b []byte) error

+ type SpaceDeleteResponse struct

+ func (*SpaceDeleteResponse) Descriptor() ([]byte, []int)

+ func (*SpaceDeleteResponse) ProtoMessage()

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

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

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

+ func (m *SpaceDeleteResponse) Reset()

+ func (m *SpaceDeleteResponse) Size() (n int)

+ func (m *SpaceDeleteResponse) String() string

+ func (m *SpaceDeleteResponse) Unmarshal(dAtA []byte) error

+ func (m *SpaceDeleteResponse) XXX_DiscardUnknown()

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

+ func (m *SpaceDeleteResponse) XXX_Merge(src proto.Message)

+ func (m *SpaceDeleteResponse) XXX_Size() int

+ func (m *SpaceDeleteResponse) XXX_Unmarshal(b []byte) error