indexgatewaypb

package
v2.5.2 Latest Latest
Warning

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

 Go to latest Published: Apr 27, 2022 License: AGPL-3.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

func RegisterIndexGatewayServer 

func RegisterIndexGatewayServer(s *grpc.Server, srv IndexGatewayServer)

Types

type GetChunkRefRequest 

type GetChunkRefRequest struct {
	From     github_com_prometheus_common_model.Time `protobuf:"varint,1,opt,name=from,proto3,customtype=github.com/prometheus/common/model.Time" json:"from"`
	Through  github_com_prometheus_common_model.Time `protobuf:"varint,2,opt,name=through,proto3,customtype=github.com/prometheus/common/model.Time" json:"through"`
	Matchers string                                  `protobuf:"bytes,3,opt,name=matchers,proto3" json:"matchers,omitempty"`
}

func (*GetChunkRefRequest) Descriptor 

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

func (*GetChunkRefRequest) Equal 

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

func (*GetChunkRefRequest) GetMatchers 

func (m *GetChunkRefRequest) GetMatchers() string

func (*GetChunkRefRequest) GoString 

func (this *GetChunkRefRequest) GoString() string

func (*GetChunkRefRequest) Marshal 

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

func (*GetChunkRefRequest) MarshalTo 

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

func (*GetChunkRefRequest) MarshalToSizedBuffer 

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

func (*GetChunkRefRequest) ProtoMessage 

func (*GetChunkRefRequest) ProtoMessage()

func (*GetChunkRefRequest) Reset 

func (m *GetChunkRefRequest) Reset()

func (*GetChunkRefRequest) Size 

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

func (*GetChunkRefRequest) String 

func (this *GetChunkRefRequest) String() string

func (*GetChunkRefRequest) Unmarshal 

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

func (*GetChunkRefRequest) XXX_DiscardUnknown 

func (m *GetChunkRefRequest) XXX_DiscardUnknown()

func (*GetChunkRefRequest) XXX_Marshal 

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

func (*GetChunkRefRequest) XXX_Merge 

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

func (*GetChunkRefRequest) XXX_Size 

func (m *GetChunkRefRequest) XXX_Size() int

func (*GetChunkRefRequest) XXX_Unmarshal 

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

type GetChunkRefResponse 

type GetChunkRefResponse struct {
	Refs []*logproto.ChunkRef `protobuf:"bytes,1,rep,name=refs,proto3" json:"refs,omitempty"`
}

func (*GetChunkRefResponse) Descriptor 

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

func (*GetChunkRefResponse) Equal 

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

func (*GetChunkRefResponse) GetRefs 

func (m *GetChunkRefResponse) GetRefs() []*logproto.ChunkRef

func (*GetChunkRefResponse) GoString 

func (this *GetChunkRefResponse) GoString() string

func (*GetChunkRefResponse) Marshal 

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

func (*GetChunkRefResponse) MarshalTo 

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

func (*GetChunkRefResponse) MarshalToSizedBuffer 

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

func (*GetChunkRefResponse) ProtoMessage 

func (*GetChunkRefResponse) ProtoMessage()

func (*GetChunkRefResponse) Reset 

func (m *GetChunkRefResponse) Reset()

func (*GetChunkRefResponse) Size 

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

func (*GetChunkRefResponse) String 

func (this *GetChunkRefResponse) String() string

func (*GetChunkRefResponse) Unmarshal 

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

func (*GetChunkRefResponse) XXX_DiscardUnknown 

func (m *GetChunkRefResponse) XXX_DiscardUnknown()

func (*GetChunkRefResponse) XXX_Marshal 

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

func (*GetChunkRefResponse) XXX_Merge 

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

func (*GetChunkRefResponse) XXX_Size 

func (m *GetChunkRefResponse) XXX_Size() int

func (*GetChunkRefResponse) XXX_Unmarshal 

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

type IndexGatewayClient 

