snapshotv1alpha1

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Mar 23, 2024 License: Apache-2.0 Imports: 8 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Part_Encoding_name = map[int32]string{
		0: "ENCODING_UNKNOWN",
		1: "ENCODING_PARQUET",
		2: "ENCODING_ARROW",
	}
	Part_Encoding_value = map[string]int32{
		"ENCODING_UNKNOWN": 0,
		"ENCODING_PARQUET": 1,
		"ENCODING_ARROW":   2,
	}
)

Enum value maps for Part_Encoding.

View Source 
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var File_frostdb_snapshot_v1alpha1_snapshot_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type FooterData 

type FooterData struct {
	TableMetadata []*Table `protobuf:"bytes,1,rep,name=table_metadata,json=tableMetadata,proto3" json:"table_metadata,omitempty"`
	// contains filtered or unexported fields
}

FooterData is a message stored in the footer of a snapshot file that encodes data about the rest of the file.

func (*FooterData) Descriptor deprecated 

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

Deprecated: Use FooterData.ProtoReflect.Descriptor instead.

func (*FooterData) GetTableMetadata 

func (x *FooterData) GetTableMetadata() []*Table

func (*FooterData) MarshalToSizedBufferVT 

func (m *FooterData) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FooterData) MarshalToVT 

func (m *FooterData) MarshalToVT(dAtA []byte) (int, error)

func (*FooterData) MarshalVT 

func (m *FooterData) MarshalVT() (dAtA []byte, err error)

func (*FooterData) ProtoMessage 

func (*FooterData) ProtoMessage()

func (*FooterData) ProtoReflect 

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

func (*FooterData) Reset 

func (x *FooterData) Reset()

func (*FooterData) SizeVT 

func (m *FooterData) SizeVT() (n int)

func (*FooterData) String 

func (x *FooterData) String() string

func (*FooterData) UnmarshalVT 

func (m *FooterData) UnmarshalVT(dAtA []byte) error

type Granule 

