metastorepb

package
v3.3.2 Latest Latest
Warning

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

 Go to latest Published: Dec 18, 2024 License: AGPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMetastore = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMetastore   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterMetastoreServiceServer 

func RegisterMetastoreServiceServer(s *grpc.Server, srv MetastoreServiceServer)

Types

type AddBlockRequest 

type AddBlockRequest struct {
	Block *BlockMeta `protobuf:"bytes,1,opt,name=block,proto3" json:"block,omitempty"`
}

func (*AddBlockRequest) Descriptor 

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

func (*AddBlockRequest) Equal 

func (this *AddBlockRequest) Equal(that interface{}) bool

func (*AddBlockRequest) GetBlock 

func (m *AddBlockRequest) GetBlock() *BlockMeta

func (*AddBlockRequest) GoString 

func (this *AddBlockRequest) GoString() string

func (*AddBlockRequest) Marshal 

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

func (*AddBlockRequest) MarshalTo 

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

func (*AddBlockRequest) MarshalToSizedBuffer 

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

func (*AddBlockRequest) ProtoMessage 

func (*AddBlockRequest) ProtoMessage()

func (*AddBlockRequest) Reset 

func (m *AddBlockRequest) Reset()

func (*AddBlockRequest) Size 

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

func (*AddBlockRequest) String 

func (this *AddBlockRequest) String() string

func (*AddBlockRequest) Unmarshal 

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

func (*AddBlockRequest) XXX_DiscardUnknown 

func (m *AddBlockRequest) XXX_DiscardUnknown()

func (*AddBlockRequest) XXX_Marshal 

func (m *AddBlockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddBlockRequest) XXX_Merge 

func (m *AddBlockRequest) XXX_Merge(src proto.Message)

func (*AddBlockRequest) XXX_Size 

func (m *AddBlockRequest) XXX_Size() int

func (*AddBlockRequest) XXX_Unmarshal 

func (m *AddBlockRequest) XXX_Unmarshal(b []byte) error

type AddBlockResponse 

type AddBlockResponse struct {
}

func (*AddBlockResponse) Descriptor 

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

func (*AddBlockResponse) Equal 

func (this *AddBlockResponse) Equal(that interface{}) bool

func (*AddBlockResponse) GoString 

func (this *AddBlockResponse) GoString() string

func (*AddBlockResponse) Marshal 

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

func (*AddBlockResponse) MarshalTo 

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

func (*AddBlockResponse) MarshalToSizedBuffer 

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

func (*AddBlockResponse) ProtoMessage 

func (*AddBlockResponse) ProtoMessage()

func (*AddBlockResponse) Reset 

func (m *AddBlockResponse) Reset()

func (*AddBlockResponse) Size 

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

func (*AddBlockResponse) String 

func (this *AddBlockResponse) String() string

func (*AddBlockResponse) Unmarshal 

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

func (*AddBlockResponse) XXX_DiscardUnknown 

func (m *AddBlockResponse) XXX_DiscardUnknown()

func (*AddBlockResponse) XXX_Marshal 

func (m *AddBlockResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddBlockResponse) XXX_Merge 

func (m *AddBlockResponse) XXX_Merge(src proto.Message)

func (*AddBlockResponse) XXX_Size 

func (m *AddBlockResponse) XXX_Size() int

func (*AddBlockResponse) XXX_Unmarshal 

func (m *AddBlockResponse) XXX_Unmarshal(b []byte) error

type BlockMeta 

type BlockMeta struct {
	FormatVersion   uint64           `protobuf:"varint,1,opt,name=format_version,json=formatVersion,proto3" json:"format_version,omitempty"`
	Id              string           `protobuf:"bytes,2,opt,name=id,proto3" json:"id,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"`
	CompactionLevel uint32           `protobuf:"varint,6,opt,name=compaction_level,json=compactionLevel,proto3" json:"compaction_level,omitempty"`
	IndexRef        DataRef          `protobuf:"bytes,7,opt,name=indexRef,proto3" json:"indexRef"`
	TenantStreams   []*TenantStreams `protobuf:"bytes,8,rep,name=tenant_streams,json=tenantStreams,proto3" json:"tenant_streams,omitempty"`
}