type IndexGatewayClient interface {
	/// QueryIndex reads the indexes required for given query & sends back the batch of rows
	/// in rpc streams
	QueryIndex(ctx context.Context, in *QueryIndexRequest, opts ...grpc.CallOption) (IndexGateway_QueryIndexClient, error)
	/// GetChunkRef returns chunk reference that match the provided label matchers
	GetChunkRef(ctx context.Context, in *GetChunkRefRequest, opts ...grpc.CallOption) (*GetChunkRefResponse, error)
	LabelNamesForMetricName(ctx context.Context, in *LabelNamesForMetricNameRequest, opts ...grpc.CallOption) (*LabelResponse, error)
	LabelValuesForMetricName(ctx context.Context, in *LabelValuesForMetricNameRequest, opts ...grpc.CallOption) (*LabelResponse, error)
}

IndexGatewayClient is the client API for IndexGateway service.

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

func NewIndexGatewayClient 

func NewIndexGatewayClient(cc *grpc.ClientConn) IndexGatewayClient

type IndexGatewayServer 

type IndexGatewayServer interface {
	/// QueryIndex reads the indexes required for given query & sends back the batch of rows
	/// in rpc streams
	QueryIndex(*QueryIndexRequest, IndexGateway_QueryIndexServer) error
	/// GetChunkRef returns chunk reference that match the provided label matchers
	GetChunkRef(context.Context, *GetChunkRefRequest) (*GetChunkRefResponse, error)
	LabelNamesForMetricName(context.Context, *LabelNamesForMetricNameRequest) (*LabelResponse, error)
	LabelValuesForMetricName(context.Context, *LabelValuesForMetricNameRequest) (*LabelResponse, error)
}

IndexGatewayServer is the server API for IndexGateway service.

type IndexGateway_QueryIndexClient 

type IndexGateway_QueryIndexClient interface {
	Recv() (*QueryIndexResponse, error)
	grpc.ClientStream
}

type IndexGateway_QueryIndexServer 

type IndexGateway_QueryIndexServer interface {
	Send(*QueryIndexResponse) error
	grpc.ServerStream
}

type IndexQuery 

type IndexQuery struct {
	TableName        string `protobuf:"bytes,1,opt,name=tableName,proto3" json:"tableName,omitempty"`
	HashValue        string `protobuf:"bytes,2,opt,name=hashValue,proto3" json:"hashValue,omitempty"`
	RangeValuePrefix []byte `protobuf:"bytes,3,opt,name=rangeValuePrefix,proto3" json:"rangeValuePrefix,omitempty"`
	RangeValueStart  []byte `protobuf:"bytes,4,opt,name=rangeValueStart,proto3" json:"rangeValueStart,omitempty"`
	ValueEqual       []byte `protobuf:"bytes,5,opt,name=valueEqual,proto3" json:"valueEqual,omitempty"`
}

func (*IndexQuery) Descriptor 

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

func (*IndexQuery) Equal 

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

func (*IndexQuery) GetHashValue 

func (m *IndexQuery) GetHashValue() string

func (*IndexQuery) GetRangeValuePrefix 

func (m *IndexQuery) GetRangeValuePrefix() []byte

func (*IndexQuery) GetRangeValueStart 

func (m *IndexQuery) GetRangeValueStart() []byte

func (*IndexQuery) GetTableName 

func (m *IndexQuery) GetTableName() string

func (*IndexQuery) GetValueEqual 

func (m *IndexQuery) GetValueEqual() []byte

func (*IndexQuery) GoString 

func (this *IndexQuery) GoString() string

func (*IndexQuery) Marshal 

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

func (*IndexQuery) MarshalTo 

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

func (*IndexQuery) MarshalToSizedBuffer 

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

func (*IndexQuery) ProtoMessage 

func (*IndexQuery) ProtoMessage()

func (*IndexQuery) Reset 

func (m *IndexQuery) Reset()

func (*IndexQuery) Size 

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

func (*IndexQuery) String 

func (this *IndexQuery) String() string

func (*IndexQuery) Unmarshal 

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

func (*IndexQuery) XXX_DiscardUnknown 

func (m *IndexQuery) XXX_DiscardUnknown()

func (*IndexQuery) XXX_Marshal 

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