type Granule struct {
	PartMetadata []*Part `protobuf:"bytes,1,rep,name=part_metadata,json=partMetadata,proto3" json:"part_metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*Granule) Descriptor deprecated 

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

Deprecated: Use Granule.ProtoReflect.Descriptor instead.

func (*Granule) GetPartMetadata 

func (x *Granule) GetPartMetadata() []*Part

func (*Granule) MarshalToSizedBufferVT 

func (m *Granule) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Granule) MarshalToVT 

func (m *Granule) MarshalToVT(dAtA []byte) (int, error)

func (*Granule) MarshalVT 

func (m *Granule) MarshalVT() (dAtA []byte, err error)

func (*Granule) ProtoMessage 

func (*Granule) ProtoMessage()

func (*Granule) ProtoReflect 

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

func (*Granule) Reset 

func (x *Granule) Reset()

func (*Granule) SizeVT 

func (m *Granule) SizeVT() (n int)

func (*Granule) String 

func (x *Granule) String() string

func (*Granule) UnmarshalVT 

func (m *Granule) UnmarshalVT(dAtA []byte) error

type Part 

type Part struct {
	StartOffset     int64         `protobuf:"varint,1,opt,name=start_offset,json=startOffset,proto3" json:"start_offset,omitempty"`
	EndOffset       int64         `protobuf:"varint,2,opt,name=end_offset,json=endOffset,proto3" json:"end_offset,omitempty"`
	Tx              uint64        `protobuf:"varint,3,opt,name=tx,proto3" json:"tx,omitempty"`
	CompactionLevel uint64        `protobuf:"varint,4,opt,name=compaction_level,json=compactionLevel,proto3" json:"compaction_level,omitempty"`
	Encoding        Part_Encoding `protobuf:"varint,5,opt,name=encoding,proto3,enum=frostdb.snapshot.v1alpha1.Part_Encoding" json:"encoding,omitempty"`
	// contains filtered or unexported fields
}

func (*Part) Descriptor deprecated 

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

Deprecated: Use Part.ProtoReflect.Descriptor instead.

func (*Part) GetCompactionLevel 

func (x *Part) GetCompactionLevel() uint64

func (*Part) GetEncoding 

func (x *Part) GetEncoding() Part_Encoding

func (*Part) GetEndOffset 

func (x *Part) GetEndOffset() int64

func (*Part) GetStartOffset 

func (x *Part) GetStartOffset() int64

func (*Part) GetTx 

func (x *Part) GetTx() uint64

func (*Part) MarshalToSizedBufferVT 

func (m *Part) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Part) MarshalToVT 

func (m *Part) MarshalToVT(dAtA []byte) (int, error)

func (*Part) MarshalVT 

func (m *Part) MarshalVT() (dAtA []byte, err error)

func (*Part) ProtoMessage 

func (*Part) ProtoMessage()

func (*Part) ProtoReflect 

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

func (*Part) Reset 

func (x *Part) Reset()

func (*Part) SizeVT 

func (m *Part) SizeVT() (n int)

func (*Part) String 

func (x *Part) String() string

func (*Part) UnmarshalVT 

func (m *Part) UnmarshalVT(dAtA []byte) error

type Part_Encoding 

type Part_Encoding int32
const (
	Part_ENCODING_UNKNOWN Part_Encoding = 0
	Part_ENCODING_PARQUET Part_Encoding = 1
	Part_ENCODING_ARROW   Part_Encoding = 2
)

func (Part_Encoding) Descriptor 

func (Part_Encoding) Descriptor() protoreflect.EnumDescriptor

func (Part_Encoding) Enum 

func (x Part_Encoding) Enum() *Part_Encoding

func (Part_Encoding) EnumDescriptor deprecated 

func (Part_Encoding) EnumDescriptor() ([]byte, []int)

Deprecated: Use Part_Encoding.Descriptor instead.

func (Part_Encoding) Number 

func (x Part_Encoding) Number() protoreflect.EnumNumber

func (Part_Encoding) String 

func (x Part_Encoding) String() string

func (Part_Encoding) Type 

func (Part_Encoding) Type() protoreflect.EnumType

type Table 

type Table struct {
	Name            string                `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Config          *v1alpha1.TableConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	ActiveBlock     *Table_TableBlock     `protobuf:"bytes,3,opt,name=active_block,json=activeBlock,proto3" json:"active_block,omitempty"`
	GranuleMetadata []*Granule            `protobuf:"bytes,4,rep,name=granule_metadata,json=granuleMetadata,proto3" json:"granule_metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*Table) Descriptor deprecated 

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

Deprecated: Use Table.ProtoReflect.Descriptor instead.

func (*Table) GetActiveBlock 

func (x *Table) GetActiveBlock() *Table_TableBlock

func (*Table) GetConfig 

func (x *Table) GetConfig() *v1alpha1.TableConfig

func (*Table) GetGranuleMetadata 

func (x *Table) GetGranuleMetadata() []*Granule

func (*Table) GetName 

func (x *Table) GetName() string

func (*Table) MarshalToSizedBufferVT 

func (m *Table) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Table) MarshalToVT 

func (m *Table) MarshalToVT(dAtA []byte) (int, error)

func (*Table) MarshalVT 

func (m *Table) MarshalVT() (dAtA []byte, err error)

func (*Table) ProtoMessage 

func (*Table) ProtoMessage()

func (*Table) ProtoReflect 

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

func (*Table) Reset 

func (x *Table) Reset()

func (*Table) SizeVT 

func (m *Table) SizeVT() (n int)

func (*Table) String 

func (x *Table) String() string

func (*Table) UnmarshalVT 

func (m *Table) UnmarshalVT(dAtA []byte) error

type Table_TableBlock 

type Table_TableBlock struct {
	Ulid   []byte `protobuf:"bytes,1,opt,name=ulid,proto3" json:"ulid,omitempty"`
	Size   int64  `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	MinTx  uint64 `protobuf:"varint,3,opt,name=min_tx,json=minTx,proto3" json:"min_tx,omitempty"`
	PrevTx uint64 `protobuf:"varint,4,opt,name=prev_tx,json=prevTx,proto3" json:"prev_tx,omitempty"`
	// contains filtered or unexported fields
}

func (*Table_TableBlock) Descriptor deprecated 

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

Deprecated: Use Table_TableBlock.ProtoReflect.Descriptor instead.

func (*Table_TableBlock) GetMinTx 

func (x *Table_TableBlock) GetMinTx() uint64

func (*Table_TableBlock) GetPrevTx 

func (x *Table_TableBlock) GetPrevTx() uint64

func (*Table_TableBlock) GetSize 

func (x *Table_TableBlock) GetSize() int64

func (*Table_TableBlock) GetUlid 

func (x *Table_TableBlock) GetUlid() []byte

func (*Table_TableBlock) MarshalToSizedBufferVT 

func (m *Table_TableBlock) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Table_TableBlock) MarshalToVT 

func (m *Table_TableBlock) MarshalToVT(dAtA []byte) (int, error)

func (*Table_TableBlock) MarshalVT 

func (m *Table_TableBlock) MarshalVT() (dAtA []byte, err error)

func (*Table_TableBlock) ProtoMessage 

func (*Table_TableBlock) ProtoMessage()

func (*Table_TableBlock) ProtoReflect 

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

func (*Table_TableBlock) Reset 

func (x *Table_TableBlock) Reset()

func (*Table_TableBlock) SizeVT 

func (m *Table_TableBlock) SizeVT() (n int)

func (*Table_TableBlock) String 

func (x *Table_TableBlock) String() string

func (*Table_TableBlock) UnmarshalVT 

func (m *Table_TableBlock) UnmarshalVT(dAtA []byte) error

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.