func (*BlockMeta) Descriptor 

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

func (*BlockMeta) Equal 

func (this *BlockMeta) Equal(that interface{}) bool

func (*BlockMeta) GetCompactionLevel 

func (m *BlockMeta) GetCompactionLevel() uint32

func (*BlockMeta) GetFormatVersion 

func (m *BlockMeta) GetFormatVersion() uint64

func (*BlockMeta) GetId 

func (m *BlockMeta) GetId() string

func (*BlockMeta) GetIndexRef 

func (m *BlockMeta) GetIndexRef() DataRef

func (*BlockMeta) GetMaxTime 

func (m *BlockMeta) GetMaxTime() int64

func (*BlockMeta) GetMinTime 

func (m *BlockMeta) GetMinTime() int64

func (*BlockMeta) GetTenantStreams 

func (m *BlockMeta) GetTenantStreams() []*TenantStreams

func (*BlockMeta) GoString 

func (this *BlockMeta) GoString() string

func (*BlockMeta) Marshal 

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

func (*BlockMeta) MarshalTo 

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

func (*BlockMeta) MarshalToSizedBuffer 

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

func (*BlockMeta) ProtoMessage 

func (*BlockMeta) ProtoMessage()

func (*BlockMeta) Reset 

func (m *BlockMeta) Reset()

func (*BlockMeta) Size 

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

func (*BlockMeta) String 

func (this *BlockMeta) String() string

func (*BlockMeta) Unmarshal 

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

func (*BlockMeta) XXX_DiscardUnknown 

func (m *BlockMeta) XXX_DiscardUnknown()

func (*BlockMeta) XXX_Marshal 

func (m *BlockMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BlockMeta) XXX_Merge 

func (m *BlockMeta) XXX_Merge(src proto.Message)

func (*BlockMeta) XXX_Size 

func (m *BlockMeta) XXX_Size() int

func (*BlockMeta) XXX_Unmarshal 

func (m *BlockMeta) XXX_Unmarshal(b []byte) error

type DataRef 

type DataRef struct {
	Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Length int64 `protobuf:"varint,2,opt,name=length,proto3" json:"length,omitempty"`
}

func (*DataRef) Descriptor 

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

func (*DataRef) Equal 

func (this *DataRef) Equal(that interface{}) bool

func (*DataRef) GetLength 

func (m *DataRef) GetLength() int64

func (*DataRef) GetOffset 

func (m *DataRef) GetOffset() int64

func (*DataRef) GoString 

func (this *DataRef) GoString() string

func (*DataRef) Marshal 

func (m *DataRef) Marshal() (dAtA []byte, err error)

func (*DataRef) MarshalTo 

func (m *DataRef) MarshalTo(dAtA []byte) (int, error)

func (*DataRef) MarshalToSizedBuffer 

func (m *DataRef) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DataRef) ProtoMessage 

func (*DataRef) ProtoMessage()

func (*DataRef) Reset 

func (m *DataRef) Reset()

func (*DataRef) Size 

func (m *DataRef) Size() (n int)

func (*DataRef) String 

func (this *DataRef) String() string

func (*DataRef) Unmarshal 

func (m *DataRef) Unmarshal(dAtA []byte) error

func (*DataRef) XXX_DiscardUnknown 

func (m *DataRef) XXX_DiscardUnknown()

func (*DataRef) XXX_Marshal 

func (m *DataRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataRef) XXX_Merge 

func (m *DataRef) XXX_Merge(src proto.Message)

func (*DataRef) XXX_Size 

func (m *DataRef) XXX_Size() int

func (*DataRef) XXX_Unmarshal 

func (m *DataRef) XXX_Unmarshal(b []byte) error

type ListBlocksForQueryRequest 

type ListBlocksForQueryRequest struct {
	TenantId  string `protobuf:"bytes,1,opt,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"`
}

func (*ListBlocksForQueryRequest) Descriptor 

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

func (*ListBlocksForQueryRequest) Equal 