func (*IndexQuery) XXX_Merge 

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

func (*IndexQuery) XXX_Size 

func (m *IndexQuery) XXX_Size() int

func (*IndexQuery) XXX_Unmarshal 

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

type LabelNamesForMetricNameRequest 

type LabelNamesForMetricNameRequest struct {
	MetricName string                                  `protobuf:"bytes,1,opt,name=metric_name,json=metricName,proto3" json:"metric_name,omitempty"`
	From       github_com_prometheus_common_model.Time `protobuf:"varint,2,opt,name=from,proto3,customtype=github.com/prometheus/common/model.Time" json:"from"`
	Through    github_com_prometheus_common_model.Time `protobuf:"varint,3,opt,name=through,proto3,customtype=github.com/prometheus/common/model.Time" json:"through"`
}

func (*LabelNamesForMetricNameRequest) Descriptor 

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

func (*LabelNamesForMetricNameRequest) Equal 

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

func (*LabelNamesForMetricNameRequest) GetMetricName 

func (m *LabelNamesForMetricNameRequest) GetMetricName() string

func (*LabelNamesForMetricNameRequest) GoString 

func (this *LabelNamesForMetricNameRequest) GoString() string

func (*LabelNamesForMetricNameRequest) Marshal 

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

func (*LabelNamesForMetricNameRequest) MarshalTo 

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

func (*LabelNamesForMetricNameRequest) MarshalToSizedBuffer 

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

func (*LabelNamesForMetricNameRequest) ProtoMessage 

func (*LabelNamesForMetricNameRequest) ProtoMessage()

func (*LabelNamesForMetricNameRequest) Reset 

func (m *LabelNamesForMetricNameRequest) Reset()

func (*LabelNamesForMetricNameRequest) Size 

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

func (*LabelNamesForMetricNameRequest) String 

func (this *LabelNamesForMetricNameRequest) String() string

func (*LabelNamesForMetricNameRequest) Unmarshal 

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

func (*LabelNamesForMetricNameRequest) XXX_DiscardUnknown 

func (m *LabelNamesForMetricNameRequest) XXX_DiscardUnknown()

func (*LabelNamesForMetricNameRequest) XXX_Marshal 

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

func (*LabelNamesForMetricNameRequest) XXX_Merge 

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

func (*LabelNamesForMetricNameRequest) XXX_Size 

func (m *LabelNamesForMetricNameRequest) XXX_Size() int

func (*LabelNamesForMetricNameRequest) XXX_Unmarshal 

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

type LabelResponse 

type LabelResponse struct {
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
}

func (*LabelResponse) Descriptor 

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

func (*LabelResponse) Equal 

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

func (*LabelResponse) GetValues 

func (m *LabelResponse) GetValues() []string

func (*LabelResponse) GoString 

func (this *LabelResponse) GoString() string

func (*LabelResponse) Marshal 

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

func (*LabelResponse) MarshalTo 

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

func (*LabelResponse) MarshalToSizedBuffer 

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

func (*LabelResponse) ProtoMessage 

func (*LabelResponse) ProtoMessage()

func (*LabelResponse) Reset 

func (m *LabelResponse) Reset()

func (*LabelResponse) Size 

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

func (*LabelResponse) String 

func (this *LabelResponse) String() string

func (*LabelResponse) Unmarshal 

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

func (*LabelResponse) XXX_DiscardUnknown 

func (m *LabelResponse) XXX_DiscardUnknown()

func (*LabelResponse) XXX_Marshal 

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

func (*LabelResponse) XXX_Merge 

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

func (*LabelResponse) XXX_Size 

func (m *LabelResponse) XXX_Size() int

func (*LabelResponse) XXX_Unmarshal 

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

type LabelValuesForMetricNameRequest 

