nodesyncproto

type ColdSyncProtocolType int32

type ColdSyncRequest struct {
	SpaceId      string               `protobuf:"bytes,1,opt,name=spaceId,proto3" json:"spaceId,omitempty"`
	ProtocolType ColdSyncProtocolType `protobuf:"varint,2,opt,name=protocolType,proto3,enum=anyNodeSync.ColdSyncProtocolType" json:"protocolType,omitempty"`
	// contains filtered or unexported fields
}

type ColdSyncResponse struct {
	Filename     string               `protobuf:"bytes,2,opt,name=filename,proto3" json:"filename,omitempty"`
	Data         []byte               `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Crc32        uint32               `protobuf:"varint,4,opt,name=crc32,proto3" json:"crc32,omitempty"`
	ProtocolType ColdSyncProtocolType `protobuf:"varint,5,opt,name=protocolType,proto3,enum=anyNodeSync.ColdSyncProtocolType" json:"protocolType,omitempty"`
	// contains filtered or unexported fields
}

type DRPCNodeSyncClient interface {
	DRPCConn() drpc.Conn

	PartitionSync(ctx context.Context, in *PartitionSyncRequest) (*PartitionSyncResponse, error)
	ColdSync(ctx context.Context, in *ColdSyncRequest) (DRPCNodeSync_ColdSyncClient, error)
}

type DRPCNodeSyncDescription struct{}

type DRPCNodeSyncServer interface {
	PartitionSync(context.Context, *PartitionSyncRequest) (*PartitionSyncResponse, error)
	ColdSync(*ColdSyncRequest, DRPCNodeSync_ColdSyncStream) error
}

type DRPCNodeSyncUnimplementedServer struct{}

type DRPCNodeSync_ColdSyncClient interface {
	drpc.Stream
	Recv() (*ColdSyncResponse, error)
}

type DRPCNodeSync_ColdSyncStream interface {
	drpc.Stream
	Send(*ColdSyncResponse) error
}

type DRPCNodeSync_PartitionSyncStream interface {
	drpc.Stream
	SendAndClose(*PartitionSyncResponse) error
}

type ErrCodes int32

type PartitionSyncRange struct {
	From     uint64 `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"`
	To       uint64 `protobuf:"varint,2,opt,name=to,proto3" json:"to,omitempty"`
	Limit    uint32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	Elements bool   `protobuf:"varint,4,opt,name=elements,proto3" json:"elements,omitempty"`
	// contains filtered or unexported fields
}

type PartitionSyncRequest struct {
	PartitionId uint64                `protobuf:"varint,1,opt,name=partitionId,proto3" json:"partitionId,omitempty"`
	Ranges      []*PartitionSyncRange `protobuf:"bytes,2,rep,name=ranges,proto3" json:"ranges,omitempty"`
	// contains filtered or unexported fields
}

type PartitionSyncResponse struct {
	Results []*PartitionSyncResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

type PartitionSyncResult struct {
	Hash     []byte                        `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	Elements []*PartitionSyncResultElement `protobuf:"bytes,2,rep,name=elements,proto3" json:"elements,omitempty"`
	Count    uint32                        `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

type PartitionSyncResultElement struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Head string `protobuf:"bytes,2,opt,name=head,proto3" json:"head,omitempty"`
	// contains filtered or unexported fields
}