chunk_client

package
v0.0.0-...-5019c65 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 23, 2023 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Default_TMiscExt_UncompressedDataSize   = int64(0)
	Default_TMiscExt_CompressedDataSize     = int64(0)
	Default_TMiscExt_DataWeight             = int64(1)
	Default_TMiscExt_MetaSize               = int64(0)
	Default_TMiscExt_RowCount               = int64(0)
	Default_TMiscExt_CompressionCodec       = int32(0)
	Default_TMiscExt_Sorted                 = bool(false)
	Default_TMiscExt_ValueCount             = int64(0)
	Default_TMiscExt_MaxDataBlockSize       = int64(0)
	Default_TMiscExt_MinTimestamp           = uint64(0)
	Default_TMiscExt_MaxTimestamp           = uint64(0)
	Default_TMiscExt_FirstOverlayedRowIndex = int64(0)
	Default_TMiscExt_Eden                   = bool(false)
	Default_TMiscExt_UniqueKeys             = bool(false)
	Default_TMiscExt_CreationTime           = uint64(0)
	Default_TMiscExt_SharedToSkynet         = bool(false)
)

Default values for TMiscExt fields.

View Source 
const (
	Default_TChunkSpec_TableIndex         = int32(0)
	Default_TChunkSpec_ErasureCodec       = int32(0)
	Default_TChunkSpec_TableRowIndex      = int64(0)
	Default_TChunkSpec_RowIndexIsAbsolute = bool(false)
)

Default values for TChunkSpec fields.

View Source 
const (
	Default_TDataStatistics_UncompressedDataSize = int64(0)
	Default_TDataStatistics_CompressedDataSize   = int64(0)
	Default_TDataStatistics_RowCount             = int64(0)
	Default_TDataStatistics_ChunkCount           = int64(0)
	Default_TDataStatistics_RegularDiskSpace     = int64(0)
	Default_TDataStatistics_ErasureDiskSpace     = int64(0)
	Default_TDataStatistics_DataWeight           = int64(0)
	Default_TDataStatistics_UnmergedRowCount     = int64(0)
	Default_TDataStatistics_UnmergedDataWeight   = int64(0)
)

Default values for TDataStatistics fields.

View Source 
const (
	Default_TBlocksExt_SyncOnClose = bool(true)
)

Default values for TBlocksExt fields.

Variables

View Source 
var File_yt_proto_yt_client_chunk_client_proto_chunk_meta_proto protoreflect.FileDescriptor
View Source 
var File_yt_proto_yt_client_chunk_client_proto_chunk_spec_proto protoreflect.FileDescriptor
View Source 
var File_yt_proto_yt_client_chunk_client_proto_confirm_chunk_replica_info_proto protoreflect.FileDescriptor
View Source 
var File_yt_proto_yt_client_chunk_client_proto_data_statistics_proto protoreflect.FileDescriptor
View Source 
var File_yt_proto_yt_client_chunk_client_proto_read_limit_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type TBlockInfo 

type TBlockInfo struct {
	Offset   *int64  `protobuf:"varint,1,req,name=offset" json:"offset,omitempty"`
	Size     *int64  `protobuf:"varint,2,req,name=size" json:"size,omitempty"`
	Checksum *uint64 `protobuf:"varint,3,req,name=checksum" json:"checksum,omitempty"`
	// contains filtered or unexported fields
}

func (*TBlockInfo) Descriptor deprecated 

func (*TBlockInfo) Descriptor() ([]byte, []int)

Deprecated: Use TBlockInfo.ProtoReflect.Descriptor instead.

func (*TBlockInfo) GetChecksum 

func (x *TBlockInfo) GetChecksum() uint64

func (*TBlockInfo) GetOffset 

func (x *TBlockInfo) GetOffset() int64

func (*TBlockInfo) GetSize 

func (x *TBlockInfo) GetSize() int64

func (*TBlockInfo) ProtoMessage 

func (*TBlockInfo) ProtoMessage()

func (*TBlockInfo) ProtoReflect 

func (x *TBlockInfo) ProtoReflect() protoreflect.Message

func (*TBlockInfo) Reset 

func (x *TBlockInfo) Reset()

func (*TBlockInfo) String 

func (x *TBlockInfo) String() string

type TBlocksExt 

type TBlocksExt struct {

	// Addresses both data and system blocks.
	Blocks []*TBlockInfo `protobuf:"bytes,1,rep,name=blocks" json:"blocks,omitempty"`
	// Whether chunk was written with `sync_on_close` option.
	SyncOnClose *bool `protobuf:"varint,2,opt,name=sync_on_close,json=syncOnClose,def=1" json:"sync_on_close,omitempty"`
	// contains filtered or unexported fields
}

Chunk meta extension.

func (*TBlocksExt) Descriptor deprecated 

func (*TBlocksExt) Descriptor() ([]byte, []int)

Deprecated: Use TBlocksExt.ProtoReflect.Descriptor instead.

func (*TBlocksExt) GetBlocks 

func (x *TBlocksExt) GetBlocks() []*TBlockInfo

