metastorev1

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Jan 17, 2025 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	CompactionJobStatus_name = map[int32]string{
		0: "COMPACTION_STATUS_UNSPECIFIED",
		1: "COMPACTION_STATUS_IN_PROGRESS",
		2: "COMPACTION_STATUS_SUCCESS",
	}
	CompactionJobStatus_value = map[string]int32{
		"COMPACTION_STATUS_UNSPECIFIED": 0,
		"COMPACTION_STATUS_IN_PROGRESS": 1,
		"COMPACTION_STATUS_SUCCESS":     2,
	}
)

Enum value maps for CompactionJobStatus.

View Source 
var CompactionService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "metastore.v1.CompactionService",
	HandlerType: (*CompactionServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PollCompactionJobs",
			Handler:    _CompactionService_PollCompactionJobs_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "metastore/v1/compactor.proto",
}

CompactionService_ServiceDesc is the grpc.ServiceDesc for CompactionService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_metastore_v1_compactor_proto protoreflect.FileDescriptor
View Source 
var File_metastore_v1_index_proto protoreflect.FileDescriptor
View Source 
var File_metastore_v1_query_proto protoreflect.FileDescriptor
View Source 
var File_metastore_v1_tenant_proto protoreflect.FileDescriptor
View Source 
var File_metastore_v1_types_proto protoreflect.FileDescriptor
View Source 
var IndexService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "metastore.v1.IndexService",
	HandlerType: (*IndexServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AddBlock",
			Handler:    _IndexService_AddBlock_Handler,
		},
		{
			MethodName: "GetBlockMetadata",
			Handler:    _IndexService_GetBlockMetadata_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "metastore/v1/index.proto",
}

IndexService_ServiceDesc is the grpc.ServiceDesc for IndexService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var MetadataQueryService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "metastore.v1.MetadataQueryService",
	HandlerType: (*MetadataQueryServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "QueryMetadata",
			Handler:    _MetadataQueryService_QueryMetadata_Handler,
		},
		{
			MethodName: "QueryMetadataLabels",
			Handler:    _MetadataQueryService_QueryMetadataLabels_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "metastore/v1/query.proto",
}

MetadataQueryService_ServiceDesc is the grpc.ServiceDesc for MetadataQueryService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var TenantService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "metastore.v1.TenantService",
	HandlerType: (*TenantServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetTenant",
			Handler:    _TenantService_GetTenant_Handler,
		},
		{
			MethodName: "DeleteTenant",
			Handler:    _TenantService_DeleteTenant_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "metastore/v1/tenant.proto",
}

TenantService_ServiceDesc is the grpc.ServiceDesc for TenantService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterCompactionServiceServer added in v1.1.0 

func RegisterCompactionServiceServer(s grpc.ServiceRegistrar, srv CompactionServiceServer)

func RegisterIndexServiceServer added in v1.1.0 

func RegisterIndexServiceServer(s grpc.ServiceRegistrar, srv IndexServiceServer)

func RegisterMetadataQueryServiceServer added in v1.1.0 

func RegisterMetadataQueryServiceServer(s grpc.ServiceRegistrar, srv MetadataQueryServiceServer)

func RegisterTenantServiceServer added in v1.1.0 

func RegisterTenantServiceServer(s grpc.ServiceRegistrar, srv TenantServiceServer)

Types

type AddBlockRequest 

type AddBlockRequest struct {
	Block *BlockMeta `protobuf:"bytes,1,opt,name=block,proto3" json:"block,omitempty"`
	// contains filtered or unexported fields
}

func (*AddBlockRequest) CloneMessageVT 

func (m *AddBlockRequest) CloneMessageVT() proto.Message

func (*AddBlockRequest) CloneVT 

func (m *AddBlockRequest) CloneVT() *AddBlockRequest

func (*AddBlockRequest) Descriptor deprecated 

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

Deprecated: Use AddBlockRequest.ProtoReflect.Descriptor instead.

func (*AddBlockRequest) EqualMessageVT 

func (this *AddBlockRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*AddBlockRequest) EqualVT 

func (this *AddBlockRequest) EqualVT(that *AddBlockRequest) bool

func (*AddBlockRequest) GetBlock 

func (x *AddBlockRequest) GetBlock() *BlockMeta

func (*AddBlockRequest) MarshalToSizedBufferVT 

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

func (*AddBlockRequest) MarshalToVT 

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

func (*AddBlockRequest) MarshalVT 

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

func (*AddBlockRequest) ProtoMessage 

func (*AddBlockRequest) ProtoMessage()

func (*AddBlockRequest) ProtoReflect 

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

func (*AddBlockRequest) Reset 

func (x *AddBlockRequest) Reset()

func (*AddBlockRequest) SizeVT 

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

func (*AddBlockRequest) String 

func (x *AddBlockRequest) String() string

func (*AddBlockRequest) UnmarshalVT 

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

type AddBlockResponse 

type AddBlockResponse struct {
	// contains filtered or unexported fields
}

func (*AddBlockResponse) CloneMessageVT 

func (m *AddBlockResponse) CloneMessageVT() proto.Message

func (*AddBlockResponse) CloneVT 

func (m *AddBlockResponse) CloneVT() *AddBlockResponse

func (*AddBlockResponse) Descriptor deprecated 

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

Deprecated: Use AddBlockResponse.ProtoReflect.Descriptor instead.

func (*AddBlockResponse) EqualMessageVT 

func (this *AddBlockResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*AddBlockResponse) EqualVT 

func (this *AddBlockResponse) EqualVT(that *AddBlockResponse) bool

func (*AddBlockResponse) MarshalToSizedBufferVT 

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

func (*AddBlockResponse) MarshalToVT 

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

func (*AddBlockResponse) MarshalVT 

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

func (*AddBlockResponse) ProtoMessage 

func (*AddBlockResponse) ProtoMessage()

func (*AddBlockResponse) ProtoReflect 

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

func (*AddBlockResponse) Reset 

func (x *AddBlockResponse) Reset()

func (*AddBlockResponse) SizeVT 

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

func (*AddBlockResponse) String 

func (x *AddBlockResponse) String() string

func (*AddBlockResponse) UnmarshalVT 

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

type BlockList added in v1.1.0 