func (this *ListBlocksForQueryRequest) Equal(that interface{}) bool

func (*ListBlocksForQueryRequest) GetEndTime 

func (m *ListBlocksForQueryRequest) GetEndTime() int64

func (*ListBlocksForQueryRequest) GetStartTime 

func (m *ListBlocksForQueryRequest) GetStartTime() int64

func (*ListBlocksForQueryRequest) GetTenantId 

func (m *ListBlocksForQueryRequest) GetTenantId() string

func (*ListBlocksForQueryRequest) GoString 

func (this *ListBlocksForQueryRequest) GoString() string

func (*ListBlocksForQueryRequest) Marshal 

func (m *ListBlocksForQueryRequest) Marshal() (dAtA []byte, err error)

func (*ListBlocksForQueryRequest) MarshalTo 

func (m *ListBlocksForQueryRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListBlocksForQueryRequest) MarshalToSizedBuffer 

func (m *ListBlocksForQueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListBlocksForQueryRequest) ProtoMessage 

func (*ListBlocksForQueryRequest) ProtoMessage()

func (*ListBlocksForQueryRequest) Reset 

func (m *ListBlocksForQueryRequest) Reset()

func (*ListBlocksForQueryRequest) Size 

func (m *ListBlocksForQueryRequest) Size() (n int)

func (*ListBlocksForQueryRequest) String 

func (this *ListBlocksForQueryRequest) String() string

func (*ListBlocksForQueryRequest) Unmarshal 

func (m *ListBlocksForQueryRequest) Unmarshal(dAtA []byte) error

func (*ListBlocksForQueryRequest) XXX_DiscardUnknown 

func (m *ListBlocksForQueryRequest) XXX_DiscardUnknown()

func (*ListBlocksForQueryRequest) XXX_Marshal 

func (m *ListBlocksForQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListBlocksForQueryRequest) XXX_Merge 

func (m *ListBlocksForQueryRequest) XXX_Merge(src proto.Message)

func (*ListBlocksForQueryRequest) XXX_Size 

func (m *ListBlocksForQueryRequest) XXX_Size() int

func (*ListBlocksForQueryRequest) XXX_Unmarshal 

func (m *ListBlocksForQueryRequest) XXX_Unmarshal(b []byte) error

type ListBlocksForQueryResponse 

type ListBlocksForQueryResponse struct {
	Blocks []*BlockMeta `protobuf:"bytes,1,rep,name=blocks,proto3" json:"blocks,omitempty"`
}

func (*ListBlocksForQueryResponse) Descriptor 

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

func (*ListBlocksForQueryResponse) Equal 

func (this *ListBlocksForQueryResponse) Equal(that interface{}) bool

func (*ListBlocksForQueryResponse) GetBlocks 

func (m *ListBlocksForQueryResponse) GetBlocks() []*BlockMeta

func (*ListBlocksForQueryResponse) GoString 

func (this *ListBlocksForQueryResponse) GoString() string

func (*ListBlocksForQueryResponse) Marshal 

func (m *ListBlocksForQueryResponse) Marshal() (dAtA []byte, err error)

func (*ListBlocksForQueryResponse) MarshalTo 

func (m *ListBlocksForQueryResponse) MarshalTo(dAtA []byte) (int, error)

func (*ListBlocksForQueryResponse) MarshalToSizedBuffer 

func (m *ListBlocksForQueryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListBlocksForQueryResponse) ProtoMessage 

func (*ListBlocksForQueryResponse) ProtoMessage()

func (*ListBlocksForQueryResponse) Reset 

func (m *ListBlocksForQueryResponse) Reset()

func (*ListBlocksForQueryResponse) Size 

func (m *ListBlocksForQueryResponse) Size() (n int)

func (*ListBlocksForQueryResponse) String 

func (this *ListBlocksForQueryResponse) String() string

func (*ListBlocksForQueryResponse) Unmarshal 

func (m *ListBlocksForQueryResponse) Unmarshal(dAtA []byte) error

func (*ListBlocksForQueryResponse) XXX_DiscardUnknown 

func (m *ListBlocksForQueryResponse) XXX_DiscardUnknown()