func (*TBlocksExt) GetSyncOnClose 

func (x *TBlocksExt) GetSyncOnClose() bool

func (*TBlocksExt) ProtoMessage 

func (*TBlocksExt) ProtoMessage()

func (*TBlocksExt) ProtoReflect 

func (x *TBlocksExt) ProtoReflect() protoreflect.Message

func (*TBlocksExt) Reset 

func (x *TBlocksExt) Reset()

func (*TBlocksExt) String 

func (x *TBlocksExt) String() string

type TChunkMeta 

type TChunkMeta struct {

	// The type (EChunkType) of data stored in this chunk (e.g. tabular, file blob etc).
	Type *int32 `protobuf:"varint,1,req,name=type" json:"type,omitempty"`
	// Format (EChunkFormat) validated by reader.
	Format *int32 `protobuf:"varint,3,req,name=format" json:"format,omitempty"`
	// EChunkFeatures bitmask of the features that are used in this chunk.
	// Chunk reader validates that it supports all the chunk's features.
	Features   *uint64             `protobuf:"varint,4,opt,name=features" json:"features,omitempty"`
	Extensions *misc.TExtensionSet `protobuf:"bytes,2,req,name=extensions" json:"extensions,omitempty"`
	// contains filtered or unexported fields
}

TChunkMeta is stored in *.meta files on data nodes and passed around (possibly with a different extension subset).

func (*TChunkMeta) Descriptor deprecated 

func (*TChunkMeta) Descriptor() ([]byte, []int)

Deprecated: Use TChunkMeta.ProtoReflect.Descriptor instead.

func (*TChunkMeta) GetExtensions 

func (x *TChunkMeta) GetExtensions() *misc.TExtensionSet

func (*TChunkMeta) GetFeatures 

func (x *TChunkMeta) GetFeatures() uint64

func (*TChunkMeta) GetFormat 

func (x *TChunkMeta) GetFormat() int32

func (*TChunkMeta) GetType 

func (x *TChunkMeta) GetType() int32

func (*TChunkMeta) ProtoMessage 

func (*TChunkMeta) ProtoMessage()

func (*TChunkMeta) ProtoReflect 

func (x *TChunkMeta) ProtoReflect() protoreflect.Message

func (*TChunkMeta) Reset 

func (x *TChunkMeta) Reset()

func (*TChunkMeta) String 

func (x *TChunkMeta) String() string

type TChunkSpec 