type BlockList struct {
	Tenant string   `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Shard  uint32   `protobuf:"varint,2,opt,name=shard,proto3" json:"shard,omitempty"`
	Blocks []string `protobuf:"bytes,3,rep,name=blocks,proto3" json:"blocks,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockList) CloneMessageVT added in v1.1.0 

func (m *BlockList) CloneMessageVT() proto.Message

func (*BlockList) CloneVT added in v1.1.0 

func (m *BlockList) CloneVT() *BlockList

func (*BlockList) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use BlockList.ProtoReflect.Descriptor instead.

func (*BlockList) EqualMessageVT added in v1.1.0 

func (this *BlockList) EqualMessageVT(thatMsg proto.Message) bool

func (*BlockList) EqualVT added in v1.1.0 

func (this *BlockList) EqualVT(that *BlockList) bool

func (*BlockList) GetBlocks added in v1.1.0 

func (x *BlockList) GetBlocks() []string

func (*BlockList) GetShard added in v1.1.0 

func (x *BlockList) GetShard() uint32

func (*BlockList) GetTenant added in v1.1.0 

func (x *BlockList) GetTenant() string

func (*BlockList) MarshalToSizedBufferVT added in v1.1.0 

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

func (*BlockList) MarshalToVT added in v1.1.0 

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

func (*BlockList) MarshalVT added in v1.1.0 

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

func (*BlockList) ProtoMessage added in v1.1.0 

func (*BlockList) ProtoMessage()

func (*BlockList) ProtoReflect added in v1.1.0 

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

func (*BlockList) Reset added in v1.1.0 

func (x *BlockList) Reset()

func (*BlockList) SizeVT added in v1.1.0 

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

func (*BlockList) String added in v1.1.0 

func (x *BlockList) String() string

func (*BlockList) UnmarshalVT added in v1.1.0 

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

type BlockMeta 

type BlockMeta struct {
	FormatVersion uint32 `protobuf:"varint,1,opt,name=format_version,json=formatVersion,proto3" json:"format_version,omitempty"`
	// Block ID is a unique identifier for the block.
	// This is the only field that is not included into
	// the string table.
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// If empty, datasets belong to distinct tenants.
	Tenant          int32      `protobuf:"varint,3,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Shard           uint32     `protobuf:"varint,4,opt,name=shard,proto3" json:"shard,omitempty"`
	CompactionLevel uint32     `protobuf:"varint,5,opt,name=compaction_level,json=compactionLevel,proto3" json:"compaction_level,omitempty"`
	MinTime         int64      `protobuf:"varint,6,opt,name=min_time,json=minTime,proto3" json:"min_time,omitempty"`
	MaxTime         int64      `protobuf:"varint,7,opt,name=max_time,json=maxTime,proto3" json:"max_time,omitempty"`
	CreatedBy       int32      `protobuf:"varint,8,opt,name=created_by,json=createdBy,proto3" json:"created_by,omitempty"`
	Size            uint64     `protobuf:"varint,9,opt,name=size,proto3" json:"size,omitempty"`
	Datasets        []*Dataset `protobuf:"bytes,10,rep,name=datasets,proto3" json:"datasets,omitempty"`
	// String table contains strings of the block.
	// By convention, the first string is always an empty string.
	StringTable []string `protobuf:"bytes,11,rep,name=string_table,json=stringTable,proto3" json:"string_table,omitempty"`
	// contains filtered or unexported fields
}

BlockMeta is a metadata entry that describes the block's contents. A block is a collection of datasets that share certain properties, such as shard ID, compaction level, tenant ID, time range, creation time, and more.

The block content's format denotes the binary format of the datasets and the metadata entry (to address logical dependencies). Each dataset has its own table of contents that lists the sections within the dataset. Each dataset has its own set of attributes (labels) that describe its specific contents.

func (*BlockMeta) CloneMessageVT 

func (m *BlockMeta) CloneMessageVT() proto.Message

func (*BlockMeta) CloneVT 

func (m *BlockMeta) CloneVT() *BlockMeta

func (*BlockMeta) Descriptor deprecated 

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

Deprecated: Use BlockMeta.ProtoReflect.Descriptor instead.

func (*BlockMeta) EqualMessageVT 

func (this *BlockMeta) EqualMessageVT(thatMsg proto.Message) bool

func (*BlockMeta) EqualVT 

func (this *BlockMeta) EqualVT(that *BlockMeta) bool

func (*BlockMeta) GetCompactionLevel 

func (x *BlockMeta) GetCompactionLevel() uint32

func (*BlockMeta) GetCreatedBy added in v1.1.0 

func (x *BlockMeta) GetCreatedBy() int32

func (*BlockMeta) GetDatasets 

func (x *BlockMeta) GetDatasets() []*Dataset

func (*BlockMeta) GetFormatVersion 

func (x *BlockMeta) GetFormatVersion() uint32

func (*BlockMeta) GetId 

func (x *BlockMeta) GetId() string

func (*BlockMeta) GetMaxTime 

func (x *BlockMeta) GetMaxTime() int64

func (*BlockMeta) GetMinTime 

func (x *BlockMeta) GetMinTime() int64

func (*BlockMeta) GetShard 

func (x *BlockMeta) GetShard() uint32

func (*BlockMeta) GetSize 

func (x *BlockMeta) GetSize() uint64

func (*BlockMeta) GetStringTable added in v1.1.0 

func (x *BlockMeta) GetStringTable() []string

func (*BlockMeta) GetTenant added in v1.1.0 

func (x *BlockMeta) GetTenant() int32

func (*BlockMeta) MarshalToSizedBufferVT 

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

func (*BlockMeta) MarshalToVT 

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

func (*BlockMeta) MarshalVT 

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

func (*BlockMeta) ProtoMessage 

func (*BlockMeta) ProtoMessage()

func (*BlockMeta) ProtoReflect 

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

func (*BlockMeta) Reset 

func (x *BlockMeta) Reset()

func (*BlockMeta) SizeVT 

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

func (*BlockMeta) String 

func (x *BlockMeta) String() string

func (*BlockMeta) UnmarshalVT 

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

type BlockTombstones added in v1.1.0 

type BlockTombstones struct {
	Name            string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Shard           uint32   `protobuf:"varint,2,opt,name=shard,proto3" json:"shard,omitempty"`
	Tenant          string   `protobuf:"bytes,3,opt,name=tenant,proto3" json:"tenant,omitempty"`
	CompactionLevel uint32   `protobuf:"varint,4,opt,name=compaction_level,json=compactionLevel,proto3" json:"compaction_level,omitempty"`
	Blocks          []string `protobuf:"bytes,5,rep,name=blocks,proto3" json:"blocks,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockTombstones) CloneMessageVT added in v1.1.0 

func (m *BlockTombstones) CloneMessageVT() proto.Message

func (*BlockTombstones) CloneVT added in v1.1.0 

func (m *BlockTombstones) CloneVT() *BlockTombstones

func (*BlockTombstones) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use BlockTombstones.ProtoReflect.Descriptor instead.

func (*BlockTombstones) EqualMessageVT added in v1.1.0 

func (this *BlockTombstones) EqualMessageVT(thatMsg proto.Message) bool

func (*BlockTombstones) EqualVT added in v1.1.0 

func (this *BlockTombstones) EqualVT(that *BlockTombstones) bool

func (*BlockTombstones) GetBlocks added in v1.1.0 

func (x *BlockTombstones) GetBlocks() []string

func (*BlockTombstones) GetCompactionLevel added in v1.1.0 

func (x *BlockTombstones) GetCompactionLevel() uint32

func (*BlockTombstones) GetName added in v1.1.0 

func (x *BlockTombstones) GetName() string

func (*BlockTombstones) GetShard added in v1.1.0 

func (x *BlockTombstones) GetShard() uint32

func (*BlockTombstones) GetTenant added in v1.1.0 

func (x *BlockTombstones) GetTenant() string

func (*BlockTombstones) MarshalToSizedBufferVT added in v1.1.0 

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

func (*BlockTombstones) MarshalToVT added in v1.1.0 

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

func (*BlockTombstones) MarshalVT added in v1.1.0 

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

func (*BlockTombstones) ProtoMessage added in v1.1.0 

func (*BlockTombstones) ProtoMessage()

func (*BlockTombstones) ProtoReflect added in v1.1.0 

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

func (*BlockTombstones) Reset added in v1.1.0 

func (x *BlockTombstones) Reset()

func (*BlockTombstones) SizeVT added in v1.1.0 

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

func (*BlockTombstones) String added in v1.1.0 

func (x *BlockTombstones) String() string

func (*BlockTombstones) UnmarshalVT added in v1.1.0 

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

type CompactedBlocks added in v1.1.0 

type CompactedBlocks struct {
	SourceBlocks *BlockList   `protobuf:"bytes,1,opt,name=source_blocks,json=sourceBlocks,proto3" json:"source_blocks,omitempty"`
	NewBlocks    []*BlockMeta `protobuf:"bytes,2,rep,name=new_blocks,json=newBlocks,proto3" json:"new_blocks,omitempty"`
	// contains filtered or unexported fields
}

func (*CompactedBlocks) CloneMessageVT added in v1.1.0 

func (m *CompactedBlocks) CloneMessageVT() proto.Message

func (*CompactedBlocks) CloneVT added in v1.1.0 

func (m *CompactedBlocks) CloneVT() *CompactedBlocks

func (*CompactedBlocks) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use CompactedBlocks.ProtoReflect.Descriptor instead.

func (*CompactedBlocks) EqualMessageVT added in v1.1.0 

func (this *CompactedBlocks) EqualMessageVT(thatMsg proto.Message) bool

func (*CompactedBlocks) EqualVT added in v1.1.0 

func (this *CompactedBlocks) EqualVT(that *CompactedBlocks) bool

func (*CompactedBlocks) GetNewBlocks added in v1.1.0 

func (x *CompactedBlocks) GetNewBlocks() []*BlockMeta

func (*CompactedBlocks) GetSourceBlocks added in v1.1.0 

func (x *CompactedBlocks) GetSourceBlocks() *BlockList

func (*CompactedBlocks) MarshalToSizedBufferVT added in v1.1.0 

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

func (*CompactedBlocks) MarshalToVT added in v1.1.0 

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

func (*CompactedBlocks) MarshalVT added in v1.1.0 

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

func (*CompactedBlocks) ProtoMessage added in v1.1.0 

func (*CompactedBlocks) ProtoMessage()

func (*CompactedBlocks) ProtoReflect added in v1.1.0 

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

func (*CompactedBlocks) Reset added in v1.1.0 

func (x *CompactedBlocks) Reset()

func (*CompactedBlocks) SizeVT added in v1.1.0 

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

func (*CompactedBlocks) String added in v1.1.0 

func (x *CompactedBlocks) String() string

func (*CompactedBlocks) UnmarshalVT added in v1.1.0 

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

type CompactionJob added in v1.1.0 

type CompactionJob struct {
	Name            string        `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Shard           uint32        `protobuf:"varint,2,opt,name=shard,proto3" json:"shard,omitempty"`
	Tenant          string        `protobuf:"bytes,3,opt,name=tenant,proto3" json:"tenant,omitempty"`
	CompactionLevel uint32        `protobuf:"varint,4,opt,name=compaction_level,json=compactionLevel,proto3" json:"compaction_level,omitempty"`
	SourceBlocks    []string      `protobuf:"bytes,5,rep,name=source_blocks,json=sourceBlocks,proto3" json:"source_blocks,omitempty"`
	Tombstones      []*Tombstones `protobuf:"bytes,6,rep,name=tombstones,proto3" json:"tombstones,omitempty"`
	// contains filtered or unexported fields
}

func (*CompactionJob) CloneMessageVT added in v1.1.0 

func (m *CompactionJob) CloneMessageVT() proto.Message

func (*CompactionJob) CloneVT added in v1.1.0 

func (m *CompactionJob) CloneVT() *CompactionJob

func (*CompactionJob) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use CompactionJob.ProtoReflect.Descriptor instead.

func (*CompactionJob) EqualMessageVT added in v1.1.0 

func (this *CompactionJob) EqualMessageVT(thatMsg proto.Message) bool

func (*CompactionJob) EqualVT added in v1.1.0 

func (this *CompactionJob) EqualVT(that *CompactionJob) bool

func (*CompactionJob) GetCompactionLevel added in v1.1.0 

func (x *CompactionJob) GetCompactionLevel() uint32

func (*CompactionJob) GetName added in v1.1.0 

func (x *CompactionJob) GetName() string

func (*CompactionJob) GetShard added in v1.1.0 

func (x *CompactionJob) GetShard() uint32

func (*CompactionJob) GetSourceBlocks added in v1.1.0 

func (x *CompactionJob) GetSourceBlocks() []string

func (*CompactionJob) GetTenant added in v1.1.0 

func (x *CompactionJob) GetTenant() string

func (*CompactionJob) GetTombstones added in v1.1.0 

func (x *CompactionJob) GetTombstones() []*Tombstones

func (*CompactionJob) MarshalToSizedBufferVT added in v1.1.0 

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

func (*CompactionJob) MarshalToVT added in v1.1.0 

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

func (*CompactionJob) MarshalVT added in v1.1.0 

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

func (*CompactionJob) ProtoMessage added in v1.1.0 

func (*CompactionJob) ProtoMessage()

func (*CompactionJob) ProtoReflect added in v1.1.0 

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

func (*CompactionJob) Reset added in v1.1.0 

func (x *CompactionJob) Reset()

func (*CompactionJob) SizeVT added in v1.1.0 

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

func (*CompactionJob) String added in v1.1.0 

func (x *CompactionJob) String() string

func (*CompactionJob) UnmarshalVT added in v1.1.0 

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

type CompactionJobAssignment added in v1.1.0 

type CompactionJobAssignment struct {
	Name           string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Token          uint64 `protobuf:"varint,2,opt,name=token,proto3" json:"token,omitempty"`
	LeaseExpiresAt int64  `protobuf:"varint,3,opt,name=lease_expires_at,json=leaseExpiresAt,proto3" json:"lease_expires_at,omitempty"`
	// contains filtered or unexported fields
}

func (*CompactionJobAssignment) CloneMessageVT added in v1.1.0 

func (m *CompactionJobAssignment) CloneMessageVT() proto.Message

func (*CompactionJobAssignment) CloneVT added in v1.1.0 

func (m *CompactionJobAssignment) CloneVT() *CompactionJobAssignment

func (*CompactionJobAssignment) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use CompactionJobAssignment.ProtoReflect.Descriptor instead.

func (*CompactionJobAssignment) EqualMessageVT added in v1.1.0 

func (this *CompactionJobAssignment) EqualMessageVT(thatMsg proto.Message) bool

func (*CompactionJobAssignment) EqualVT added in v1.1.0 

func (this *CompactionJobAssignment) EqualVT(that *CompactionJobAssignment) bool

func (*CompactionJobAssignment) GetLeaseExpiresAt added in v1.1.0 

func (x *CompactionJobAssignment) GetLeaseExpiresAt() int64

func (*CompactionJobAssignment) GetName added in v1.1.0 

func (x *CompactionJobAssignment) GetName() string

func (*CompactionJobAssignment) GetToken added in v1.1.0 

func (x *CompactionJobAssignment) GetToken() uint64

func (*CompactionJobAssignment) MarshalToSizedBufferVT added in v1.1.0 

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

func (*CompactionJobAssignment) MarshalToVT added in v1.1.0 

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

func (*CompactionJobAssignment) MarshalVT added in v1.1.0 

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

func (*CompactionJobAssignment) ProtoMessage added in v1.1.0 

func (*CompactionJobAssignment) ProtoMessage()

func (*CompactionJobAssignment) ProtoReflect added in v1.1.0 

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

func (*CompactionJobAssignment) Reset added in v1.1.0 

func (x *CompactionJobAssignment) Reset()

func (*CompactionJobAssignment) SizeVT added in v1.1.0 

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

func (*CompactionJobAssignment) String added in v1.1.0 

func (x *CompactionJobAssignment) String() string

func (*CompactionJobAssignment) UnmarshalVT added in v1.1.0 

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

type CompactionJobStatus added in v1.1.0 

type CompactionJobStatus int32
const (
	CompactionJobStatus_COMPACTION_STATUS_UNSPECIFIED CompactionJobStatus = 0
	CompactionJobStatus_COMPACTION_STATUS_IN_PROGRESS CompactionJobStatus = 1
	CompactionJobStatus_COMPACTION_STATUS_SUCCESS     CompactionJobStatus = 2
)

func (CompactionJobStatus) Descriptor added in v1.1.0 

func (CompactionJobStatus) Descriptor() protoreflect.EnumDescriptor

func (CompactionJobStatus) Enum added in v1.1.0 

func (x CompactionJobStatus) Enum() *CompactionJobStatus

func (CompactionJobStatus) EnumDescriptor deprecated added in v1.1.0 

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

Deprecated: Use CompactionJobStatus.Descriptor instead.

func (CompactionJobStatus) Number added in v1.1.0 

func (x CompactionJobStatus) Number() protoreflect.EnumNumber

func (CompactionJobStatus) String added in v1.1.0 

func (x CompactionJobStatus) String() string

func (CompactionJobStatus) Type added in v1.1.0 

func (CompactionJobStatus) Type() protoreflect.EnumType

type CompactionJobStatusUpdate added in v1.1.0 

type CompactionJobStatusUpdate struct {
	Name   string              `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Token  uint64              `protobuf:"varint,2,opt,name=token,proto3" json:"token,omitempty"`
	Status CompactionJobStatus `protobuf:"varint,3,opt,name=status,proto3,enum=metastore.v1.CompactionJobStatus" json:"status,omitempty"`
	// Only present if the job completed successfully.
	CompactedBlocks *CompactedBlocks `protobuf:"bytes,4,opt,name=compacted_blocks,json=compactedBlocks,proto3" json:"compacted_blocks,omitempty"`
	// contains filtered or unexported fields
}

func (*CompactionJobStatusUpdate) CloneMessageVT added in v1.1.0 

func (m *CompactionJobStatusUpdate) CloneMessageVT() proto.Message

func (*CompactionJobStatusUpdate) CloneVT added in v1.1.0 

func (m *CompactionJobStatusUpdate) CloneVT() *CompactionJobStatusUpdate

func (*CompactionJobStatusUpdate) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use CompactionJobStatusUpdate.ProtoReflect.Descriptor instead.

func (*CompactionJobStatusUpdate) EqualMessageVT added in v1.1.0 

func (this *CompactionJobStatusUpdate) EqualMessageVT(thatMsg proto.Message) bool

func (*CompactionJobStatusUpdate) EqualVT added in v1.1.0 

func (this *CompactionJobStatusUpdate) EqualVT(that *CompactionJobStatusUpdate) bool

func (*CompactionJobStatusUpdate) GetCompactedBlocks added in v1.1.0 

func (x *CompactionJobStatusUpdate) GetCompactedBlocks() *CompactedBlocks

func (*CompactionJobStatusUpdate) GetName added in v1.1.0 

func (x *CompactionJobStatusUpdate) GetName() string

func (*CompactionJobStatusUpdate) GetStatus added in v1.1.0 

func (x *CompactionJobStatusUpdate) GetStatus() CompactionJobStatus

func (*CompactionJobStatusUpdate) GetToken added in v1.1.0 

func (x *CompactionJobStatusUpdate) GetToken() uint64

func (*CompactionJobStatusUpdate) MarshalToSizedBufferVT added in v1.1.0 

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

func (*CompactionJobStatusUpdate) MarshalToVT added in v1.1.0 

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

func (*CompactionJobStatusUpdate) MarshalVT added in v1.1.0 

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

func (*CompactionJobStatusUpdate) ProtoMessage added in v1.1.0 

func (*CompactionJobStatusUpdate) ProtoMessage()

func (*CompactionJobStatusUpdate) ProtoReflect added in v1.1.0 

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

func (*CompactionJobStatusUpdate) Reset added in v1.1.0 

func (x *CompactionJobStatusUpdate) Reset()

func (*CompactionJobStatusUpdate) SizeVT added in v1.1.0 

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

func (*CompactionJobStatusUpdate) String added in v1.1.0 

func (x *CompactionJobStatusUpdate) String() string

func (*CompactionJobStatusUpdate) UnmarshalVT added in v1.1.0 

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

type CompactionServiceClient added in v1.1.0 

type CompactionServiceClient interface {
	// Used to both retrieve jobs and update the jobs status at the same time.
	PollCompactionJobs(ctx context.Context, in *PollCompactionJobsRequest, opts ...grpc.CallOption) (*PollCompactionJobsResponse, error)
}

CompactionServiceClient is the client API for CompactionService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewCompactionServiceClient added in v1.1.0 

func NewCompactionServiceClient(cc grpc.ClientConnInterface) CompactionServiceClient

type CompactionServiceServer added in v1.1.0 

type CompactionServiceServer interface {
	// Used to both retrieve jobs and update the jobs status at the same time.
	PollCompactionJobs(context.Context, *PollCompactionJobsRequest) (*PollCompactionJobsResponse, error)
	// contains filtered or unexported methods
}

CompactionServiceServer is the server API for CompactionService service. All implementations must embed UnimplementedCompactionServiceServer for forward compatibility

type Dataset 

type Dataset struct {
	Tenant  int32 `protobuf:"varint,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Name    int32 `protobuf:"varint,2,opt,name=name,proto3" json:"name,omitempty"`
	MinTime int64 `protobuf:"varint,3,opt,name=min_time,json=minTime,proto3" json:"min_time,omitempty"`
	MaxTime int64 `protobuf:"varint,4,opt,name=max_time,json=maxTime,proto3" json:"max_time,omitempty"`
	// Table of contents lists data sections within the tenant
	// service region. The offsets are absolute.
	//
	// The interpretation of the table of contents is specific
	// to the metadata format version. By default, the sections are:
	//   - 0: profiles.parquet
	//   - 1: index.tsdb
	//   - 2: symbols.symdb
	TableOfContents []uint64 `protobuf:"varint,5,rep,packed,name=table_of_contents,json=tableOfContents,proto3" json:"table_of_contents,omitempty"`
	// Size of the dataset in bytes.
	Size uint64 `protobuf:"varint,6,opt,name=size,proto3" json:"size,omitempty"`
	// Length prefixed label key-value pairs.
	//
	// Multiple label sets can be associated with a dataset to denote relationships
	// across multiple dimensions. For example, each dataset currently stores data
	// for multiple profile types:
	//   - service_name=A, profile_type=cpu
	//   - service_name=A, profile_type=memory
	//
	// Labels are primarily used to filter datasets based on their attributes.
	// For instance, labels can be used to select datasets containing a specific
	// service.
	//
	// The set of attributes is extensible and can grow over time. For example, a
	// namespace attribute could be added to datasets:
	//   - service_name=A, profile_type=cpu
	//   - service_name=A, profile_type=memory
	//   - service_name=B, namespace=N, profile_type=cpu
	//   - service_name=B, namespace=N, profile_type=memory
	//   - service_name=C, namespace=N, profile_type=cpu
	//   - service_name=C, namespace=N, profile_type=memory
	//
	// This organization enables querying datasets by namespace without accessing
	// the block contents, which significantly improves performance.
	//
	// Metadata labels are not required to be included in the block's TSDB index
	// and may be orthogonal to the data dimensions. Generally, attributes serve
	// two primary purposes:
	//   - To create data scopes that span multiple service, reducing the need to
	//     scan the entire set of block satisfying the query expression, i.e.,
	//     the time range and tenant ID.
	//   - To provide additional information about datasets without altering the
	//     storage schema or access methods.
	//
	// For example, this approach can support cost attribution or similar breakdown
	// analyses. It can also handle data dependencies (e.g., links to external data)
	// using labels.
	//
	// The cardinality of the labels is expected to remain relatively low (fewer
	// than a million unique combinations globally). However, this depends on the
	// metadata storage system.
	//
	// Metadata labels are represented as a slice of `int32` values that refer to
	// strings in the metadata entry's string table. The slice is a sequence of
	// length-prefixed key-value (KV) pairs:
	//
	// len(2) | k1 | v1 | k2 | v2 | len(3) | k1 | v3 | k2 | v4 | k3 | v5
	//
	// The order of KV pairs is not defined. The format is optimized for indexing
	// rather than querying, and it is not intended to be the most space-efficient
	// representation. Since entries are supposed to be indexed, the redundancy of
	// denormalized relationships is not a concern.
	Labels []int32 `protobuf:"varint,8,rep,packed,name=labels,proto3" json:"labels,omitempty"`
	// contains filtered or unexported fields
}

func (*Dataset) CloneMessageVT 

func (m *Dataset) CloneMessageVT() proto.Message

func (*Dataset) CloneVT 

func (m *Dataset) CloneVT() *Dataset

func (*Dataset) Descriptor deprecated 

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

Deprecated: Use Dataset.ProtoReflect.Descriptor instead.

func (*Dataset) EqualMessageVT 

func (this *Dataset) EqualMessageVT(thatMsg proto.Message) bool

func (*Dataset) EqualVT 

func (this *Dataset) EqualVT(that *Dataset) bool

func (*Dataset) GetLabels 

func (x *Dataset) GetLabels() []int32

func (*Dataset) GetMaxTime 

func (x *Dataset) GetMaxTime() int64

func (*Dataset) GetMinTime 

func (x *Dataset) GetMinTime() int64

func (*Dataset) GetName 

func (x *Dataset) GetName() int32

func (*Dataset) GetSize 

func (x *Dataset) GetSize() uint64

func (*Dataset) GetTableOfContents 

func (x *Dataset) GetTableOfContents() []uint64

func (*Dataset) GetTenant added in v1.1.0 

func (x *Dataset) GetTenant() int32

func (*Dataset) MarshalToSizedBufferVT 

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

func (*Dataset) MarshalToVT 

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

func (*Dataset) MarshalVT 

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

func (*Dataset) ProtoMessage 

func (*Dataset) ProtoMessage()

func (*Dataset) ProtoReflect 

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

func (*Dataset) Reset 

func (x *Dataset) Reset()

func (*Dataset) SizeVT 

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

func (*Dataset) String 

func (x *Dataset) String() string

func (*Dataset) UnmarshalVT 

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

type DeleteTenantRequest added in v1.1.0 

type DeleteTenantRequest struct {
	TenantId string `protobuf:"bytes,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTenantRequest) CloneMessageVT added in v1.1.0 

func (m *DeleteTenantRequest) CloneMessageVT() proto.Message

func (*DeleteTenantRequest) CloneVT added in v1.1.0 

func (m *DeleteTenantRequest) CloneVT() *DeleteTenantRequest

func (*DeleteTenantRequest) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use DeleteTenantRequest.ProtoReflect.Descriptor instead.

func (*DeleteTenantRequest) EqualMessageVT added in v1.1.0 

func (this *DeleteTenantRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*DeleteTenantRequest) EqualVT added in v1.1.0 

func (this *DeleteTenantRequest) EqualVT(that *DeleteTenantRequest) bool

func (*DeleteTenantRequest) GetTenantId added in v1.1.0 

func (x *DeleteTenantRequest) GetTenantId() string

func (*DeleteTenantRequest) MarshalToSizedBufferVT added in v1.1.0 

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

func (*DeleteTenantRequest) MarshalToVT added in v1.1.0 

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

func (*DeleteTenantRequest) MarshalVT added in v1.1.0 

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

func (*DeleteTenantRequest) ProtoMessage added in v1.1.0 

func (*DeleteTenantRequest) ProtoMessage()

func (*DeleteTenantRequest) ProtoReflect added in v1.1.0 

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

func (*DeleteTenantRequest) Reset added in v1.1.0 

func (x *DeleteTenantRequest) Reset()

func (*DeleteTenantRequest) SizeVT added in v1.1.0 

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

func (*DeleteTenantRequest) String added in v1.1.0 

func (x *DeleteTenantRequest) String() string

func (*DeleteTenantRequest) UnmarshalVT added in v1.1.0 

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

type DeleteTenantResponse added in v1.1.0 

type DeleteTenantResponse struct {
	// contains filtered or unexported fields
}

func (*DeleteTenantResponse) CloneMessageVT added in v1.1.0 

func (m *DeleteTenantResponse) CloneMessageVT() proto.Message

func (*DeleteTenantResponse) CloneVT added in v1.1.0 

func (m *DeleteTenantResponse) CloneVT() *DeleteTenantResponse

func (*DeleteTenantResponse) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use DeleteTenantResponse.ProtoReflect.Descriptor instead.

func (*DeleteTenantResponse) EqualMessageVT added in v1.1.0 

func (this *DeleteTenantResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*DeleteTenantResponse) EqualVT added in v1.1.0 

func (this *DeleteTenantResponse) EqualVT(that *DeleteTenantResponse) bool

func (*DeleteTenantResponse) MarshalToSizedBufferVT added in v1.1.0 

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

func (*DeleteTenantResponse) MarshalToVT added in v1.1.0 

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

func (*DeleteTenantResponse) MarshalVT added in v1.1.0 

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

func (*DeleteTenantResponse) ProtoMessage added in v1.1.0 

func (*DeleteTenantResponse) ProtoMessage()

func (*DeleteTenantResponse) ProtoReflect added in v1.1.0 

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

func (*DeleteTenantResponse) Reset added in v1.1.0 

func (x *DeleteTenantResponse) Reset()

func (*DeleteTenantResponse) SizeVT added in v1.1.0 

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

func (*DeleteTenantResponse) String added in v1.1.0 

func (x *DeleteTenantResponse) String() string

func (*DeleteTenantResponse) UnmarshalVT added in v1.1.0 

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

type GetBlockMetadataRequest added in v1.1.0 

type GetBlockMetadataRequest struct {
	Blocks *BlockList `protobuf:"bytes,1,opt,name=blocks,proto3" json:"blocks,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBlockMetadataRequest) CloneMessageVT added in v1.1.0 

func (m *GetBlockMetadataRequest) CloneMessageVT() proto.Message

func (*GetBlockMetadataRequest) CloneVT added in v1.1.0 

func (m *GetBlockMetadataRequest) CloneVT() *GetBlockMetadataRequest

func (*GetBlockMetadataRequest) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use GetBlockMetadataRequest.ProtoReflect.Descriptor instead.

func (*GetBlockMetadataRequest) EqualMessageVT added in v1.1.0 

func (this *GetBlockMetadataRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*GetBlockMetadataRequest) EqualVT added in v1.1.0 

func (this *GetBlockMetadataRequest) EqualVT(that *GetBlockMetadataRequest) bool

func (*GetBlockMetadataRequest) GetBlocks added in v1.1.0 

func (x *GetBlockMetadataRequest) GetBlocks() *BlockList

func (*GetBlockMetadataRequest) MarshalToSizedBufferVT added in v1.1.0 

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

func (*GetBlockMetadataRequest) MarshalToVT added in v1.1.0 

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

func (*GetBlockMetadataRequest) MarshalVT added in v1.1.0 

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

func (*GetBlockMetadataRequest) ProtoMessage added in v1.1.0 

func (*GetBlockMetadataRequest) ProtoMessage()

func (*GetBlockMetadataRequest) ProtoReflect added in v1.1.0 

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

func (*GetBlockMetadataRequest) Reset added in v1.1.0 

func (x *GetBlockMetadataRequest) Reset()

func (*GetBlockMetadataRequest) SizeVT added in v1.1.0 

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

func (*GetBlockMetadataRequest) String added in v1.1.0 

func (x *GetBlockMetadataRequest) String() string

func (*GetBlockMetadataRequest) UnmarshalVT added in v1.1.0 

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

type GetBlockMetadataResponse added in v1.1.0 

type GetBlockMetadataResponse struct {
	Blocks []*BlockMeta `protobuf:"bytes,1,rep,name=blocks,proto3" json:"blocks,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBlockMetadataResponse) CloneMessageVT added in v1.1.0 

func (m *GetBlockMetadataResponse) CloneMessageVT() proto.Message

func (*GetBlockMetadataResponse) CloneVT added in v1.1.0 

func (m *GetBlockMetadataResponse) CloneVT() *GetBlockMetadataResponse

func (*GetBlockMetadataResponse) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use GetBlockMetadataResponse.ProtoReflect.Descriptor instead.

func (*GetBlockMetadataResponse) EqualMessageVT added in v1.1.0 

func (this *GetBlockMetadataResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*GetBlockMetadataResponse) EqualVT added in v1.1.0 

func (this *GetBlockMetadataResponse) EqualVT(that *GetBlockMetadataResponse) bool

func (*GetBlockMetadataResponse) GetBlocks added in v1.1.0 

func (x *GetBlockMetadataResponse) GetBlocks() []*BlockMeta

func (*GetBlockMetadataResponse) MarshalToSizedBufferVT added in v1.1.0 

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

func (*GetBlockMetadataResponse) MarshalToVT added in v1.1.0 

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

func (*GetBlockMetadataResponse) MarshalVT added in v1.1.0 

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

func (*GetBlockMetadataResponse) ProtoMessage added in v1.1.0 

func (*GetBlockMetadataResponse) ProtoMessage()

func (*GetBlockMetadataResponse) ProtoReflect added in v1.1.0 

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

func (*GetBlockMetadataResponse) Reset added in v1.1.0 

func (x *GetBlockMetadataResponse) Reset()

func (*GetBlockMetadataResponse) SizeVT added in v1.1.0 

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

func (*GetBlockMetadataResponse) String added in v1.1.0 

func (x *GetBlockMetadataResponse) String() string

func (*GetBlockMetadataResponse) UnmarshalVT added in v1.1.0 

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

type GetTenantRequest added in v1.1.0 

type GetTenantRequest struct {
	TenantId string `protobuf:"bytes,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTenantRequest) CloneMessageVT added in v1.1.0 

func (m *GetTenantRequest) CloneMessageVT() proto.Message

func (*GetTenantRequest) CloneVT added in v1.1.0 

func (m *GetTenantRequest) CloneVT() *GetTenantRequest

func (*GetTenantRequest) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use GetTenantRequest.ProtoReflect.Descriptor instead.

func (*GetTenantRequest) EqualMessageVT added in v1.1.0 

func (this *GetTenantRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*GetTenantRequest) EqualVT added in v1.1.0 

func (this *GetTenantRequest) EqualVT(that *GetTenantRequest) bool

func (*GetTenantRequest) GetTenantId added in v1.1.0 

func (x *GetTenantRequest) GetTenantId() string

func (*GetTenantRequest) MarshalToSizedBufferVT added in v1.1.0 

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

func (*GetTenantRequest) MarshalToVT added in v1.1.0 

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

func (*GetTenantRequest) MarshalVT added in v1.1.0 

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

func (*GetTenantRequest) ProtoMessage added in v1.1.0 

func (*GetTenantRequest) ProtoMessage()

func (*GetTenantRequest) ProtoReflect added in v1.1.0 

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

func (*GetTenantRequest) Reset added in v1.1.0 

func (x *GetTenantRequest) Reset()

func (*GetTenantRequest) SizeVT added in v1.1.0 

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

func (*GetTenantRequest) String added in v1.1.0 

func (x *GetTenantRequest) String() string

func (*GetTenantRequest) UnmarshalVT added in v1.1.0 

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

type GetTenantResponse added in v1.1.0 

type GetTenantResponse struct {
	Stats *TenantStats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTenantResponse) CloneMessageVT added in v1.1.0 

func (m *GetTenantResponse) CloneMessageVT() proto.Message

func (*GetTenantResponse) CloneVT added in v1.1.0 

func (m *GetTenantResponse) CloneVT() *GetTenantResponse

func (*GetTenantResponse) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use GetTenantResponse.ProtoReflect.Descriptor instead.

func (*GetTenantResponse) EqualMessageVT added in v1.1.0 

func (this *GetTenantResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*GetTenantResponse) EqualVT added in v1.1.0 

func (this *GetTenantResponse) EqualVT(that *GetTenantResponse) bool

func (*GetTenantResponse) GetStats added in v1.1.0 

func (x *GetTenantResponse) GetStats() *TenantStats

func (*GetTenantResponse) MarshalToSizedBufferVT added in v1.1.0 

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

func (*GetTenantResponse) MarshalToVT added in v1.1.0 

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

func (*GetTenantResponse) MarshalVT added in v1.1.0 

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

func (*GetTenantResponse) ProtoMessage added in v1.1.0 

func (*GetTenantResponse) ProtoMessage()

func (*GetTenantResponse) ProtoReflect added in v1.1.0 

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

func (*GetTenantResponse) Reset added in v1.1.0 

func (x *GetTenantResponse) Reset()

func (*GetTenantResponse) SizeVT added in v1.1.0 

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

func (*GetTenantResponse) String added in v1.1.0 

func (x *GetTenantResponse) String() string

func (*GetTenantResponse) UnmarshalVT added in v1.1.0 

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

type IndexServiceClient added in v1.1.0 

type IndexServiceClient interface {
	AddBlock(ctx context.Context, in *AddBlockRequest, opts ...grpc.CallOption) (*AddBlockResponse, error)
	GetBlockMetadata(ctx context.Context, in *GetBlockMetadataRequest, opts ...grpc.CallOption) (*GetBlockMetadataResponse, error)
}

IndexServiceClient is the client API for IndexService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewIndexServiceClient added in v1.1.0 

func NewIndexServiceClient(cc grpc.ClientConnInterface) IndexServiceClient

type IndexServiceServer added in v1.1.0 

type IndexServiceServer interface {
	AddBlock(context.Context, *AddBlockRequest) (*AddBlockResponse, error)
	GetBlockMetadata(context.Context, *GetBlockMetadataRequest) (*GetBlockMetadataResponse, error)
	// contains filtered or unexported methods
}

IndexServiceServer is the server API for IndexService service. All implementations must embed UnimplementedIndexServiceServer for forward compatibility

type MetadataQueryServiceClient added in v1.1.0 

type MetadataQueryServiceClient interface {
	QueryMetadata(ctx context.Context, in *QueryMetadataRequest, opts ...grpc.CallOption) (*QueryMetadataResponse, error)
	QueryMetadataLabels(ctx context.Context, in *QueryMetadataLabelsRequest, opts ...grpc.CallOption) (*QueryMetadataLabelsResponse, error)
}

MetadataQueryServiceClient is the client API for MetadataQueryService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewMetadataQueryServiceClient added in v1.1.0 

func NewMetadataQueryServiceClient(cc grpc.ClientConnInterface) MetadataQueryServiceClient

type MetadataQueryServiceServer added in v1.1.0 

type MetadataQueryServiceServer interface {
	QueryMetadata(context.Context, *QueryMetadataRequest) (*QueryMetadataResponse, error)
	QueryMetadataLabels(context.Context, *QueryMetadataLabelsRequest) (*QueryMetadataLabelsResponse, error)
	// contains filtered or unexported methods
}

MetadataQueryServiceServer is the server API for MetadataQueryService service. All implementations must embed UnimplementedMetadataQueryServiceServer for forward compatibility

type PollCompactionJobsRequest added in v1.1.0 

type PollCompactionJobsRequest struct {
	StatusUpdates []*CompactionJobStatusUpdate `protobuf:"bytes,1,rep,name=status_updates,json=statusUpdates,proto3" json:"status_updates,omitempty"`
	// How many new jobs a worker can be assigned to.
	JobCapacity uint32 `protobuf:"varint,2,opt,name=job_capacity,json=jobCapacity,proto3" json:"job_capacity,omitempty"`
	// contains filtered or unexported fields
}

func (*PollCompactionJobsRequest) CloneMessageVT added in v1.1.0 

func (m *PollCompactionJobsRequest) CloneMessageVT() proto.Message

func (*PollCompactionJobsRequest) CloneVT added in v1.1.0 

func (m *PollCompactionJobsRequest) CloneVT() *PollCompactionJobsRequest

func (*PollCompactionJobsRequest) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use PollCompactionJobsRequest.ProtoReflect.Descriptor instead.

func (*PollCompactionJobsRequest) EqualMessageVT added in v1.1.0 

func (this *PollCompactionJobsRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*PollCompactionJobsRequest) EqualVT added in v1.1.0 

func (this *PollCompactionJobsRequest) EqualVT(that *PollCompactionJobsRequest) bool

func (*PollCompactionJobsRequest) GetJobCapacity added in v1.1.0 

func (x *PollCompactionJobsRequest) GetJobCapacity() uint32

func (*PollCompactionJobsRequest) GetStatusUpdates added in v1.1.0 

func (x *PollCompactionJobsRequest) GetStatusUpdates() []*CompactionJobStatusUpdate

func (*PollCompactionJobsRequest) MarshalToSizedBufferVT added in v1.1.0 

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

func (*PollCompactionJobsRequest) MarshalToVT added in v1.1.0 

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

func (*PollCompactionJobsRequest) MarshalVT added in v1.1.0 

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

func (*PollCompactionJobsRequest) ProtoMessage added in v1.1.0 

func (*PollCompactionJobsRequest) ProtoMessage()

func (*PollCompactionJobsRequest) ProtoReflect added in v1.1.0 

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

func (*PollCompactionJobsRequest) Reset added in v1.1.0 

func (x *PollCompactionJobsRequest) Reset()

func (*PollCompactionJobsRequest) SizeVT added in v1.1.0 

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

func (*PollCompactionJobsRequest) String added in v1.1.0 

func (x *PollCompactionJobsRequest) String() string

func (*PollCompactionJobsRequest) UnmarshalVT added in v1.1.0 

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

type PollCompactionJobsResponse added in v1.1.0 

type PollCompactionJobsResponse struct {
	CompactionJobs []*CompactionJob           `protobuf:"bytes,1,rep,name=compaction_jobs,json=compactionJobs,proto3" json:"compaction_jobs,omitempty"`
	Assignments    []*CompactionJobAssignment `protobuf:"bytes,2,rep,name=assignments,proto3" json:"assignments,omitempty"`
	// contains filtered or unexported fields
}

func (*PollCompactionJobsResponse) CloneMessageVT added in v1.1.0 

func (m *PollCompactionJobsResponse) CloneMessageVT() proto.Message

func (*PollCompactionJobsResponse) CloneVT added in v1.1.0 

func (m *PollCompactionJobsResponse) CloneVT() *PollCompactionJobsResponse

func (*PollCompactionJobsResponse) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use PollCompactionJobsResponse.ProtoReflect.Descriptor instead.

func (*PollCompactionJobsResponse) EqualMessageVT added in v1.1.0 

func (this *PollCompactionJobsResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*PollCompactionJobsResponse) EqualVT added in v1.1.0 

func (this *PollCompactionJobsResponse) EqualVT(that *PollCompactionJobsResponse) bool

func (*PollCompactionJobsResponse) GetAssignments added in v1.1.0 

func (x *PollCompactionJobsResponse) GetAssignments() []*CompactionJobAssignment

func (*PollCompactionJobsResponse) GetCompactionJobs added in v1.1.0 

func (x *PollCompactionJobsResponse) GetCompactionJobs() []*CompactionJob

func (*PollCompactionJobsResponse) MarshalToSizedBufferVT added in v1.1.0 

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

func (*PollCompactionJobsResponse) MarshalToVT added in v1.1.0 

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

func (*PollCompactionJobsResponse) MarshalVT added in v1.1.0 

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

func (*PollCompactionJobsResponse) ProtoMessage added in v1.1.0 

func (*PollCompactionJobsResponse) ProtoMessage()

func (*PollCompactionJobsResponse) ProtoReflect added in v1.1.0 

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

func (*PollCompactionJobsResponse) Reset added in v1.1.0 

func (x *PollCompactionJobsResponse) Reset()

func (*PollCompactionJobsResponse) SizeVT added in v1.1.0 

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

func (*PollCompactionJobsResponse) String added in v1.1.0 

func (x *PollCompactionJobsResponse) String() string

func (*PollCompactionJobsResponse) UnmarshalVT added in v1.1.0 

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

type QueryMetadataLabelsRequest added in v1.1.0 

type QueryMetadataLabelsRequest struct {
	TenantId  []string `protobuf:"bytes,1,rep,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	StartTime int64    `protobuf:"varint,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime   int64    `protobuf:"varint,3,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Query     string   `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"`
	Labels    []string `protobuf:"bytes,5,rep,name=labels,proto3" json:"labels,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryMetadataLabelsRequest) CloneMessageVT added in v1.1.0 

func (m *QueryMetadataLabelsRequest) CloneMessageVT() proto.Message

func (*QueryMetadataLabelsRequest) CloneVT added in v1.1.0 

func (m *QueryMetadataLabelsRequest) CloneVT() *QueryMetadataLabelsRequest

func (*QueryMetadataLabelsRequest) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use QueryMetadataLabelsRequest.ProtoReflect.Descriptor instead.

func (*QueryMetadataLabelsRequest) EqualMessageVT added in v1.1.0 

func (this *QueryMetadataLabelsRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*QueryMetadataLabelsRequest) EqualVT added in v1.1.0 

func (this *QueryMetadataLabelsRequest) EqualVT(that *QueryMetadataLabelsRequest) bool

func (*QueryMetadataLabelsRequest) GetEndTime added in v1.1.0 

func (x *QueryMetadataLabelsRequest) GetEndTime() int64

func (*QueryMetadataLabelsRequest) GetLabels added in v1.1.0 

func (x *QueryMetadataLabelsRequest) GetLabels() []string

func (*QueryMetadataLabelsRequest) GetQuery added in v1.1.0 

func (x *QueryMetadataLabelsRequest) GetQuery() string

func (*QueryMetadataLabelsRequest) GetStartTime added in v1.1.0 

func (x *QueryMetadataLabelsRequest) GetStartTime() int64

func (*QueryMetadataLabelsRequest) GetTenantId added in v1.1.0 

func (x *QueryMetadataLabelsRequest) GetTenantId() []string

func (*QueryMetadataLabelsRequest) MarshalToSizedBufferVT added in v1.1.0 

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

func (*QueryMetadataLabelsRequest) MarshalToVT added in v1.1.0 

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

func (*QueryMetadataLabelsRequest) MarshalVT added in v1.1.0 

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

func (*QueryMetadataLabelsRequest) ProtoMessage added in v1.1.0 

func (*QueryMetadataLabelsRequest) ProtoMessage()

func (*QueryMetadataLabelsRequest) ProtoReflect added in v1.1.0 

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

func (*QueryMetadataLabelsRequest) Reset added in v1.1.0 

func (x *QueryMetadataLabelsRequest) Reset()

func (*QueryMetadataLabelsRequest) SizeVT added in v1.1.0 

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

func (*QueryMetadataLabelsRequest) String added in v1.1.0 

func (x *QueryMetadataLabelsRequest) String() string

func (*QueryMetadataLabelsRequest) UnmarshalVT added in v1.1.0 

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

type QueryMetadataLabelsResponse added in v1.1.0 

type QueryMetadataLabelsResponse struct {
	Labels []*v1.Labels `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryMetadataLabelsResponse) CloneMessageVT added in v1.1.0 

func (m *QueryMetadataLabelsResponse) CloneMessageVT() proto.Message

func (*QueryMetadataLabelsResponse) CloneVT added in v1.1.0 

func (m *QueryMetadataLabelsResponse) CloneVT() *QueryMetadataLabelsResponse

func (*QueryMetadataLabelsResponse) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use QueryMetadataLabelsResponse.ProtoReflect.Descriptor instead.

func (*QueryMetadataLabelsResponse) EqualMessageVT added in v1.1.0 

func (this *QueryMetadataLabelsResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*QueryMetadataLabelsResponse) EqualVT added in v1.1.0 

func (this *QueryMetadataLabelsResponse) EqualVT(that *QueryMetadataLabelsResponse) bool

func (*QueryMetadataLabelsResponse) GetLabels added in v1.1.0 

func (x *QueryMetadataLabelsResponse) GetLabels() []*v1.Labels

func (*QueryMetadataLabelsResponse) MarshalToSizedBufferVT added in v1.1.0 

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

func (*QueryMetadataLabelsResponse) MarshalToVT added in v1.1.0 

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

func (*QueryMetadataLabelsResponse) MarshalVT added in v1.1.0 

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

func (*QueryMetadataLabelsResponse) ProtoMessage added in v1.1.0 

func (*QueryMetadataLabelsResponse) ProtoMessage()

func (*QueryMetadataLabelsResponse) ProtoReflect added in v1.1.0 

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

func (*QueryMetadataLabelsResponse) Reset added in v1.1.0 

func (x *QueryMetadataLabelsResponse) Reset()

func (*QueryMetadataLabelsResponse) SizeVT added in v1.1.0 

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

func (*QueryMetadataLabelsResponse) String added in v1.1.0 

func (x *QueryMetadataLabelsResponse) String() string

func (*QueryMetadataLabelsResponse) UnmarshalVT added in v1.1.0 

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

type QueryMetadataRequest 

type QueryMetadataRequest struct {
	TenantId  []string `protobuf:"bytes,1,rep,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	StartTime int64    `protobuf:"varint,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime   int64    `protobuf:"varint,3,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Query     string   `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryMetadataRequest) CloneMessageVT 

func (m *QueryMetadataRequest) CloneMessageVT() proto.Message

func (*QueryMetadataRequest) CloneVT 

func (m *QueryMetadataRequest) CloneVT() *QueryMetadataRequest

func (*QueryMetadataRequest) Descriptor deprecated 

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

Deprecated: Use QueryMetadataRequest.ProtoReflect.Descriptor instead.

func (*QueryMetadataRequest) EqualMessageVT 

func (this *QueryMetadataRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*QueryMetadataRequest) EqualVT 

func (this *QueryMetadataRequest) EqualVT(that *QueryMetadataRequest) bool

func (*QueryMetadataRequest) GetEndTime 

func (x *QueryMetadataRequest) GetEndTime() int64

func (*QueryMetadataRequest) GetQuery 

func (x *QueryMetadataRequest) GetQuery() string

func (*QueryMetadataRequest) GetStartTime 

func (x *QueryMetadataRequest) GetStartTime() int64

func (*QueryMetadataRequest) GetTenantId 

func (x *QueryMetadataRequest) GetTenantId() []string

func (*QueryMetadataRequest) MarshalToSizedBufferVT 

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

func (*QueryMetadataRequest) MarshalToVT 

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

func (*QueryMetadataRequest) MarshalVT 

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

func (*QueryMetadataRequest) ProtoMessage 

func (*QueryMetadataRequest) ProtoMessage()

func (*QueryMetadataRequest) ProtoReflect 

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

func (*QueryMetadataRequest) Reset 

func (x *QueryMetadataRequest) Reset()

func (*QueryMetadataRequest) SizeVT 

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

func (*QueryMetadataRequest) String 

func (x *QueryMetadataRequest) String() string

func (*QueryMetadataRequest) UnmarshalVT 

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

type QueryMetadataResponse 

type QueryMetadataResponse struct {
	Blocks []*BlockMeta `protobuf:"bytes,1,rep,name=blocks,proto3" json:"blocks,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryMetadataResponse) CloneMessageVT 

func (m *QueryMetadataResponse) CloneMessageVT() proto.Message

func (*QueryMetadataResponse) CloneVT 

func (m *QueryMetadataResponse) CloneVT() *QueryMetadataResponse

func (*QueryMetadataResponse) Descriptor deprecated 

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

Deprecated: Use QueryMetadataResponse.ProtoReflect.Descriptor instead.

func (*QueryMetadataResponse) EqualMessageVT 

func (this *QueryMetadataResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*QueryMetadataResponse) EqualVT 

func (this *QueryMetadataResponse) EqualVT(that *QueryMetadataResponse) bool

func (*QueryMetadataResponse) GetBlocks 

func (x *QueryMetadataResponse) GetBlocks() []*BlockMeta

func (*QueryMetadataResponse) MarshalToSizedBufferVT 

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

func (*QueryMetadataResponse) MarshalToVT 

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

func (*QueryMetadataResponse) MarshalVT 

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

func (*QueryMetadataResponse) ProtoMessage 

func (*QueryMetadataResponse) ProtoMessage()

func (*QueryMetadataResponse) ProtoReflect 

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

func (*QueryMetadataResponse) Reset 

func (x *QueryMetadataResponse) Reset()

func (*QueryMetadataResponse) SizeVT 

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

func (*QueryMetadataResponse) String 

func (x *QueryMetadataResponse) String() string

func (*QueryMetadataResponse) UnmarshalVT 

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

type TenantServiceClient added in v1.1.0 

type TenantServiceClient interface {
	GetTenant(ctx context.Context, in *GetTenantRequest, opts ...grpc.CallOption) (*GetTenantResponse, error)
	DeleteTenant(ctx context.Context, in *DeleteTenantRequest, opts ...grpc.CallOption) (*DeleteTenantResponse, error)
}

TenantServiceClient is the client API for TenantService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTenantServiceClient added in v1.1.0 

func NewTenantServiceClient(cc grpc.ClientConnInterface) TenantServiceClient

type TenantServiceServer added in v1.1.0 

type TenantServiceServer interface {
	GetTenant(context.Context, *GetTenantRequest) (*GetTenantResponse, error)
	DeleteTenant(context.Context, *DeleteTenantRequest) (*DeleteTenantResponse, error)
	// contains filtered or unexported methods
}

TenantServiceServer is the server API for TenantService service. All implementations must embed UnimplementedTenantServiceServer for forward compatibility

type TenantStats added in v1.1.0 

type TenantStats struct {

	// Whether we received any data at any time in the past.
	DataIngested bool `protobuf:"varint,1,opt,name=data_ingested,json=dataIngested,proto3" json:"data_ingested,omitempty"`
	// Milliseconds since epoch.
	OldestProfileTime int64 `protobuf:"varint,2,opt,name=oldest_profile_time,json=oldestProfileTime,proto3" json:"oldest_profile_time,omitempty"`
	// Milliseconds since epoch.
	NewestProfileTime int64 `protobuf:"varint,3,opt,name=newest_profile_time,json=newestProfileTime,proto3" json:"newest_profile_time,omitempty"`
	// contains filtered or unexported fields
}

func (*TenantStats) CloneMessageVT added in v1.1.0 

func (m *TenantStats) CloneMessageVT() proto.Message

func (*TenantStats) CloneVT added in v1.1.0 

func (m *TenantStats) CloneVT() *TenantStats

func (*TenantStats) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use TenantStats.ProtoReflect.Descriptor instead.

func (*TenantStats) EqualMessageVT added in v1.1.0 

func (this *TenantStats) EqualMessageVT(thatMsg proto.Message) bool

func (*TenantStats) EqualVT added in v1.1.0 

func (this *TenantStats) EqualVT(that *TenantStats) bool

func (*TenantStats) GetDataIngested added in v1.1.0 

func (x *TenantStats) GetDataIngested() bool

func (*TenantStats) GetNewestProfileTime added in v1.1.0 

func (x *TenantStats) GetNewestProfileTime() int64

func (*TenantStats) GetOldestProfileTime added in v1.1.0 

func (x *TenantStats) GetOldestProfileTime() int64

func (*TenantStats) MarshalToSizedBufferVT added in v1.1.0 

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

func (*TenantStats) MarshalToVT added in v1.1.0 

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

func (*TenantStats) MarshalVT added in v1.1.0 

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

func (*TenantStats) ProtoMessage added in v1.1.0 

func (*TenantStats) ProtoMessage()

func (*TenantStats) ProtoReflect added in v1.1.0 

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

func (*TenantStats) Reset added in v1.1.0 

func (x *TenantStats) Reset()

func (*TenantStats) SizeVT added in v1.1.0 

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

func (*TenantStats) String added in v1.1.0 

func (x *TenantStats) String() string

func (*TenantStats) UnmarshalVT added in v1.1.0 

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

type Tombstones added in v1.1.0 

type Tombstones struct {
	Blocks *BlockTombstones `protobuf:"bytes,1,opt,name=blocks,proto3" json:"blocks,omitempty"`
	// contains filtered or unexported fields
}

Tombstones represent objects removed from the index but still stored.

func (*Tombstones) CloneMessageVT added in v1.1.0 

func (m *Tombstones) CloneMessageVT() proto.Message

func (*Tombstones) CloneVT added in v1.1.0 

func (m *Tombstones) CloneVT() *Tombstones

func (*Tombstones) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use Tombstones.ProtoReflect.Descriptor instead.

func (*Tombstones) EqualMessageVT added in v1.1.0 

func (this *Tombstones) EqualMessageVT(thatMsg proto.Message) bool

func (*Tombstones) EqualVT added in v1.1.0 

func (this *Tombstones) EqualVT(that *Tombstones) bool

func (*Tombstones) GetBlocks added in v1.1.0 

func (x *Tombstones) GetBlocks() *BlockTombstones

func (*Tombstones) MarshalToSizedBufferVT added in v1.1.0 

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

func (*Tombstones) MarshalToVT added in v1.1.0 

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

func (*Tombstones) MarshalVT added in v1.1.0 

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

func (*Tombstones) ProtoMessage added in v1.1.0 

func (*Tombstones) ProtoMessage()

func (*Tombstones) ProtoReflect added in v1.1.0 

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

func (*Tombstones) Reset added in v1.1.0 

func (x *Tombstones) Reset()

func (*Tombstones) SizeVT added in v1.1.0 

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

func (*Tombstones) String added in v1.1.0 

func (x *Tombstones) String() string

func (*Tombstones) UnmarshalVT added in v1.1.0 

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

type UnimplementedCompactionServiceServer added in v1.1.0 

type UnimplementedCompactionServiceServer struct {
}

UnimplementedCompactionServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedCompactionServiceServer) PollCompactionJobs added in v1.1.0 

func (UnimplementedCompactionServiceServer) PollCompactionJobs(context.Context, *PollCompactionJobsRequest) (*PollCompactionJobsResponse, error)

type UnimplementedIndexServiceServer added in v1.1.0 

type UnimplementedIndexServiceServer struct {
}

UnimplementedIndexServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedIndexServiceServer) AddBlock added in v1.1.0 

func (UnimplementedIndexServiceServer) AddBlock(context.Context, *AddBlockRequest) (*AddBlockResponse, error)

func (UnimplementedIndexServiceServer) GetBlockMetadata added in v1.1.0 

func (UnimplementedIndexServiceServer) GetBlockMetadata(context.Context, *GetBlockMetadataRequest) (*GetBlockMetadataResponse, error)

type UnimplementedMetadataQueryServiceServer added in v1.1.0 

type UnimplementedMetadataQueryServiceServer struct {
}

UnimplementedMetadataQueryServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedMetadataQueryServiceServer) QueryMetadata added in v1.1.0 

func (UnimplementedMetadataQueryServiceServer) QueryMetadata(context.Context, *QueryMetadataRequest) (*QueryMetadataResponse, error)

func (UnimplementedMetadataQueryServiceServer) QueryMetadataLabels added in v1.1.0 

func (UnimplementedMetadataQueryServiceServer) QueryMetadataLabels(context.Context, *QueryMetadataLabelsRequest) (*QueryMetadataLabelsResponse, error)

type UnimplementedTenantServiceServer added in v1.1.0 

type UnimplementedTenantServiceServer struct {
}

UnimplementedTenantServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTenantServiceServer) DeleteTenant added in v1.1.0 

func (UnimplementedTenantServiceServer) DeleteTenant(context.Context, *DeleteTenantRequest) (*DeleteTenantResponse, error)

func (UnimplementedTenantServiceServer) GetTenant added in v1.1.0 

func (UnimplementedTenantServiceServer) GetTenant(context.Context, *GetTenantRequest) (*GetTenantResponse, error)

type UnsafeCompactionServiceServer added in v1.1.0 

type UnsafeCompactionServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeCompactionServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CompactionServiceServer will result in compilation errors.

type UnsafeIndexServiceServer added in v1.1.0 

type UnsafeIndexServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeIndexServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to IndexServiceServer will result in compilation errors.

type UnsafeMetadataQueryServiceServer added in v1.1.0 

type UnsafeMetadataQueryServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeMetadataQueryServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MetadataQueryServiceServer will result in compilation errors.

type UnsafeTenantServiceServer added in v1.1.0 

type UnsafeTenantServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeTenantServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TenantServiceServer will result in compilation errors.

Source Files

View all Source files

Directories

Path Synopsis

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.