func (*ListBlocksForQueryResponse) XXX_Marshal 

func (m *ListBlocksForQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListBlocksForQueryResponse) XXX_Merge 

func (m *ListBlocksForQueryResponse) XXX_Merge(src proto.Message)

func (*ListBlocksForQueryResponse) XXX_Size 

func (m *ListBlocksForQueryResponse) XXX_Size() int

func (*ListBlocksForQueryResponse) XXX_Unmarshal 

func (m *ListBlocksForQueryResponse) XXX_Unmarshal(b []byte) error

type MetastoreServiceClient 

type MetastoreServiceClient interface {
	AddBlock(ctx context.Context, in *AddBlockRequest, opts ...grpc.CallOption) (*AddBlockResponse, error)
	ListBlocksForQuery(ctx context.Context, in *ListBlocksForQueryRequest, opts ...grpc.CallOption) (*ListBlocksForQueryResponse, error)
}

MetastoreServiceClient is the client API for MetastoreService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMetastoreServiceClient 

func NewMetastoreServiceClient(cc *grpc.ClientConn) MetastoreServiceClient

type MetastoreServiceServer 

type MetastoreServiceServer interface {
	AddBlock(context.Context, *AddBlockRequest) (*AddBlockResponse, error)
	ListBlocksForQuery(context.Context, *ListBlocksForQueryRequest) (*ListBlocksForQueryResponse, error)
}

MetastoreServiceServer is the server API for MetastoreService service.

type TenantStreams 

type TenantStreams struct {
	TenantId string `protobuf:"bytes,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,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"`
}

TenantStreams object points to the offset in the block at which the tenant streams data is located.

func (*TenantStreams) Descriptor 

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

func (*TenantStreams) Equal 

func (this *TenantStreams) Equal(that interface{}) bool

func (*TenantStreams) GetMaxTime 

func (m *TenantStreams) GetMaxTime() int64

func (*TenantStreams) GetMinTime 

func (m *TenantStreams) GetMinTime() int64

func (*TenantStreams) GetTenantId 

func (m *TenantStreams) GetTenantId() string

func (*TenantStreams) GoString 

func (this *TenantStreams) GoString() string

func (*TenantStreams) Marshal 

func (m *TenantStreams) Marshal() (dAtA []byte, err error)

func (*TenantStreams) MarshalTo 

func (m *TenantStreams) MarshalTo(dAtA []byte) (int, error)

func (*TenantStreams) MarshalToSizedBuffer 

func (m *TenantStreams) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TenantStreams) ProtoMessage 

func (*TenantStreams) ProtoMessage()

func (*TenantStreams) Reset 

func (m *TenantStreams) Reset()

func (*TenantStreams) Size 

func (m *TenantStreams) Size() (n int)

func (*TenantStreams) String 

func (this *TenantStreams) String() string

func (*TenantStreams) Unmarshal 

func (m *TenantStreams) Unmarshal(dAtA []byte) error

func (*TenantStreams) XXX_DiscardUnknown 

func (m *TenantStreams) XXX_DiscardUnknown()

func (*TenantStreams) XXX_Marshal 

func (m *TenantStreams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TenantStreams) XXX_Merge 

func (m *TenantStreams) XXX_Merge(src proto.Message)

func (*TenantStreams) XXX_Size 

func (m *TenantStreams) XXX_Size() int

func (*TenantStreams) XXX_Unmarshal 

func (m *TenantStreams) XXX_Unmarshal(b []byte) error

type UnimplementedMetastoreServiceServer 

type UnimplementedMetastoreServiceServer struct {
}

UnimplementedMetastoreServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMetastoreServiceServer) AddBlock 

func (*UnimplementedMetastoreServiceServer) AddBlock(ctx context.Context, req *AddBlockRequest) (*AddBlockResponse, error)

func (*UnimplementedMetastoreServiceServer) ListBlocksForQuery 

func (*UnimplementedMetastoreServiceServer) ListBlocksForQuery(ctx context.Context, req *ListBlocksForQueryRequest) (*ListBlocksForQueryResponse, 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.