type TChunkSpec struct {

	// COMPAT(babenko)
	// The way these fields are used is quite chaotic. Possible encodings are as follows:
	// 1) chunk_id is the actual chunk id, others are not used (for static tables only);
	// 2) chunk_id is a tablet id, cell_id is the id of the cell hosting this tablet (for queries);
	// 3) chunk_id is a dynamic store id, tablet_id is the id of the tablet containing this store, and
	//    cell_id is the id of the cell hosting this tablet (for dynamic store reads).
	// In all cases, cell_id could be missing (for legacy clients).
	ChunkId  *misc.TGuid `protobuf:"bytes,1,req,name=chunk_id,json=chunkId" json:"chunk_id,omitempty"`
	TabletId *misc.TGuid `protobuf:"bytes,20,opt,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	CellId   *misc.TGuid `protobuf:"bytes,22,opt,name=cell_id,json=cellId" json:"cell_id,omitempty"`
	// Lower boundary, inclusive.
	LowerLimit *TReadLimit `protobuf:"bytes,2,opt,name=lower_limit,json=lowerLimit" json:"lower_limit,omitempty"`
	// Upper boundary, exclusive.
	UpperLimit *TReadLimit `protobuf:"bytes,3,opt,name=upper_limit,json=upperLimit" json:"upper_limit,omitempty"`
	// Initial seed addresses. The reader may ask the master for additional ones.
	Replicas      []uint32 `protobuf:"fixed32,4,rep,name=replicas" json:"replicas,omitempty"`
	TableIndex    *int32   `protobuf:"varint,7,opt,name=table_index,json=tableIndex,def=0" json:"table_index,omitempty"`
	ErasureCodec  *int32   `protobuf:"varint,9,opt,name=erasure_codec,json=erasureCodec,def=0" json:"erasure_codec,omitempty"`
	TableRowIndex *int64   `protobuf:"varint,10,opt,name=table_row_index,json=tableRowIndex,def=0" json:"table_row_index,omitempty"`
	// Chunk meta can be omitted for intermediate chunks.
	ChunkMeta *TChunkMeta `protobuf:"bytes,11,opt,name=chunk_meta,json=chunkMeta" json:"chunk_meta,omitempty"`
	// Only makes sense as a part of data split.
	Timestamp *uint64 `protobuf:"varint,12,opt,name=timestamp" json:"timestamp,omitempty"`
	// Mapping to ranges.
	RangeIndex *int32 `protobuf:"varint,13,opt,name=range_index,json=rangeIndex" json:"range_index,omitempty"`
	// Overrides the corresponding values in TMiscExt.
	RowCountOverride   *int64 `protobuf:"varint,14,opt,name=row_count_override,json=rowCountOverride" json:"row_count_override,omitempty"`
	DataWeightOverride *int64 `protobuf:"varint,15,opt,name=data_weight_override,json=dataWeightOverride" json:"data_weight_override,omitempty"`
	// Tag of the input data slice this chunk spec belongs to (if any).
	// It helps us restore the correspondence between data slices that
	// form the job input and the unread data slices returned as a
	// job interruption result.
	DataSliceTag *int64 `protobuf:"varint,16,opt,name=data_slice_tag,json=dataSliceTag" json:"data_slice_tag,omitempty"`
	// Global chunk index for the operation. Helps to identify chunk_spec
	// if fetch returns the same chunk with different limits
	// (e.g. the chunk is shared between dynamic table tablets).
	ChunkIndex *int64 `protobuf:"varint,17,opt,name=chunk_index,json=chunkIndex" json:"chunk_index,omitempty"`
	// If set, all values should be treated as having this timestamp, regardless of
	// what is written at chunk meta or versioned values.
	// May be set by some chunk view.
	OverrideTimestamp *uint64 `protobuf:"varint,18,opt,name=override_timestamp,json=overrideTimestamp" json:"override_timestamp,omitempty"`
	// Denotes that all values with timestamps strictly greater than this timestamp
	// should not be read. May be set by some chunk view.
	MaxClipTimestamp *uint64 `protobuf:"varint,23,opt,name=max_clip_timestamp,json=maxClipTimestamp" json:"max_clip_timestamp,omitempty"`
	TabletIndex      *int32  `protobuf:"varint,19,opt,name=tablet_index,json=tabletIndex" json:"tablet_index,omitempty"`
	// True if row_index upper/lower_limit is absolute (table-wise or tablet-wise)
	// rather than relative (chunk-wise).
	RowIndexIsAbsolute *bool `protobuf:"varint,21,opt,name=row_index_is_absolute,json=rowIndexIsAbsolute,def=0" json:"row_index_is_absolute,omitempty"`
	StripedErasure     *bool `protobuf:"varint,24,opt,name=striped_erasure,json=stripedErasure" json:"striped_erasure,omitempty"`
	// contains filtered or unexported fields
}

Describes a portion of table chunk.

func (*TChunkSpec) Descriptor deprecated 

func (*TChunkSpec) Descriptor() ([]byte, []int)

Deprecated: Use TChunkSpec.ProtoReflect.Descriptor instead.

func (*TChunkSpec) GetCellId 

func (x *TChunkSpec) GetCellId() *misc.TGuid

func (*TChunkSpec) GetChunkId 

func (x *TChunkSpec) GetChunkId() *misc.TGuid

func (*TChunkSpec) GetChunkIndex 

func (x *TChunkSpec) GetChunkIndex() int64

func (*TChunkSpec) GetChunkMeta 

func (x *TChunkSpec) GetChunkMeta() *TChunkMeta

func (*TChunkSpec) GetDataSliceTag 

func (x *TChunkSpec) GetDataSliceTag() int64

func (*TChunkSpec) GetDataWeightOverride 

func (x *TChunkSpec) GetDataWeightOverride() int64

func (*TChunkSpec) GetErasureCodec 

func (x *TChunkSpec) GetErasureCodec() int32

func (*TChunkSpec) GetLowerLimit 

func (x *TChunkSpec) GetLowerLimit() *TReadLimit

func (*TChunkSpec) GetMaxClipTimestamp 

func (x *TChunkSpec) GetMaxClipTimestamp() uint64

func (*TChunkSpec) GetOverrideTimestamp 

func (x *TChunkSpec) GetOverrideTimestamp() uint64

func (*TChunkSpec) GetRangeIndex 

func (x *TChunkSpec) GetRangeIndex() int32

func (*TChunkSpec) GetReplicas 

func (x *TChunkSpec) GetReplicas() []uint32

func (*TChunkSpec) GetRowCountOverride 

func (x *TChunkSpec) GetRowCountOverride() int64

func (*TChunkSpec) GetRowIndexIsAbsolute 

func (x *TChunkSpec) GetRowIndexIsAbsolute() bool

func (*TChunkSpec) GetStripedErasure 

func (x *TChunkSpec) GetStripedErasure() bool

func (*TChunkSpec) GetTableIndex 

func (x *TChunkSpec) GetTableIndex() int32

func (*TChunkSpec) GetTableRowIndex 

func (x *TChunkSpec) GetTableRowIndex() int64

func (*TChunkSpec) GetTabletId 

func (x *TChunkSpec) GetTabletId() *misc.TGuid

func (*TChunkSpec) GetTabletIndex 

func (x *TChunkSpec) GetTabletIndex() int32

func (*TChunkSpec) GetTimestamp 

func (x *TChunkSpec) GetTimestamp() uint64

func (*TChunkSpec) GetUpperLimit 

func (x *TChunkSpec) GetUpperLimit() *TReadLimit

func (*TChunkSpec) ProtoMessage 

func (*TChunkSpec) ProtoMessage()

func (*TChunkSpec) ProtoReflect 

func (x *TChunkSpec) ProtoReflect() protoreflect.Message

func (*TChunkSpec) Reset 

func (x *TChunkSpec) Reset()

func (*TChunkSpec) String 

func (x *TChunkSpec) String() string

type TConfirmChunkReplicaInfo 

type TConfirmChunkReplicaInfo struct {
	Replica      *uint64     `protobuf:"fixed64,1,req,name=replica" json:"replica,omitempty"`
	LocationUuid *misc.TGuid `protobuf:"bytes,2,req,name=location_uuid,json=locationUuid" json:"location_uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*TConfirmChunkReplicaInfo) Descriptor deprecated 

func (*TConfirmChunkReplicaInfo) Descriptor() ([]byte, []int)

Deprecated: Use TConfirmChunkReplicaInfo.ProtoReflect.Descriptor instead.

func (*TConfirmChunkReplicaInfo) GetLocationUuid 

func (x *TConfirmChunkReplicaInfo) GetLocationUuid() *misc.TGuid

func (*TConfirmChunkReplicaInfo) GetReplica 

func (x *TConfirmChunkReplicaInfo) GetReplica() uint64

func (*TConfirmChunkReplicaInfo) ProtoMessage 

func (*TConfirmChunkReplicaInfo) ProtoMessage()

func (*TConfirmChunkReplicaInfo) ProtoReflect 

func (x *TConfirmChunkReplicaInfo) ProtoReflect() protoreflect.Message

func (*TConfirmChunkReplicaInfo) Reset 

func (x *TConfirmChunkReplicaInfo) Reset()

func (*TConfirmChunkReplicaInfo) String 

func (x *TConfirmChunkReplicaInfo) String() string

type TDataStatistics 

type TDataStatistics struct {
	UncompressedDataSize *int64 `protobuf:"varint,1,opt,name=uncompressed_data_size,json=uncompressedDataSize,def=0" json:"uncompressed_data_size,omitempty"`
	CompressedDataSize   *int64 `protobuf:"varint,2,opt,name=compressed_data_size,json=compressedDataSize,def=0" json:"compressed_data_size,omitempty"`
	RowCount             *int64 `protobuf:"varint,3,opt,name=row_count,json=rowCount,def=0" json:"row_count,omitempty"`
	ChunkCount           *int64 `protobuf:"varint,4,opt,name=chunk_count,json=chunkCount,def=0" json:"chunk_count,omitempty"`
	RegularDiskSpace     *int64 `protobuf:"varint,6,opt,name=regular_disk_space,json=regularDiskSpace,def=0" json:"regular_disk_space,omitempty"`
	ErasureDiskSpace     *int64 `protobuf:"varint,7,opt,name=erasure_disk_space,json=erasureDiskSpace,def=0" json:"erasure_disk_space,omitempty"`
	// For backward compatibility this can be -1 which means "invalid value".
	DataWeight         *int64 `protobuf:"varint,8,opt,name=data_weight,json=dataWeight,def=0" json:"data_weight,omitempty"`
	UnmergedRowCount   *int64 `protobuf:"varint,9,opt,name=unmerged_row_count,json=unmergedRowCount,def=0" json:"unmerged_row_count,omitempty"`
	UnmergedDataWeight *int64 `protobuf:"varint,10,opt,name=unmerged_data_weight,json=unmergedDataWeight,def=0" json:"unmerged_data_weight,omitempty"`
	// contains filtered or unexported fields
}

func (*TDataStatistics) Descriptor deprecated 

func (*TDataStatistics) Descriptor() ([]byte, []int)

Deprecated: Use TDataStatistics.ProtoReflect.Descriptor instead.

func (*TDataStatistics) GetChunkCount 

func (x *TDataStatistics) GetChunkCount() int64

func (*TDataStatistics) GetCompressedDataSize 

func (x *TDataStatistics) GetCompressedDataSize() int64

func (*TDataStatistics) GetDataWeight 

func (x *TDataStatistics) GetDataWeight() int64

func (*TDataStatistics) GetErasureDiskSpace 

func (x *TDataStatistics) GetErasureDiskSpace() int64

func (*TDataStatistics) GetRegularDiskSpace 

func (x *TDataStatistics) GetRegularDiskSpace() int64

func (*TDataStatistics) GetRowCount 

func (x *TDataStatistics) GetRowCount() int64

func (*TDataStatistics) GetUncompressedDataSize 

func (x *TDataStatistics) GetUncompressedDataSize() int64

func (*TDataStatistics) GetUnmergedDataWeight 

func (x *TDataStatistics) GetUnmergedDataWeight() int64

func (*TDataStatistics) GetUnmergedRowCount 

func (x *TDataStatistics) GetUnmergedRowCount() int64

func (*TDataStatistics) ProtoMessage 

func (*TDataStatistics) ProtoMessage()

func (*TDataStatistics) ProtoReflect 

func (x *TDataStatistics) ProtoReflect() protoreflect.Message

func (*TDataStatistics) Reset 

func (x *TDataStatistics) Reset()

func (*TDataStatistics) String 

func (x *TDataStatistics) String() string

type TErasurePlacementExt 

type TErasurePlacementExt struct {
	PartInfos       []*TPartInfo `protobuf:"bytes,1,rep,name=part_infos,json=partInfos" json:"part_infos,omitempty"`
	ParityPartCount *int32       `protobuf:"varint,2,req,name=parity_part_count,json=parityPartCount" json:"parity_part_count,omitempty"`
	ParityBlockSize *int64       `protobuf:"varint,4,req,name=parity_block_size,json=parityBlockSize" json:"parity_block_size,omitempty"`
	// Parity block count for each stripe of a part.
	ParityBlockCountPerStripe []int32 `` /* 136-byte string literal not displayed */
	// Last parity block size for each stripe of a part.
	ParityLastBlockSizePerStripe []int64 `` /* 147-byte string literal not displayed */
	// We cannot store checksums in TPartInfo,
	// since part infos are present only for non-empty data parts.
	PartChecksums  []uint64 `protobuf:"fixed64,6,rep,name=part_checksums,json=partChecksums" json:"part_checksums,omitempty"`
	BlockChecksums []uint64 `protobuf:"fixed64,7,rep,name=block_checksums,json=blockChecksums" json:"block_checksums,omitempty"`
	// contains filtered or unexported fields
}

Chunk meta extension.

func (*TErasurePlacementExt) Descriptor deprecated 

func (*TErasurePlacementExt) Descriptor() ([]byte, []int)

Deprecated: Use TErasurePlacementExt.ProtoReflect.Descriptor instead.

func (*TErasurePlacementExt) GetBlockChecksums 

func (x *TErasurePlacementExt) GetBlockChecksums() []uint64

func (*TErasurePlacementExt) GetParityBlockCountPerStripe 

func (x *TErasurePlacementExt) GetParityBlockCountPerStripe() []int32

func (*TErasurePlacementExt) GetParityBlockSize 

func (x *TErasurePlacementExt) GetParityBlockSize() int64

func (*TErasurePlacementExt) GetParityLastBlockSizePerStripe 

func (x *TErasurePlacementExt) GetParityLastBlockSizePerStripe() []int64

func (*TErasurePlacementExt) GetParityPartCount 

func (x *TErasurePlacementExt) GetParityPartCount() int32

func (*TErasurePlacementExt) GetPartChecksums 

func (x *TErasurePlacementExt) GetPartChecksums() []uint64

func (*TErasurePlacementExt) GetPartInfos 

func (x *TErasurePlacementExt) GetPartInfos() []*TPartInfo

func (*TErasurePlacementExt) ProtoMessage 

func (*TErasurePlacementExt) ProtoMessage()

func (*TErasurePlacementExt) ProtoReflect 

func (x *TErasurePlacementExt) ProtoReflect() protoreflect.Message

func (*TErasurePlacementExt) Reset 

func (x *TErasurePlacementExt) Reset()

func (*TErasurePlacementExt) String 

func (x *TErasurePlacementExt) String() string

type TMiscExt 

type TMiscExt struct {

	// Total size of uncompressed blocks.
	UncompressedDataSize *int64 `protobuf:"varint,1,opt,name=uncompressed_data_size,json=uncompressedDataSize,def=0" json:"uncompressed_data_size,omitempty"`
	// Total size of blocks with data sent to holder.
	CompressedDataSize *int64 `protobuf:"varint,5,opt,name=compressed_data_size,json=compressedDataSize,def=0" json:"compressed_data_size,omitempty"`
	// Total size of (key column names + values + 1) in each row.
	// Must be greater than zero.
	DataWeight *int64 `protobuf:"varint,7,opt,name=data_weight,json=dataWeight,def=1" json:"data_weight,omitempty"`
	// Size of chunk meta (without TMiscExt), obtained via ByteSize.
	MetaSize *int64 `protobuf:"varint,6,opt,name=meta_size,json=metaSize,def=0" json:"meta_size,omitempty"`
	// Number of rows in this chunk (tables and journals only).
	RowCount *int64 `protobuf:"varint,2,opt,name=row_count,json=rowCount,def=0" json:"row_count,omitempty"`
	// ECompressionCodec
	CompressionCodec *int32 `protobuf:"varint,3,opt,name=compression_codec,json=compressionCodec,def=0" json:"compression_codec,omitempty"`
	// Indicates if the chunk contains a sorted rowset (tables only).
	Sorted *bool `protobuf:"varint,4,opt,name=sorted,def=0" json:"sorted,omitempty"`
	// Number of key-value pairs across all rows in the chunk.
	ValueCount *int64 `protobuf:"varint,8,opt,name=value_count,json=valueCount,def=0" json:"value_count,omitempty"`
	// Uncompressed size of the largest data block.
	MaxDataBlockSize *int64 `protobuf:"varint,9,opt,name=max_data_block_size,json=maxDataBlockSize,def=0" json:"max_data_block_size,omitempty"`
	// Min/max timestamps for versioned table chunks.
	MinTimestamp *uint64 `protobuf:"varint,10,opt,name=min_timestamp,json=minTimestamp,def=0" json:"min_timestamp,omitempty"`
	MaxTimestamp *uint64 `protobuf:"varint,11,opt,name=max_timestamp,json=maxTimestamp,def=0" json:"max_timestamp,omitempty"`
	// Is the chunk sealed (journals only)?
	Sealed *bool `protobuf:"varint,13,opt,name=sealed" json:"sealed,omitempty"`
	// For overlayed journal chunks, contains the journal-wide index of the first row.
	FirstOverlayedRowIndex *int64 `` /* 132-byte string literal not displayed */
	// Does this chunk belong to Eden (dynamic tables only)?
	Eden *bool `protobuf:"varint,14,opt,name=eden,def=0" json:"eden,omitempty"`
	// EErasureCodec
	ErasureCodec *int32 `protobuf:"varint,15,opt,name=erasure_codec,json=erasureCodec" json:"erasure_codec,omitempty"`
	// Indicates if the chunk contains a sorted rowset with unique keys (tables only).
	UniqueKeys *bool `protobuf:"varint,16,opt,name=unique_keys,json=uniqueKeys,def=0" json:"unique_keys,omitempty"`
	// Chunk creation time.
	CreationTime *uint64 `protobuf:"varint,17,opt,name=creation_time,json=creationTime,def=0" json:"creation_time,omitempty"`
	// When set, data nodes allow downloading this chunk by HTTP.
	SharedToSkynet *bool `protobuf:"varint,18,opt,name=shared_to_skynet,json=sharedToSkynet,def=0" json:"shared_to_skynet,omitempty"`
	// System blocks contain internal information (e.g. chunk index).
	SystemBlockCount *int32 `protobuf:"varint,21,opt,name=system_block_count,json=systemBlockCount" json:"system_block_count,omitempty"`
	// Is it a striped erasure chunk?
	StripedErasure *bool `protobuf:"varint,22,opt,name=striped_erasure,json=stripedErasure" json:"striped_erasure,omitempty"`
	// If present, is used by corresponding block reader to distinguish between block versions.
	BlockFormatVersion *int32 `protobuf:"varint,23,opt,name=block_format_version,json=blockFormatVersion" json:"block_format_version,omitempty"`
	// contains filtered or unexported fields
}

Chunk meta extension.

func (*TMiscExt) Descriptor deprecated 

func (*TMiscExt) Descriptor() ([]byte, []int)

Deprecated: Use TMiscExt.ProtoReflect.Descriptor instead.

func (*TMiscExt) GetBlockFormatVersion 

func (x *TMiscExt) GetBlockFormatVersion() int32

func (*TMiscExt) GetCompressedDataSize 

func (x *TMiscExt) GetCompressedDataSize() int64

func (*TMiscExt) GetCompressionCodec 

func (x *TMiscExt) GetCompressionCodec() int32

func (*TMiscExt) GetCreationTime 

func (x *TMiscExt) GetCreationTime() uint64

func (*TMiscExt) GetDataWeight 

func (x *TMiscExt) GetDataWeight() int64

func (*TMiscExt) GetEden 

func (x *TMiscExt) GetEden() bool

func (*TMiscExt) GetErasureCodec 

func (x *TMiscExt) GetErasureCodec() int32

func (*TMiscExt) GetFirstOverlayedRowIndex 

func (x *TMiscExt) GetFirstOverlayedRowIndex() int64

func (*TMiscExt) GetMaxDataBlockSize 

func (x *TMiscExt) GetMaxDataBlockSize() int64

func (*TMiscExt) GetMaxTimestamp 

func (x *TMiscExt) GetMaxTimestamp() uint64

func (*TMiscExt) GetMetaSize 

func (x *TMiscExt) GetMetaSize() int64

func (*TMiscExt) GetMinTimestamp 

func (x *TMiscExt) GetMinTimestamp() uint64

func (*TMiscExt) GetRowCount 

func (x *TMiscExt) GetRowCount() int64

func (*TMiscExt) GetSealed 

func (x *TMiscExt) GetSealed() bool

func (*TMiscExt) GetSharedToSkynet 

func (x *TMiscExt) GetSharedToSkynet() bool

func (*TMiscExt) GetSorted 

func (x *TMiscExt) GetSorted() bool

func (*TMiscExt) GetStripedErasure 

func (x *TMiscExt) GetStripedErasure() bool

func (*TMiscExt) GetSystemBlockCount 

func (x *TMiscExt) GetSystemBlockCount() int32

func (*TMiscExt) GetUncompressedDataSize 

func (x *TMiscExt) GetUncompressedDataSize() int64

func (*TMiscExt) GetUniqueKeys 

func (x *TMiscExt) GetUniqueKeys() bool

func (*TMiscExt) GetValueCount 

func (x *TMiscExt) GetValueCount() int64

func (*TMiscExt) ProtoMessage 

func (*TMiscExt) ProtoMessage()

func (*TMiscExt) ProtoReflect 

func (x *TMiscExt) ProtoReflect() protoreflect.Message

func (*TMiscExt) Reset 

func (x *TMiscExt) Reset()

func (*TMiscExt) String 

func (x *TMiscExt) String() string

type TPartInfo 

type TPartInfo struct {

	// Chunk-wide indexes of starting blocks of the stripes of a part.
	FirstBlockIndexPerStripe []int32 `` /* 133-byte string literal not displayed */
	// Block sizes.
	BlockSizes []int64 `protobuf:"varint,2,rep,name=block_sizes,json=blockSizes" json:"block_sizes,omitempty"`
	// contains filtered or unexported fields
}

func (*TPartInfo) Descriptor deprecated 

func (*TPartInfo) Descriptor() ([]byte, []int)

Deprecated: Use TPartInfo.ProtoReflect.Descriptor instead.

func (*TPartInfo) GetBlockSizes 

func (x *TPartInfo) GetBlockSizes() []int64

func (*TPartInfo) GetFirstBlockIndexPerStripe 

func (x *TPartInfo) GetFirstBlockIndexPerStripe() []int32

func (*TPartInfo) ProtoMessage 

func (*TPartInfo) ProtoMessage()

func (*TPartInfo) ProtoReflect 

func (x *TPartInfo) ProtoReflect() protoreflect.Message

func (*TPartInfo) Reset 

func (x *TPartInfo) Reset()

func (*TPartInfo) String 

func (x *TPartInfo) String() string

type TReadLimit 

type TReadLimit struct {
	RowIndex            *int64 `protobuf:"varint,1,opt,name=row_index,json=rowIndex" json:"row_index,omitempty"`
	ChunkIndex          *int32 `protobuf:"varint,2,opt,name=chunk_index,json=chunkIndex" json:"chunk_index,omitempty"`
	Offset              *int64 `protobuf:"varint,3,opt,name=offset" json:"offset,omitempty"`
	LegacyKey           []byte `protobuf:"bytes,4,opt,name=legacy_key,json=legacyKey" json:"legacy_key,omitempty"`
	KeyBoundPrefix      []byte `protobuf:"bytes,7,opt,name=key_bound_prefix,json=keyBoundPrefix" json:"key_bound_prefix,omitempty"`
	KeyBoundIsInclusive *bool  `protobuf:"varint,8,opt,name=key_bound_is_inclusive,json=keyBoundIsInclusive" json:"key_bound_is_inclusive,omitempty"`
	TabletIndex         *int32 `protobuf:"varint,6,opt,name=tablet_index,json=tabletIndex" json:"tablet_index,omitempty"`
	// Sometimes keys in read limits are transported in wire format via attachments.
	// This index indicates the proper key inside attachments' rowset.
	// Attachment with key bound keyset shares same index.
	KeyIndex *int32 `protobuf:"varint,5,opt,name=key_index,json=keyIndex" json:"key_index,omitempty"`
	// contains filtered or unexported fields
}

A boundary can be given by: * row index (for tables and journals only) * chunk index * offset (for files only) * key (for tables only) A boundary is either inclusive or exclusive depending of the context.

func (*TReadLimit) Descriptor deprecated 

func (*TReadLimit) Descriptor() ([]byte, []int)

Deprecated: Use TReadLimit.ProtoReflect.Descriptor instead.

func (*TReadLimit) GetChunkIndex 

func (x *TReadLimit) GetChunkIndex() int32

func (*TReadLimit) GetKeyBoundIsInclusive 

func (x *TReadLimit) GetKeyBoundIsInclusive() bool

func (*TReadLimit) GetKeyBoundPrefix 

func (x *TReadLimit) GetKeyBoundPrefix() []byte

func (*TReadLimit) GetKeyIndex 

func (x *TReadLimit) GetKeyIndex() int32

func (*TReadLimit) GetLegacyKey 

func (x *TReadLimit) GetLegacyKey() []byte

func (*TReadLimit) GetOffset 

func (x *TReadLimit) GetOffset() int64

func (*TReadLimit) GetRowIndex 

func (x *TReadLimit) GetRowIndex() int64

func (*TReadLimit) GetTabletIndex 

func (x *TReadLimit) GetTabletIndex() int32

func (*TReadLimit) ProtoMessage 

func (*TReadLimit) ProtoMessage()

func (*TReadLimit) ProtoReflect 

func (x *TReadLimit) ProtoReflect() protoreflect.Message

func (*TReadLimit) Reset 

func (x *TReadLimit) Reset()

func (*TReadLimit) String 

func (x *TReadLimit) String() string

type TReadRange 

type TReadRange struct {
	LowerLimit *TReadLimit `protobuf:"bytes,1,opt,name=lower_limit,json=lowerLimit" json:"lower_limit,omitempty"`
	UpperLimit *TReadLimit `protobuf:"bytes,2,opt,name=upper_limit,json=upperLimit" json:"upper_limit,omitempty"`
	// contains filtered or unexported fields
}

func (*TReadRange) Descriptor deprecated 

func (*TReadRange) Descriptor() ([]byte, []int)

Deprecated: Use TReadRange.ProtoReflect.Descriptor instead.

func (*TReadRange) GetLowerLimit 

func (x *TReadRange) GetLowerLimit() *TReadLimit

func (*TReadRange) GetUpperLimit 

func (x *TReadRange) GetUpperLimit() *TReadLimit

func (*TReadRange) ProtoMessage 

func (*TReadRange) ProtoMessage()

func (*TReadRange) ProtoReflect 

func (x *TReadRange) ProtoReflect() protoreflect.Message

func (*TReadRange) Reset 

func (x *TReadRange) Reset()

func (*TReadRange) String 

func (x *TReadRange) String() string

type TStripedErasurePlacementExt 

type TStripedErasurePlacementExt struct {
	PartInfos []*TStripedErasurePlacementExt_TPartInfo `protobuf:"bytes,1,rep,name=part_infos,json=partInfos" json:"part_infos,omitempty"`
	// Numbers of blocks in segments.
	SegmentBlockCounts []int32 `protobuf:"varint,2,rep,name=segment_block_counts,json=segmentBlockCounts" json:"segment_block_counts,omitempty"`
	// Sizes of the original blocks.
	BlockSizes []int64 `protobuf:"varint,3,rep,name=block_sizes,json=blockSizes" json:"block_sizes,omitempty"`
	// Some of the input blocks can be padded to fit into the segment.
	BlockPaddingSizes []int64 `protobuf:"varint,5,rep,name=block_padding_sizes,json=blockPaddingSizes" json:"block_padding_sizes,omitempty"`
	// Checksums of the original blocks.
	BlockChecksums []uint64 `protobuf:"fixed64,4,rep,name=block_checksums,json=blockChecksums" json:"block_checksums,omitempty"`
	// contains filtered or unexported fields
}

Chunk meta extension.

func (*TStripedErasurePlacementExt) Descriptor deprecated 

func (*TStripedErasurePlacementExt) Descriptor() ([]byte, []int)

Deprecated: Use TStripedErasurePlacementExt.ProtoReflect.Descriptor instead.

func (*TStripedErasurePlacementExt) GetBlockChecksums 

func (x *TStripedErasurePlacementExt) GetBlockChecksums() []uint64

func (*TStripedErasurePlacementExt) GetBlockPaddingSizes 

func (x *TStripedErasurePlacementExt) GetBlockPaddingSizes() []int64

func (*TStripedErasurePlacementExt) GetBlockSizes 

func (x *TStripedErasurePlacementExt) GetBlockSizes() []int64

func (*TStripedErasurePlacementExt) GetPartInfos 

func (x *TStripedErasurePlacementExt) GetPartInfos() []*TStripedErasurePlacementExt_TPartInfo

func (*TStripedErasurePlacementExt) GetSegmentBlockCounts 

func (x *TStripedErasurePlacementExt) GetSegmentBlockCounts() []int32

func (*TStripedErasurePlacementExt) ProtoMessage 

func (*TStripedErasurePlacementExt) ProtoMessage()

func (*TStripedErasurePlacementExt) ProtoReflect 

func (x *TStripedErasurePlacementExt) ProtoReflect() protoreflect.Message

func (*TStripedErasurePlacementExt) Reset 

func (x *TStripedErasurePlacementExt) Reset()

func (*TStripedErasurePlacementExt) String 

func (x *TStripedErasurePlacementExt) String() string

type TStripedErasurePlacementExt_TPartInfo 

type TStripedErasurePlacementExt_TPartInfo struct {

	// Sizes of segments in given part.
	SegmentSizes []int64 `protobuf:"varint,1,rep,name=segment_sizes,json=segmentSizes" json:"segment_sizes,omitempty"`
	// Checksums of segments in given part.
	SegmentChecksums []uint64 `protobuf:"fixed64,2,rep,name=segment_checksums,json=segmentChecksums" json:"segment_checksums,omitempty"`
	// contains filtered or unexported fields
}

func (*TStripedErasurePlacementExt_TPartInfo) Descriptor deprecated 

func (*TStripedErasurePlacementExt_TPartInfo) Descriptor() ([]byte, []int)

Deprecated: Use TStripedErasurePlacementExt_TPartInfo.ProtoReflect.Descriptor instead.

func (*TStripedErasurePlacementExt_TPartInfo) GetSegmentChecksums 

func (x *TStripedErasurePlacementExt_TPartInfo) GetSegmentChecksums() []uint64

func (*TStripedErasurePlacementExt_TPartInfo) GetSegmentSizes 

func (x *TStripedErasurePlacementExt_TPartInfo) GetSegmentSizes() []int64

func (*TStripedErasurePlacementExt_TPartInfo) ProtoMessage 

func (*TStripedErasurePlacementExt_TPartInfo) ProtoMessage()

func (*TStripedErasurePlacementExt_TPartInfo) ProtoReflect 

func (x *TStripedErasurePlacementExt_TPartInfo) ProtoReflect() protoreflect.Message

func (*TStripedErasurePlacementExt_TPartInfo) Reset 

func (x *TStripedErasurePlacementExt_TPartInfo) Reset()

func (*TStripedErasurePlacementExt_TPartInfo) String 

func (x *TStripedErasurePlacementExt_TPartInfo) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.