type LabelValuesForMetricNameRequest struct {
	MetricName string                                  `protobuf:"bytes,1,opt,name=metric_name,json=metricName,proto3" json:"metric_name,omitempty"`
	LabelName  string                                  `protobuf:"bytes,2,opt,name=label_name,json=labelName,proto3" json:"label_name,omitempty"`
	From       github_com_prometheus_common_model.Time `protobuf:"varint,3,opt,name=from,proto3,customtype=github.com/prometheus/common/model.Time" json:"from"`
	Through    github_com_prometheus_common_model.Time `protobuf:"varint,4,opt,name=through,proto3,customtype=github.com/prometheus/common/model.Time" json:"through"`
	Matchers   string                                  `protobuf:"bytes,5,opt,name=matchers,proto3" json:"matchers,omitempty"`
}

func (*LabelValuesForMetricNameRequest) Descriptor 

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

func (*LabelValuesForMetricNameRequest) Equal 

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

func (*LabelValuesForMetricNameRequest) GetLabelName 

func (m *LabelValuesForMetricNameRequest) GetLabelName() string

func (*LabelValuesForMetricNameRequest) GetMatchers 

func (m *LabelValuesForMetricNameRequest) GetMatchers() string

func (*LabelValuesForMetricNameRequest) GetMetricName 

func (m *LabelValuesForMetricNameRequest) GetMetricName() string

func (*LabelValuesForMetricNameRequest) GoString 

func (this *LabelValuesForMetricNameRequest) GoString() string

func (*LabelValuesForMetricNameRequest) Marshal 

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

func (*LabelValuesForMetricNameRequest) MarshalTo 

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

func (*LabelValuesForMetricNameRequest) MarshalToSizedBuffer 

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

func (*LabelValuesForMetricNameRequest) ProtoMessage 

func (*LabelValuesForMetricNameRequest) ProtoMessage()

func (*LabelValuesForMetricNameRequest) Reset 

func (m *LabelValuesForMetricNameRequest) Reset()

func (*LabelValuesForMetricNameRequest) Size 

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

func (*LabelValuesForMetricNameRequest) String 

func (this *LabelValuesForMetricNameRequest) String() string

func (*LabelValuesForMetricNameRequest) Unmarshal 

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

func (*LabelValuesForMetricNameRequest) XXX_DiscardUnknown 

func (m *LabelValuesForMetricNameRequest) XXX_DiscardUnknown()

func (*LabelValuesForMetricNameRequest) XXX_Marshal 

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

func (*LabelValuesForMetricNameRequest) XXX_Merge 

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

func (*LabelValuesForMetricNameRequest) XXX_Size 

func (m *LabelValuesForMetricNameRequest) XXX_Size() int

func (*LabelValuesForMetricNameRequest) XXX_Unmarshal 

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

type QueryIndexRequest 

type QueryIndexRequest struct {
	Queries []*IndexQuery `protobuf:"bytes,1,rep,name=Queries,proto3" json:"Queries,omitempty"`
}

func (*QueryIndexRequest) Descriptor 

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

func (*QueryIndexRequest) Equal 

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

func (*QueryIndexRequest) GetQueries 

func (m *QueryIndexRequest) GetQueries() []*IndexQuery

func (*QueryIndexRequest) GoString 

func (this *QueryIndexRequest) GoString() string

func (*QueryIndexRequest) Marshal 

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

func (*QueryIndexRequest) MarshalTo 

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

func (*QueryIndexRequest) MarshalToSizedBuffer 

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

func (*QueryIndexRequest) ProtoMessage 

func (*QueryIndexRequest) ProtoMessage()

func (*QueryIndexRequest) Reset 

func (m *QueryIndexRequest) Reset()

func (*QueryIndexRequest) Size 

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

func (*QueryIndexRequest) String 

func (this *QueryIndexRequest) String() string

func (*QueryIndexRequest) Unmarshal 

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

func (*QueryIndexRequest) XXX_DiscardUnknown 

func (m *QueryIndexRequest) XXX_DiscardUnknown()

func (*QueryIndexRequest) XXX_Marshal 

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

func (*QueryIndexRequest) XXX_Merge 

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

func (*QueryIndexRequest) XXX_Size 

func (m *QueryIndexRequest) XXX_Size() int

func (*QueryIndexRequest) XXX_Unmarshal 

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

