search

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Apr 17, 2020 License: Apache-2.0 Imports: 5 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var HealthCheckResponse_ServingStatus_name = map[int32]string{
	0: "UNKNOWN",
	1: "SERVING",
	2: "NOT_SERVING",
}
View Source 
var HealthCheckResponse_ServingStatus_value = map[string]int32{
	"UNKNOWN":     0,
	"SERVING":     1,
	"NOT_SERVING": 2,
}

Functions

func RegisterSearchServiceServer 

func RegisterSearchServiceServer(s *grpc.Server, srv SearchServiceServer)

Types

type ConsistencyParams 

type ConsistencyParams struct {
	// A Level value of "" means stale is ok; "at_plus" means we need
	// consistency at least at or beyond the consistency vector but
	// not before.
	Level string `protobuf:"bytes,1,opt,name=Level,proto3" json:"Level,omitempty"`
	// Keyed by indexName.
	Vectors              map[string]*ConsistencyVectors `` /* 155-byte string literal not displayed */
	Results              string                         `protobuf:"bytes,3,opt,name=Results,proto3" json:"Results,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

ConsistencyParams represent the consistency requirements of a client's request.

func (*ConsistencyParams) Descriptor 

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

func (*ConsistencyParams) GetLevel 

func (m *ConsistencyParams) GetLevel() string

func (*ConsistencyParams) GetResults 

func (m *ConsistencyParams) GetResults() string

func (*ConsistencyParams) GetVectors 

func (m *ConsistencyParams) GetVectors() map[string]*ConsistencyVectors

func (*ConsistencyParams) ProtoMessage 

func (*ConsistencyParams) ProtoMessage()

func (*ConsistencyParams) Reset 

func (m *ConsistencyParams) Reset()

func (*ConsistencyParams) String 

func (m *ConsistencyParams) String() string

func (*ConsistencyParams) XXX_DiscardUnknown 

func (m *ConsistencyParams) XXX_DiscardUnknown()

func (*ConsistencyParams) XXX_Marshal 

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

func (*ConsistencyParams) XXX_Merge 

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

func (*ConsistencyParams) XXX_Size 

func (m *ConsistencyParams) XXX_Size() int

func (*ConsistencyParams) XXX_Unmarshal 

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

type ConsistencyVectors 

type ConsistencyVectors struct {
	ConsistencyVector    map[string]uint64 `` /* 176-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Key is partition or partition/partitionUUID. Value is seq. For example, a DCP data source might have the key as either "vbucketId" or "vbucketId/vbucketUUID".

func (*ConsistencyVectors) Descriptor 

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

func (*ConsistencyVectors) GetConsistencyVector 

func (m *ConsistencyVectors) GetConsistencyVector() map[string]uint64

func (*ConsistencyVectors) ProtoMessage 

func (*ConsistencyVectors) ProtoMessage()

func (*ConsistencyVectors) Reset 

func (m *ConsistencyVectors) Reset()

func (*ConsistencyVectors) String 

func (m *ConsistencyVectors) String() string

func (*ConsistencyVectors) XXX_DiscardUnknown 

func (m *ConsistencyVectors) XXX_DiscardUnknown()

func (*ConsistencyVectors) XXX_Marshal 

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

func (*ConsistencyVectors) XXX_Merge 

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

func (*ConsistencyVectors) XXX_Size 

func (m *ConsistencyVectors) XXX_Size() int

func (*ConsistencyVectors) XXX_Unmarshal 

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

type DocCountRequest 

type DocCountRequest struct {
	IndexName            string   `protobuf:"bytes,1,opt,name=IndexName,proto3" json:"IndexName,omitempty"`
	IndexUUID            string   `protobuf:"bytes,2,opt,name=IndexUUID,proto3" json:"IndexUUID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DocCountRequest) Descriptor 

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

func (*DocCountRequest) GetIndexName 

func (m *DocCountRequest) GetIndexName() string

func (*DocCountRequest) GetIndexUUID 

func (m *DocCountRequest) GetIndexUUID() string

func (*DocCountRequest) ProtoMessage 

func (*DocCountRequest) ProtoMessage()

func (*DocCountRequest) Reset 

func (m *DocCountRequest) Reset()

func (*DocCountRequest) String 

func (m *DocCountRequest) String() string

func (*DocCountRequest) XXX_DiscardUnknown 

func (m *DocCountRequest) XXX_DiscardUnknown()

func (*DocCountRequest) XXX_Marshal 

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

func (*DocCountRequest) XXX_Merge 

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

func (*DocCountRequest) XXX_Size 

func (m *DocCountRequest) XXX_Size() int

func (*DocCountRequest) XXX_Unmarshal 

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

type DocCountResult 

type DocCountResult struct {
	DocCount             int64    `protobuf:"varint,1,opt,name=DocCount,proto3" json:"DocCount,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DocCountResult) Descriptor 

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

func (*DocCountResult) GetDocCount 

func (m *DocCountResult) GetDocCount() int64

func (*DocCountResult) ProtoMessage 

func (*DocCountResult) ProtoMessage()

func (*DocCountResult) Reset 

func (m *DocCountResult) Reset()

func (*DocCountResult) String 

func (m *DocCountResult) String() string

func (*DocCountResult) XXX_DiscardUnknown 

func (m *DocCountResult) XXX_DiscardUnknown()

func (*DocCountResult) XXX_Marshal 

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

func (*DocCountResult) XXX_Merge 

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

func (*DocCountResult) XXX_Size 

func (m *DocCountResult) XXX_Size() int

func (*DocCountResult) XXX_Unmarshal 

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

type HealthCheckRequest 

type HealthCheckRequest struct {
	Service              string   `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HealthCheckRequest) Descriptor 

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

func (*HealthCheckRequest) GetService 

func (m *HealthCheckRequest) GetService() string

func (*HealthCheckRequest) ProtoMessage 

func (*HealthCheckRequest) ProtoMessage()

func (*HealthCheckRequest) Reset 

func (m *HealthCheckRequest) Reset()

func (*HealthCheckRequest) String 

func (m *HealthCheckRequest) String() string

func (*HealthCheckRequest) XXX_DiscardUnknown 

func (m *HealthCheckRequest) XXX_DiscardUnknown()

func (*HealthCheckRequest) XXX_Marshal 

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

func (*HealthCheckRequest) XXX_Merge 

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

func (*HealthCheckRequest) XXX_Size 

func (m *HealthCheckRequest) XXX_Size() int

func (*HealthCheckRequest) XXX_Unmarshal 

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

type HealthCheckResponse 

type HealthCheckResponse struct {
	Status               HealthCheckResponse_ServingStatus `protobuf:"varint,1,opt,name=status,proto3,enum=search.HealthCheckResponse_ServingStatus" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

func (*HealthCheckResponse) Descriptor 

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

func (*HealthCheckResponse) GetStatus 

func (m *HealthCheckResponse) GetStatus() HealthCheckResponse_ServingStatus

func (*HealthCheckResponse) ProtoMessage 

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) Reset 

func (m *HealthCheckResponse) Reset()

func (*HealthCheckResponse) String 

func (m *HealthCheckResponse) String() string

func (*HealthCheckResponse) XXX_DiscardUnknown 

func (m *HealthCheckResponse) XXX_DiscardUnknown()

func (*HealthCheckResponse) XXX_Marshal 

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

func (*HealthCheckResponse) XXX_Merge 

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

func (*HealthCheckResponse) XXX_Size 

func (m *HealthCheckResponse) XXX_Size() int

func (*HealthCheckResponse) XXX_Unmarshal 

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

type HealthCheckResponse_ServingStatus 

type HealthCheckResponse_ServingStatus int32
const (
	HealthCheckResponse_UNKNOWN     HealthCheckResponse_ServingStatus = 0
	HealthCheckResponse_SERVING     HealthCheckResponse_ServingStatus = 1
	HealthCheckResponse_NOT_SERVING HealthCheckResponse_ServingStatus = 2
)

func (HealthCheckResponse_ServingStatus) EnumDescriptor 

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

func (HealthCheckResponse_ServingStatus) String 

func (x HealthCheckResponse_ServingStatus) String() string

type QueryCtl 

type QueryCtl struct {
	Timeout              int64              `protobuf:"varint,1,opt,name=Timeout,proto3" json:"Timeout,omitempty"`
	Consistency          *ConsistencyParams `protobuf:"bytes,2,opt,name=Consistency,proto3" json:"Consistency,omitempty"`
	PartitionSelection   string             `protobuf:"bytes,3,opt,name=PartitionSelection,proto3" json:"PartitionSelection,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

QueryCtl defines the JSON parameters that control query execution and which are independent of any specific pindex type.

func (*QueryCtl) Descriptor 

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

func (*QueryCtl) GetConsistency 

func (m *QueryCtl) GetConsistency() *ConsistencyParams

func (*QueryCtl) GetPartitionSelection 

func (m *QueryCtl) GetPartitionSelection() string

func (*QueryCtl) GetTimeout 

func (m *QueryCtl) GetTimeout() int64

func (*QueryCtl) ProtoMessage 

func (*QueryCtl) ProtoMessage()

func (*QueryCtl) Reset 

func (m *QueryCtl) Reset()

func (*QueryCtl) String 

func (m *QueryCtl) String() string

func (*QueryCtl) XXX_DiscardUnknown 

func (m *QueryCtl) XXX_DiscardUnknown()

func (*QueryCtl) XXX_Marshal 

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

func (*QueryCtl) XXX_Merge 

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

func (*QueryCtl) XXX_Size 

func (m *QueryCtl) XXX_Size() int

func (*QueryCtl) XXX_Unmarshal 

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

type QueryCtlParams 

type QueryCtlParams struct {
	Ctl                  *QueryCtl `protobuf:"bytes,1,opt,name=Ctl,proto3" json:"Ctl,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

QueryCtlParams defines the JSON that includes the "ctl" part of a query request. These "ctl" query request parameters are independent of any specific pindex type.

func (*QueryCtlParams) Descriptor 

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

func (*QueryCtlParams) GetCtl 

func (m *QueryCtlParams) GetCtl() *QueryCtl

func (*QueryCtlParams) ProtoMessage 

func (*QueryCtlParams) ProtoMessage()

func (*QueryCtlParams) Reset 

func (m *QueryCtlParams) Reset()

func (*QueryCtlParams) String 

func (m *QueryCtlParams) String() string

func (*QueryCtlParams) XXX_DiscardUnknown 

func (m *QueryCtlParams) XXX_DiscardUnknown()

func (*QueryCtlParams) XXX_Marshal 

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

func (*QueryCtlParams) XXX_Merge 

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

func (*QueryCtlParams) XXX_Size 

func (m *QueryCtlParams) XXX_Size() int

func (*QueryCtlParams) XXX_Unmarshal 

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

type QueryPIndexes 

type QueryPIndexes struct {
	// An empty or nil PIndexNames means the query should use all
	// the pindexes of the index.
	PIndexNames          []string `protobuf:"bytes,1,rep,name=PIndexNames,proto3" json:"PIndexNames,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QueryPIndexes) Descriptor 

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

func (*QueryPIndexes) GetPIndexNames 

func (m *QueryPIndexes) GetPIndexNames() []string

func (*QueryPIndexes) ProtoMessage 

func (*QueryPIndexes) ProtoMessage()

func (*QueryPIndexes) Reset 

func (m *QueryPIndexes) Reset()

func (*QueryPIndexes) String 

func (m *QueryPIndexes) String() string

func (*QueryPIndexes) XXX_DiscardUnknown 

func (m *QueryPIndexes) XXX_DiscardUnknown()

func (*QueryPIndexes) XXX_Marshal 

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

func (*QueryPIndexes) XXX_Merge 

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

func (*QueryPIndexes) XXX_Size 

func (m *QueryPIndexes) XXX_Size() int

func (*QueryPIndexes) XXX_Unmarshal 

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

type SearchRequest 

type SearchRequest struct {
	Contents             []byte   `protobuf:"bytes,1,opt,name=Contents,proto3" json:"Contents,omitempty"`
	IndexName            string   `protobuf:"bytes,2,opt,name=IndexName,proto3" json:"IndexName,omitempty"`
	IndexUUID            string   `protobuf:"bytes,3,opt,name=IndexUUID,proto3" json:"IndexUUID,omitempty"`
	Stream               bool     `protobuf:"varint,4,opt,name=Stream,proto3" json:"Stream,omitempty"`
	QueryCtlParams       []byte   `protobuf:"bytes,5,opt,name=QueryCtlParams,proto3" json:"QueryCtlParams,omitempty"`
	QueryPIndexes        []byte   `protobuf:"bytes,6,opt,name=QueryPIndexes,proto3" json:"QueryPIndexes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SearchRequest) Descriptor 

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

func (*SearchRequest) GetContents 

func (m *SearchRequest) GetContents() []byte

func (*SearchRequest) GetIndexName 

func (m *SearchRequest) GetIndexName() string

func (*SearchRequest) GetIndexUUID 

func (m *SearchRequest) GetIndexUUID() string

func (*SearchRequest) GetQueryCtlParams 

func (m *SearchRequest) GetQueryCtlParams() []byte

func (*SearchRequest) GetQueryPIndexes 

func (m *SearchRequest) GetQueryPIndexes() []byte

func (*SearchRequest) GetStream 

func (m *SearchRequest) GetStream() bool

func (*SearchRequest) ProtoMessage 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) Reset 

func (m *SearchRequest) Reset()

func (*SearchRequest) String 

func (m *SearchRequest) String() string

func (*SearchRequest) XXX_DiscardUnknown 

func (m *SearchRequest) XXX_DiscardUnknown()

func (*SearchRequest) XXX_Marshal 

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

func (*SearchRequest) XXX_Merge 

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

func (*SearchRequest) XXX_Size 

func (m *SearchRequest) XXX_Size() int

func (*SearchRequest) XXX_Unmarshal 

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

type SearchResult 

type SearchResult struct {
	Contents             []byte   `protobuf:"bytes,1,opt,name=Contents,proto3" json:"Contents,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SearchResult) Descriptor 

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

func (*SearchResult) GetContents 

func (m *SearchResult) GetContents() []byte

func (*SearchResult) ProtoMessage 

func (*SearchResult) ProtoMessage()

func (*SearchResult) Reset 

func (m *SearchResult) Reset()

func (*SearchResult) String 

func (m *SearchResult) String() string

func (*SearchResult) XXX_DiscardUnknown 

func (m *SearchResult) XXX_DiscardUnknown()

func (*SearchResult) XXX_Marshal 

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

func (*SearchResult) XXX_Merge 

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

func (*SearchResult) XXX_Size 

func (m *SearchResult) XXX_Size() int

func (*SearchResult) XXX_Unmarshal 

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

type SearchServiceClient 

type SearchServiceClient interface {
	// external rpcs, for rpc clients
	Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (SearchService_SearchClient, error)
	Check(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
	DocCount(ctx context.Context, in *DocCountRequest, opts ...grpc.CallOption) (*DocCountResult, error)
}

SearchServiceClient is the client API for SearchService service.

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

func NewSearchServiceClient 

func NewSearchServiceClient(cc *grpc.ClientConn) SearchServiceClient

type SearchServiceServer 

type SearchServiceServer interface {
	// external rpcs, for rpc clients
	Search(*SearchRequest, SearchService_SearchServer) error
	Check(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
	DocCount(context.Context, *DocCountRequest) (*DocCountResult, error)
}

SearchServiceServer is the server API for SearchService service.

type SearchService_SearchClient 

type SearchService_SearchClient interface {
	Recv() (*StreamSearchResults, error)
	grpc.ClientStream
}

type SearchService_SearchServer 

type SearchService_SearchServer interface {
	Send(*StreamSearchResults) error
	grpc.ServerStream
}

type StreamSearchResults 

type StreamSearchResults struct {
	// Types that are valid to be assigned to Contents:
	//	*StreamSearchResults_Hits
	//	*StreamSearchResults_SearchResult
	Contents             isStreamSearchResults_Contents `protobuf_oneof:"Contents"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

A stream SearchResult describes the streaming results of executing a SearchRequest.

func (*StreamSearchResults) Descriptor 

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

func (*StreamSearchResults) GetContents 

func (m *StreamSearchResults) GetContents() isStreamSearchResults_Contents

func (*StreamSearchResults) GetHits 

func (m *StreamSearchResults) GetHits() *StreamSearchResults_Batch

func (*StreamSearchResults) GetSearchResult 

func (m *StreamSearchResults) GetSearchResult() []byte

func (*StreamSearchResults) ProtoMessage 

func (*StreamSearchResults) ProtoMessage()

func (*StreamSearchResults) Reset 

func (m *StreamSearchResults) Reset()

func (*StreamSearchResults) String 

func (m *StreamSearchResults) String() string

func (*StreamSearchResults) XXX_DiscardUnknown 

func (m *StreamSearchResults) XXX_DiscardUnknown()

func (*StreamSearchResults) XXX_Marshal 

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

func (*StreamSearchResults) XXX_Merge 

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

func (*StreamSearchResults) XXX_OneofFuncs 

func (*StreamSearchResults) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*StreamSearchResults) XXX_Size 

func (m *StreamSearchResults) XXX_Size() int

func (*StreamSearchResults) XXX_Unmarshal 

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

type StreamSearchResults_Batch 

type StreamSearchResults_Batch struct {
	Bytes                []byte   `protobuf:"bytes,1,opt,name=Bytes,proto3" json:"Bytes,omitempty"`
	Offsets              []uint64 `protobuf:"varint,2,rep,packed,name=Offsets,proto3" json:"Offsets,omitempty"`
	Total                uint64   `protobuf:"varint,3,opt,name=Total,proto3" json:"Total,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamSearchResults_Batch) Descriptor 

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

func (*StreamSearchResults_Batch) GetBytes 

func (m *StreamSearchResults_Batch) GetBytes() []byte

func (*StreamSearchResults_Batch) GetOffsets 

func (m *StreamSearchResults_Batch) GetOffsets() []uint64

func (*StreamSearchResults_Batch) GetTotal 

func (m *StreamSearchResults_Batch) GetTotal() uint64

func (*StreamSearchResults_Batch) ProtoMessage 

func (*StreamSearchResults_Batch) ProtoMessage()

func (*StreamSearchResults_Batch) Reset 

func (m *StreamSearchResults_Batch) Reset()

func (*StreamSearchResults_Batch) String 

func (m *StreamSearchResults_Batch) String() string

func (*StreamSearchResults_Batch) XXX_DiscardUnknown 

func (m *StreamSearchResults_Batch) XXX_DiscardUnknown()

func (*StreamSearchResults_Batch) XXX_Marshal 

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

func (*StreamSearchResults_Batch) XXX_Merge 

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

func (*StreamSearchResults_Batch) XXX_Size 

func (m *StreamSearchResults_Batch) XXX_Size() int

func (*StreamSearchResults_Batch) XXX_Unmarshal 

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

type StreamSearchResults_Hits 

type StreamSearchResults_Hits struct {
	Hits *StreamSearchResults_Batch `protobuf:"bytes,1,opt,name=Hits,proto3,oneof"`
}

type StreamSearchResults_SearchResult 

type StreamSearchResults_SearchResult struct {
	SearchResult []byte `protobuf:"bytes,2,opt,name=SearchResult,proto3,oneof"`
}

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.