Versions in this module Expand all Collapse all v2 v2.4.3 Mar 21, 2022 Changes in this version + var ErrIntOverflowGateway = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthGateway = fmt.Errorf("proto: negative length found during unmarshaling") + func RegisterIndexGatewayServer(s *grpc.Server, srv IndexGatewayServer) + type IndexGatewayClient interface + QueryIndex func(ctx context.Context, in *QueryIndexRequest, opts ...grpc.CallOption) (IndexGateway_QueryIndexClient, error) + func NewIndexGatewayClient(cc *grpc.ClientConn) IndexGatewayClient + type IndexGatewayServer interface + QueryIndex func(*QueryIndexRequest, IndexGateway_QueryIndexServer) error + type IndexGateway_QueryIndexClient interface + Recv func() (*QueryIndexResponse, error) + type IndexGateway_QueryIndexServer interface + Send func(*QueryIndexResponse) error + type IndexQuery struct + HashValue string + RangeValuePrefix []byte + RangeValueStart []byte + TableName string + ValueEqual []byte + func (*IndexQuery) Descriptor() ([]byte, []int) + func (*IndexQuery) ProtoMessage() + func (m *IndexQuery) GetHashValue() string + func (m *IndexQuery) GetRangeValuePrefix() []byte + func (m *IndexQuery) GetRangeValueStart() []byte + func (m *IndexQuery) GetTableName() string + func (m *IndexQuery) GetValueEqual() []byte + func (m *IndexQuery) Marshal() (dAtA []byte, err error) + func (m *IndexQuery) MarshalTo(dAtA []byte) (int, error) + func (m *IndexQuery) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *IndexQuery) Reset() + func (m *IndexQuery) Size() (n int) + func (m *IndexQuery) Unmarshal(dAtA []byte) error + func (m *IndexQuery) XXX_DiscardUnknown() + func (m *IndexQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IndexQuery) XXX_Merge(src proto.Message) + func (m *IndexQuery) XXX_Size() int + func (m *IndexQuery) XXX_Unmarshal(b []byte) error + func (this *IndexQuery) Equal(that interface{}) bool + func (this *IndexQuery) GoString() string + func (this *IndexQuery) String() string + type QueryIndexRequest struct + Queries []*IndexQuery + func (*QueryIndexRequest) Descriptor() ([]byte, []int) + func (*QueryIndexRequest) ProtoMessage() + func (m *QueryIndexRequest) GetQueries() []*IndexQuery + func (m *QueryIndexRequest) Marshal() (dAtA []byte, err error) + func (m *QueryIndexRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryIndexRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryIndexRequest) Reset() + func (m *QueryIndexRequest) Size() (n int) + func (m *QueryIndexRequest) Unmarshal(dAtA []byte) error + func (m *QueryIndexRequest) XXX_DiscardUnknown() + func (m *QueryIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryIndexRequest) XXX_Merge(src proto.Message) + func (m *QueryIndexRequest) XXX_Size() int + func (m *QueryIndexRequest) XXX_Unmarshal(b []byte) error + func (this *QueryIndexRequest) Equal(that interface{}) bool + func (this *QueryIndexRequest) GoString() string + func (this *QueryIndexRequest) String() string + type QueryIndexResponse struct + QueryKey string + Rows []*Row + func (*QueryIndexResponse) Descriptor() ([]byte, []int) + func (*QueryIndexResponse) ProtoMessage() + func (m *QueryIndexResponse) GetQueryKey() string + func (m *QueryIndexResponse) GetRows() []*Row + func (m *QueryIndexResponse) Marshal() (dAtA []byte, err error) + func (m *QueryIndexResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryIndexResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryIndexResponse) Reset() + func (m *QueryIndexResponse) Size() (n int) + func (m *QueryIndexResponse) Unmarshal(dAtA []byte) error + func (m *QueryIndexResponse) XXX_DiscardUnknown() + func (m *QueryIndexResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryIndexResponse) XXX_Merge(src proto.Message) + func (m *QueryIndexResponse) XXX_Size() int + func (m *QueryIndexResponse) XXX_Unmarshal(b []byte) error + func (this *QueryIndexResponse) Equal(that interface{}) bool + func (this *QueryIndexResponse) GoString() string + func (this *QueryIndexResponse) String() string + type Row struct + RangeValue []byte + Value []byte + func (*Row) Descriptor() ([]byte, []int) + func (*Row) ProtoMessage() + func (m *Row) GetRangeValue() []byte + func (m *Row) GetValue() []byte + func (m *Row) Marshal() (dAtA []byte, err error) + func (m *Row) MarshalTo(dAtA []byte) (int, error) + func (m *Row) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Row) Reset() + func (m *Row) Size() (n int) + func (m *Row) Unmarshal(dAtA []byte) error + func (m *Row) XXX_DiscardUnknown() + func (m *Row) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Row) XXX_Merge(src proto.Message) + func (m *Row) XXX_Size() int + func (m *Row) XXX_Unmarshal(b []byte) error + func (this *Row) Equal(that interface{}) bool + func (this *Row) GoString() string + func (this *Row) String() string + type UnimplementedIndexGatewayServer struct + func (*UnimplementedIndexGatewayServer) QueryIndex(req *QueryIndexRequest, srv IndexGateway_QueryIndexServer) error Other modules containing this package github.com/pao214/loki/v3
Go to main page