type QueryIndexResponse 

type QueryIndexResponse struct {
	QueryKey string `protobuf:"bytes,1,opt,name=QueryKey,proto3" json:"QueryKey,omitempty"`
	Rows     []*Row `protobuf:"bytes,2,rep,name=rows,proto3" json:"rows,omitempty"`
}

func (*QueryIndexResponse) Descriptor 

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

func (*QueryIndexResponse) Equal 

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

func (*QueryIndexResponse) GetQueryKey 

func (m *QueryIndexResponse) GetQueryKey() string

func (*QueryIndexResponse) GetRows 

func (m *QueryIndexResponse) GetRows() []*Row

func (*QueryIndexResponse) GoString 

func (this *QueryIndexResponse) GoString() string

func (*QueryIndexResponse) Marshal 

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

func (*QueryIndexResponse) MarshalTo 

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

func (*QueryIndexResponse) MarshalToSizedBuffer 

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

func (*QueryIndexResponse) ProtoMessage 

func (*QueryIndexResponse) ProtoMessage()

func (*QueryIndexResponse) Reset 

func (m *QueryIndexResponse) Reset()

func (*QueryIndexResponse) Size 

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

func (*QueryIndexResponse) String 

func (this *QueryIndexResponse) String() string

func (*QueryIndexResponse) Unmarshal 

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

func (*QueryIndexResponse) XXX_DiscardUnknown 

func (m *QueryIndexResponse) XXX_DiscardUnknown()

func (*QueryIndexResponse) XXX_Marshal 

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

func (*QueryIndexResponse) XXX_Merge 

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

func (*QueryIndexResponse) XXX_Size 

func (m *QueryIndexResponse) XXX_Size() int

func (*QueryIndexResponse) XXX_Unmarshal 

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

type Row 

type Row struct {
	RangeValue []byte `protobuf:"bytes,1,opt,name=rangeValue,proto3" json:"rangeValue,omitempty"`
	Value      []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*Row) Descriptor 

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

func (*Row) Equal 

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

func (*Row) GetRangeValue 

func (m *Row) GetRangeValue() []byte

func (*Row) GetValue 

func (m *Row) GetValue() []byte

func (*Row) GoString 

func (this *Row) GoString() string

func (*Row) Marshal 

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

func (*Row) MarshalTo 

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

func (*Row) MarshalToSizedBuffer 

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

func (*Row) ProtoMessage 

func (*Row) ProtoMessage()

func (*Row) Reset 

func (m *Row) Reset()

func (*Row) Size 

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

func (*Row) String 

func (this *Row) String() string

func (*Row) Unmarshal 

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

func (*Row) XXX_DiscardUnknown 

func (m *Row) XXX_DiscardUnknown()

func (*Row) XXX_Marshal 

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

func (*Row) XXX_Merge 

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

func (*Row) XXX_Size 

func (m *Row) XXX_Size() int

func (*Row) XXX_Unmarshal 

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

type UnimplementedIndexGatewayServer 

type UnimplementedIndexGatewayServer struct {
}

UnimplementedIndexGatewayServer can be embedded to have forward compatible implementations.

func (*UnimplementedIndexGatewayServer) GetChunkRef 

func (*UnimplementedIndexGatewayServer) GetChunkRef(ctx context.Context, req *GetChunkRefRequest) (*GetChunkRefResponse, error)

func (*UnimplementedIndexGatewayServer) LabelNamesForMetricName 

func (*UnimplementedIndexGatewayServer) LabelNamesForMetricName(ctx context.Context, req *LabelNamesForMetricNameRequest) (*LabelResponse, error)

func (*UnimplementedIndexGatewayServer) LabelValuesForMetricName 

func (*UnimplementedIndexGatewayServer) LabelValuesForMetricName(ctx context.Context, req *LabelValuesForMetricNameRequest) (*LabelResponse, error)

func (*UnimplementedIndexGatewayServer) QueryIndex 

func (*UnimplementedIndexGatewayServer) QueryIndex(req *QueryIndexRequest, srv IndexGateway_QueryIndexServer) 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.