nodesyncproto

type AdoptArchiveRequest struct {
	SpaceId string `protobuf:"bytes,1,opt,name=spaceId,proto3" json:"spaceId,omitempty"`
	// srcKey is the full key of the gzipped snapshot within the shared bucket (sender's prefix)
	SrcKey string `protobuf:"bytes,2,opt,name=srcKey,proto3" json:"srcKey,omitempty"`
	// heads hashes of the space at snapshot time, as stored in the sender's index
	OldHash string `protobuf:"bytes,3,opt,name=oldHash,proto3" json:"oldHash,omitempty"`
	NewHash string `protobuf:"bytes,4,opt,name=newHash,proto3" json:"newHash,omitempty"`
	// eager asks the receiver to restore the space in background right away
	Eager            bool  `protobuf:"varint,5,opt,name=eager,proto3" json:"eager,omitempty"`
	CompressedSize   int64 `protobuf:"varint,6,opt,name=compressedSize,proto3" json:"compressedSize,omitempty"`
	UncompressedSize int64 `protobuf:"varint,7,opt,name=uncompressedSize,proto3" json:"uncompressedSize,omitempty"`
	// contains filtered or unexported fields
}

type AdoptArchiveResponse struct {
	Result AdoptArchiveResult `protobuf:"varint,1,opt,name=result,proto3,enum=anyNodeSync.AdoptArchiveResult" json:"result,omitempty"`
	// contains filtered or unexported fields
}

type AdoptArchiveResult int32

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)
	AdoptArchive(ctx context.Context, in *AdoptArchiveRequest) (*AdoptArchiveResponse, error)
}

type DRPCNodeSyncDescription struct{}

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

type DRPCNodeSyncUnimplementedServer struct{}

type DRPCNodeSync_AdoptArchiveStream interface {
	drpc.Stream
	SendAndClose(*AdoptArchiveResponse) error
}

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
}