proto

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Jan 20, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	LivenessState_name = map[int32]string{
		0: "LIVENESS_STATE_UNKNOWN",
		1: "LIVENESS_STATE_ALIVE",
		2: "LIVENESS_STATE_DEAD",
	}
	LivenessState_value = map[string]int32{
		"LIVENESS_STATE_UNKNOWN": 0,
		"LIVENESS_STATE_ALIVE":   1,
		"LIVENESS_STATE_DEAD":    2,
	}
)

Enum value maps for LivenessState.

View Source 
var (
	ReadinessState_name = map[int32]string{
		0: "READINESS_STATE_UNKNOWN",
		1: "READINESS_STATE_READY",
		2: "READINESS_STATE_NOT_READY",
	}
	ReadinessState_value = map[string]int32{
		"READINESS_STATE_UNKNOWN":   0,
		"READINESS_STATE_READY":     1,
		"READINESS_STATE_NOT_READY": 2,
	}
)

Enum value maps for ReadinessState.

View Source 
var (
	NodeRole_name = map[int32]string{
		0: "NODE_ROLE_UNKNOWN",
		1: "NODE_ROLE_INDEXER",
		2: "NODE_ROLE_SEARCHER",
	}
	NodeRole_value = map[string]int32{
		"NODE_ROLE_UNKNOWN":  0,
		"NODE_ROLE_INDEXER":  1,
		"NODE_ROLE_SEARCHER": 2,
	}
)

Enum value maps for NodeRole.

View Source 
var (
	NodeState_name = map[int32]string{
		0: "NODE_STATE_UNKNOWN",
		1: "NODE_STATE_ALIVE",
		2: "NODE_STATE_SUSPECT",
		3: "NODE_STATE_DEAD",
		4: "NODE_STATE_LEFT",
	}
	NodeState_value = map[string]int32{
		"NODE_STATE_UNKNOWN": 0,
		"NODE_STATE_ALIVE":   1,
		"NODE_STATE_SUSPECT": 2,
		"NODE_STATE_DEAD":    3,
		"NODE_STATE_LEFT":    4,
	}
)

Enum value maps for NodeState.

View Source 
var File_proto_index_proto protoreflect.FileDescriptor
View Source 
var Index_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "index.Index",
	HandlerType: (*IndexServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "LivenessCheck",
			Handler:    _Index_LivenessCheck_Handler,
		},
		{
			MethodName: "ReadinessCheck",
			Handler:    _Index_ReadinessCheck_Handler,
		},
		{
			MethodName: "Metrics",
			Handler:    _Index_Metrics_Handler,
		},
		{
			MethodName: "Cluster",
			Handler:    _Index_Cluster_Handler,
		},
		{
			MethodName: "CreateIndex",
			Handler:    _Index_CreateIndex_Handler,
		},
		{
			MethodName: "DeleteIndex",
			Handler:    _Index_DeleteIndex_Handler,
		},
		{
			MethodName: "AddDocuments",
			Handler:    _Index_AddDocuments_Handler,
		},
		{
			MethodName: "DeleteDocuments",
			Handler:    _Index_DeleteDocuments_Handler,
		},
		{
			MethodName: "Search",
			Handler:    _Index_Search_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/index.proto",
}

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

Functions

func RegisterIndexServer 

func RegisterIndexServer(s grpc.ServiceRegistrar, srv IndexServer)

Types

type AddDocumentsRequest 

type AddDocumentsRequest struct {
	IndexName string      `protobuf:"bytes,1,opt,name=index_name,proto3" json:"index_name,omitempty"`
	ShardName string      `protobuf:"bytes,2,opt,name=shard_name,proto3" json:"shard_name,omitempty"`
	Documents []*Document `protobuf:"bytes,3,rep,name=documents,proto3" json:"documents,omitempty"`
	// contains filtered or unexported fields
}

func (*AddDocumentsRequest) Descriptor deprecated 

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

Deprecated: Use AddDocumentsRequest.ProtoReflect.Descriptor instead.

func (*AddDocumentsRequest) GetDocuments 

func (x *AddDocumentsRequest) GetDocuments() []*Document

func (*AddDocumentsRequest) GetIndexName 

func (x *AddDocumentsRequest) GetIndexName() string

func (*AddDocumentsRequest) GetShardName 

func (x *AddDocumentsRequest) GetShardName() string

func (*AddDocumentsRequest) ProtoMessage 

func (*AddDocumentsRequest) ProtoMessage()

func (*AddDocumentsRequest) ProtoReflect 

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

func (*AddDocumentsRequest) Reset 

func (x *AddDocumentsRequest) Reset()

func (*AddDocumentsRequest) String 

func (x *AddDocumentsRequest) String() string

type AddDocumentsResponse 

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

func (*AddDocumentsResponse) Descriptor deprecated 

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

Deprecated: Use AddDocumentsResponse.ProtoReflect.Descriptor instead.

func (*AddDocumentsResponse) ProtoMessage 

func (*AddDocumentsResponse) ProtoMessage()

func (*AddDocumentsResponse) ProtoReflect 

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

func (*AddDocumentsResponse) Reset 

func (x *AddDocumentsResponse) Reset()

func (*AddDocumentsResponse) String 

func (x *AddDocumentsResponse) String() string

type AggregationRequest added in v0.2.0 

type AggregationRequest struct {
	Type    string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Options []byte `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*AggregationRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use AggregationRequest.ProtoReflect.Descriptor instead.

func (*AggregationRequest) GetOptions added in v0.2.0 

func (x *AggregationRequest) GetOptions() []byte

func (*AggregationRequest) GetType added in v0.2.0 

func (x *AggregationRequest) GetType() string

func (*AggregationRequest) ProtoMessage added in v0.2.0 

func (*AggregationRequest) ProtoMessage()

func (*AggregationRequest) ProtoReflect added in v0.2.0 

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

func (*AggregationRequest) Reset added in v0.2.0 

func (x *AggregationRequest) Reset()

func (*AggregationRequest) String added in v0.2.0 

func (x *AggregationRequest) String() string

type AggregationResponse added in v0.2.0 

type AggregationResponse struct {
	Buckets map[string]float64 `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AggregationResponse) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use AggregationResponse.ProtoReflect.Descriptor instead.

func (*AggregationResponse) GetBuckets added in v0.2.0 

func (x *AggregationResponse) GetBuckets() map[string]float64

func (*AggregationResponse) ProtoMessage added in v0.2.0 

func (*AggregationResponse) ProtoMessage()

func (*AggregationResponse) ProtoReflect added in v0.2.0 

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

func (*AggregationResponse) Reset added in v0.2.0 

func (x *AggregationResponse) Reset()

func (*AggregationResponse) String added in v0.2.0 

func (x *AggregationResponse) String() string

type ClusterRequest 

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

func (*ClusterRequest) Descriptor deprecated 

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

Deprecated: Use ClusterRequest.ProtoReflect.Descriptor instead.

func (*ClusterRequest) ProtoMessage 

func (*ClusterRequest) ProtoMessage()

func (*ClusterRequest) ProtoReflect 

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

func (*ClusterRequest) Reset 

func (x *ClusterRequest) Reset()

func (*ClusterRequest) String 

func (x *ClusterRequest) String() string

type ClusterResponse 

type ClusterResponse struct {
	Nodes              map[string]*Node          `` /* 151-byte string literal not displayed */
	Indexes            map[string]*IndexMetadata `` /* 155-byte string literal not displayed */
	IndexerAssignment  []byte                    `protobuf:"bytes,3,opt,name=indexer_assignment,json=indexerAssignment,proto3" json:"indexer_assignment,omitempty"`
	SearcherAssignment []byte                    `protobuf:"bytes,4,opt,name=searcher_assignment,json=searcherAssignment,proto3" json:"searcher_assignment,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterResponse) Descriptor deprecated 

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

Deprecated: Use ClusterResponse.ProtoReflect.Descriptor instead.

func (*ClusterResponse) GetIndexerAssignment 

func (x *ClusterResponse) GetIndexerAssignment() []byte

func (*ClusterResponse) GetIndexes 

func (x *ClusterResponse) GetIndexes() map[string]*IndexMetadata

func (*ClusterResponse) GetNodes 

func (x *ClusterResponse) GetNodes() map[string]*Node

func (*ClusterResponse) GetSearcherAssignment 

func (x *ClusterResponse) GetSearcherAssignment() []byte

func (*ClusterResponse) ProtoMessage 

func (*ClusterResponse) ProtoMessage()

func (*ClusterResponse) ProtoReflect 

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

func (*ClusterResponse) Reset 

func (x *ClusterResponse) Reset()

func (*ClusterResponse) String 

func (x *ClusterResponse) String() string

type CreateIndexRequest 

type CreateIndexRequest struct {
	IndexName          string `protobuf:"bytes,1,opt,name=index_name,proto3" json:"index_name,omitempty"`
	IndexUri           string `protobuf:"bytes,2,opt,name=index_uri,proto3" json:"index_uri,omitempty"`
	LockUri            string `protobuf:"bytes,3,opt,name=lock_uri,proto3" json:"lock_uri,omitempty"`
	IndexMapping       []byte `protobuf:"bytes,4,opt,name=index_mapping,proto3" json:"index_mapping,omitempty"`
	NumShards          uint32 `protobuf:"varint,5,opt,name=num_shards,proto3" json:"num_shards,omitempty"`
	DefaultSearchField string `protobuf:"bytes,6,opt,name=default_search_field,proto3" json:"default_search_field,omitempty"`
	DefaultAnalyzer    []byte `protobuf:"bytes,7,opt,name=default_analyzer,proto3" json:"default_analyzer,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateIndexRequest) Descriptor deprecated 

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

Deprecated: Use CreateIndexRequest.ProtoReflect.Descriptor instead.

func (*CreateIndexRequest) GetDefaultAnalyzer added in v0.2.0 

func (x *CreateIndexRequest) GetDefaultAnalyzer() []byte

func (*CreateIndexRequest) GetDefaultSearchField added in v0.2.0 

func (x *CreateIndexRequest) GetDefaultSearchField() string

func (*CreateIndexRequest) GetIndexMapping 

func (x *CreateIndexRequest) GetIndexMapping() []byte

func (*CreateIndexRequest) GetIndexName 

func (x *CreateIndexRequest) GetIndexName() string

func (*CreateIndexRequest) GetIndexUri 

func (x *CreateIndexRequest) GetIndexUri() string

func (*CreateIndexRequest) GetLockUri 

func (x *CreateIndexRequest) GetLockUri() string

func (*CreateIndexRequest) GetNumShards 

func (x *CreateIndexRequest) GetNumShards() uint32

func (*CreateIndexRequest) ProtoMessage 

func (*CreateIndexRequest) ProtoMessage()

func (*CreateIndexRequest) ProtoReflect 

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

func (*CreateIndexRequest) Reset 

func (x *CreateIndexRequest) Reset()

func (*CreateIndexRequest) String 

func (x *CreateIndexRequest) String() string

type CreateIndexResponse 

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

func (*CreateIndexResponse) Descriptor deprecated 

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

Deprecated: Use CreateIndexResponse.ProtoReflect.Descriptor instead.

func (*CreateIndexResponse) ProtoMessage 

func (*CreateIndexResponse) ProtoMessage()

func (*CreateIndexResponse) ProtoReflect 

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

func (*CreateIndexResponse) Reset 

func (x *CreateIndexResponse) Reset()

func (*CreateIndexResponse) String 

func (x *CreateIndexResponse) String() string

type DeleteDocumentsRequest 

type DeleteDocumentsRequest struct {
	IndexName string   `protobuf:"bytes,1,opt,name=index_name,proto3" json:"index_name,omitempty"`
	ShardName string   `protobuf:"bytes,2,opt,name=shard_name,proto3" json:"shard_name,omitempty"`
	Ids       []string `protobuf:"bytes,3,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteDocumentsRequest) Descriptor deprecated 

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

Deprecated: Use DeleteDocumentsRequest.ProtoReflect.Descriptor instead.

func (*DeleteDocumentsRequest) GetIds 

func (x *DeleteDocumentsRequest) GetIds() []string

func (*DeleteDocumentsRequest) GetIndexName 

func (x *DeleteDocumentsRequest) GetIndexName() string

func (*DeleteDocumentsRequest) GetShardName 

func (x *DeleteDocumentsRequest) GetShardName() string

func (*DeleteDocumentsRequest) ProtoMessage 

func (*DeleteDocumentsRequest) ProtoMessage()

func (*DeleteDocumentsRequest) ProtoReflect 

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

func (*DeleteDocumentsRequest) Reset 

func (x *DeleteDocumentsRequest) Reset()

func (*DeleteDocumentsRequest) String 

func (x *DeleteDocumentsRequest) String() string

type DeleteDocumentsResponse 

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

func (*DeleteDocumentsResponse) Descriptor deprecated 

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

Deprecated: Use DeleteDocumentsResponse.ProtoReflect.Descriptor instead.

func (*DeleteDocumentsResponse) ProtoMessage 

func (*DeleteDocumentsResponse) ProtoMessage()

func (*DeleteDocumentsResponse) ProtoReflect 

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

func (*DeleteDocumentsResponse) Reset 

func (x *DeleteDocumentsResponse) Reset()

func (*DeleteDocumentsResponse) String 

func (x *DeleteDocumentsResponse) String() string

type DeleteIndexRequest 

type DeleteIndexRequest struct {
	IndexName string `protobuf:"bytes,1,opt,name=index_name,proto3" json:"index_name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteIndexRequest) Descriptor deprecated 

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

Deprecated: Use DeleteIndexRequest.ProtoReflect.Descriptor instead.

func (*DeleteIndexRequest) GetIndexName 

func (x *DeleteIndexRequest) GetIndexName() string

func (*DeleteIndexRequest) ProtoMessage 

func (*DeleteIndexRequest) ProtoMessage()

func (*DeleteIndexRequest) ProtoReflect 

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

func (*DeleteIndexRequest) Reset 

func (x *DeleteIndexRequest) Reset()

func (*DeleteIndexRequest) String 

func (x *DeleteIndexRequest) String() string

type DeleteIndexResponse 

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

func (*DeleteIndexResponse) Descriptor deprecated 

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

Deprecated: Use DeleteIndexResponse.ProtoReflect.Descriptor instead.

func (*DeleteIndexResponse) ProtoMessage 

func (*DeleteIndexResponse) ProtoMessage()

func (*DeleteIndexResponse) ProtoReflect 

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

func (*DeleteIndexResponse) Reset 

func (x *DeleteIndexResponse) Reset()

func (*DeleteIndexResponse) String 

func (x *DeleteIndexResponse) String() string

type Document 

type Document struct {
	Id        string  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Score     float64 `protobuf:"fixed64,2,opt,name=score,proto3" json:"score,omitempty"`
	Timestamp int64   `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Fields    []byte  `protobuf:"bytes,4,opt,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

func (*Document) Descriptor deprecated 

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

Deprecated: Use Document.ProtoReflect.Descriptor instead.

func (*Document) GetFields 

func (x *Document) GetFields() []byte

func (*Document) GetId 

func (x *Document) GetId() string

func (*Document) GetScore 

func (x *Document) GetScore() float64

func (*Document) GetTimestamp added in v0.2.0 

func (x *Document) GetTimestamp() int64

func (*Document) ProtoMessage 

func (*Document) ProtoMessage()

func (*Document) ProtoReflect 

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

func (*Document) Reset 

func (x *Document) Reset()

func (*Document) String 

func (x *Document) String() string

type IndexClient 

type IndexClient interface {
	LivenessCheck(ctx context.Context, in *LivenessCheckRequest, opts ...grpc.CallOption) (*LivenessCheckResponse, error)
	ReadinessCheck(ctx context.Context, in *ReadinessCheckRequest, opts ...grpc.CallOption) (*ReadinessCheckResponse, error)
	Metrics(ctx context.Context, in *MetricsRequest, opts ...grpc.CallOption) (*MetricsResponse, error)
	Cluster(ctx context.Context, in *ClusterRequest, opts ...grpc.CallOption) (*ClusterResponse, error)
	CreateIndex(ctx context.Context, in *CreateIndexRequest, opts ...grpc.CallOption) (*CreateIndexResponse, error)
	DeleteIndex(ctx context.Context, in *DeleteIndexRequest, opts ...grpc.CallOption) (*DeleteIndexResponse, error)
	AddDocuments(ctx context.Context, in *AddDocumentsRequest, opts ...grpc.CallOption) (*AddDocumentsResponse, error)
	DeleteDocuments(ctx context.Context, in *DeleteDocumentsRequest, opts ...grpc.CallOption) (*DeleteDocumentsResponse, error)
	Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResponse, error)
}

IndexClient is the client API for Index 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 NewIndexClient 

func NewIndexClient(cc grpc.ClientConnInterface) IndexClient

type IndexMetadata 

type IndexMetadata struct {
	IndexUri     string                    `protobuf:"bytes,1,opt,name=index_uri,json=indexUri,proto3" json:"index_uri,omitempty"`
	IndexLockUri string                    `protobuf:"bytes,2,opt,name=index_lock_uri,json=indexLockUri,proto3" json:"index_lock_uri,omitempty"`
	Shards       map[string]*ShardMetadata `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*IndexMetadata) Descriptor deprecated 

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

Deprecated: Use IndexMetadata.ProtoReflect.Descriptor instead.

func (*IndexMetadata) GetIndexLockUri 

func (x *IndexMetadata) GetIndexLockUri() string

func (*IndexMetadata) GetIndexUri 

func (x *IndexMetadata) GetIndexUri() string

func (*IndexMetadata) GetShards 

func (x *IndexMetadata) GetShards() map[string]*ShardMetadata

func (*IndexMetadata) ProtoMessage 

func (*IndexMetadata) ProtoMessage()

func (*IndexMetadata) ProtoReflect 

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

func (*IndexMetadata) Reset 

func (x *IndexMetadata) Reset()

func (*IndexMetadata) String 

func (x *IndexMetadata) String() string

type IndexServer 

type IndexServer interface {
	LivenessCheck(context.Context, *LivenessCheckRequest) (*LivenessCheckResponse, error)
	ReadinessCheck(context.Context, *ReadinessCheckRequest) (*ReadinessCheckResponse, error)
	Metrics(context.Context, *MetricsRequest) (*MetricsResponse, error)
	Cluster(context.Context, *ClusterRequest) (*ClusterResponse, error)
	CreateIndex(context.Context, *CreateIndexRequest) (*CreateIndexResponse, error)
	DeleteIndex(context.Context, *DeleteIndexRequest) (*DeleteIndexResponse, error)
	AddDocuments(context.Context, *AddDocumentsRequest) (*AddDocumentsResponse, error)
	DeleteDocuments(context.Context, *DeleteDocumentsRequest) (*DeleteDocumentsResponse, error)
	Search(context.Context, *SearchRequest) (*SearchResponse, error)
	// contains filtered or unexported methods
}

IndexServer is the server API for Index service. All implementations must embed UnimplementedIndexServer for forward compatibility

type LivenessCheckRequest 

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

func (*LivenessCheckRequest) Descriptor deprecated 

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

Deprecated: Use LivenessCheckRequest.ProtoReflect.Descriptor instead.

func (*LivenessCheckRequest) ProtoMessage 

func (*LivenessCheckRequest) ProtoMessage()

func (*LivenessCheckRequest) ProtoReflect 

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

func (*LivenessCheckRequest) Reset 

func (x *LivenessCheckRequest) Reset()

func (*LivenessCheckRequest) String 

func (x *LivenessCheckRequest) String() string

type LivenessCheckResponse 

type LivenessCheckResponse struct {
	State LivenessState `protobuf:"varint,1,opt,name=state,proto3,enum=index.LivenessState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*LivenessCheckResponse) Descriptor deprecated 

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

Deprecated: Use LivenessCheckResponse.ProtoReflect.Descriptor instead.

func (*LivenessCheckResponse) GetState 

func (x *LivenessCheckResponse) GetState() LivenessState

func (*LivenessCheckResponse) ProtoMessage 

func (*LivenessCheckResponse) ProtoMessage()

func (*LivenessCheckResponse) ProtoReflect 

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

func (*LivenessCheckResponse) Reset 

func (x *LivenessCheckResponse) Reset()

func (*LivenessCheckResponse) String 

func (x *LivenessCheckResponse) String() string

type LivenessState 

type LivenessState int32
const (
	LivenessState_LIVENESS_STATE_UNKNOWN LivenessState = 0
	LivenessState_LIVENESS_STATE_ALIVE   LivenessState = 1
	LivenessState_LIVENESS_STATE_DEAD    LivenessState = 2
)

func (LivenessState) Descriptor 

func (LivenessState) Descriptor() protoreflect.EnumDescriptor

func (LivenessState) Enum 

func (x LivenessState) Enum() *LivenessState

func (LivenessState) EnumDescriptor deprecated 

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

Deprecated: Use LivenessState.Descriptor instead.

func (LivenessState) Number 

func (x LivenessState) Number() protoreflect.EnumNumber

func (LivenessState) String 

func (x LivenessState) String() string

func (LivenessState) Type 

func (LivenessState) Type() protoreflect.EnumType

type MetricsRequest 

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

func (*MetricsRequest) Descriptor deprecated 

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

Deprecated: Use MetricsRequest.ProtoReflect.Descriptor instead.

func (*MetricsRequest) ProtoMessage 

func (*MetricsRequest) ProtoMessage()

func (*MetricsRequest) ProtoReflect 

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

func (*MetricsRequest) Reset 

func (x *MetricsRequest) Reset()

func (*MetricsRequest) String 

func (x *MetricsRequest) String() string

type MetricsResponse 

type MetricsResponse struct {
	Metrics []byte `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricsResponse) Descriptor deprecated 

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

Deprecated: Use MetricsResponse.ProtoReflect.Descriptor instead.

func (*MetricsResponse) GetMetrics 

func (x *MetricsResponse) GetMetrics() []byte

func (*MetricsResponse) ProtoMessage 

func (*MetricsResponse) ProtoMessage()

func (*MetricsResponse) ProtoReflect 

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

func (*MetricsResponse) Reset 

func (x *MetricsResponse) Reset()

func (*MetricsResponse) String 

func (x *MetricsResponse) String() string

type Node 

type Node struct {
	Addr  string    `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	Port  uint32    `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	Meta  *NodeMeta `protobuf:"bytes,3,opt,name=meta,proto3" json:"meta,omitempty"`
	State NodeState `protobuf:"varint,4,opt,name=state,proto3,enum=index.NodeState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*Node) Descriptor deprecated 

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

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetAddr 

func (x *Node) GetAddr() string

func (*Node) GetMeta 

func (x *Node) GetMeta() *NodeMeta

func (*Node) GetPort 

func (x *Node) GetPort() uint32

func (*Node) GetState 

func (x *Node) GetState() NodeState

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect 

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

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) String 

func (x *Node) String() string

type NodeMeta 

type NodeMeta struct {
	GrpcPort uint32     `protobuf:"varint,1,opt,name=grpc_port,json=grpcPort,proto3" json:"grpc_port,omitempty"`
	HttpPort uint32     `protobuf:"varint,2,opt,name=http_port,json=httpPort,proto3" json:"http_port,omitempty"`
	Roles    []NodeRole `protobuf:"varint,3,rep,packed,name=roles,proto3,enum=index.NodeRole" json:"roles,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeMeta) Descriptor deprecated 

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

Deprecated: Use NodeMeta.ProtoReflect.Descriptor instead.

func (*NodeMeta) GetGrpcPort 

func (x *NodeMeta) GetGrpcPort() uint32

func (*NodeMeta) GetHttpPort 

func (x *NodeMeta) GetHttpPort() uint32

func (*NodeMeta) GetRoles 

func (x *NodeMeta) GetRoles() []NodeRole

func (*NodeMeta) ProtoMessage 

func (*NodeMeta) ProtoMessage()

func (*NodeMeta) ProtoReflect 

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

func (*NodeMeta) Reset 

func (x *NodeMeta) Reset()

func (*NodeMeta) String 

func (x *NodeMeta) String() string

type NodeRole 

type NodeRole int32
const (
	NodeRole_NODE_ROLE_UNKNOWN  NodeRole = 0
	NodeRole_NODE_ROLE_INDEXER  NodeRole = 1
	NodeRole_NODE_ROLE_SEARCHER NodeRole = 2
)

func (NodeRole) Descriptor 

func (NodeRole) Descriptor() protoreflect.EnumDescriptor

func (NodeRole) Enum 

func (x NodeRole) Enum() *NodeRole

func (NodeRole) EnumDescriptor deprecated 

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

Deprecated: Use NodeRole.Descriptor instead.

func (NodeRole) Number 

func (x NodeRole) Number() protoreflect.EnumNumber

func (NodeRole) String 

func (x NodeRole) String() string

func (NodeRole) Type 

func (NodeRole) Type() protoreflect.EnumType

type NodeState 

type NodeState int32
const (
	NodeState_NODE_STATE_UNKNOWN NodeState = 0
	NodeState_NODE_STATE_ALIVE   NodeState = 1
	NodeState_NODE_STATE_SUSPECT NodeState = 2
	NodeState_NODE_STATE_DEAD    NodeState = 3
	NodeState_NODE_STATE_LEFT    NodeState = 4
)

func (NodeState) Descriptor 

func (NodeState) Descriptor() protoreflect.EnumDescriptor

func (NodeState) Enum 

func (x NodeState) Enum() *NodeState

func (NodeState) EnumDescriptor deprecated 

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

Deprecated: Use NodeState.Descriptor instead.

func (NodeState) Number 

func (x NodeState) Number() protoreflect.EnumNumber

func (NodeState) String 

func (x NodeState) String() string

func (NodeState) Type 

func (NodeState) Type() protoreflect.EnumType

type ReadinessCheckRequest 

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

func (*ReadinessCheckRequest) Descriptor deprecated 

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

Deprecated: Use ReadinessCheckRequest.ProtoReflect.Descriptor instead.

func (*ReadinessCheckRequest) ProtoMessage 

func (*ReadinessCheckRequest) ProtoMessage()

func (*ReadinessCheckRequest) ProtoReflect 

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

func (*ReadinessCheckRequest) Reset 

func (x *ReadinessCheckRequest) Reset()

func (*ReadinessCheckRequest) String 

func (x *ReadinessCheckRequest) String() string

type ReadinessCheckResponse 

type ReadinessCheckResponse struct {
	State ReadinessState `protobuf:"varint,1,opt,name=state,proto3,enum=index.ReadinessState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadinessCheckResponse) Descriptor deprecated 

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

Deprecated: Use ReadinessCheckResponse.ProtoReflect.Descriptor instead.

func (*ReadinessCheckResponse) GetState 

func (x *ReadinessCheckResponse) GetState() ReadinessState

func (*ReadinessCheckResponse) ProtoMessage 

func (*ReadinessCheckResponse) ProtoMessage()

func (*ReadinessCheckResponse) ProtoReflect 

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

func (*ReadinessCheckResponse) Reset 

func (x *ReadinessCheckResponse) Reset()

func (*ReadinessCheckResponse) String 

func (x *ReadinessCheckResponse) String() string

type ReadinessState 

type ReadinessState int32
const (
	ReadinessState_READINESS_STATE_UNKNOWN   ReadinessState = 0
	ReadinessState_READINESS_STATE_READY     ReadinessState = 1
	ReadinessState_READINESS_STATE_NOT_READY ReadinessState = 2
)

func (ReadinessState) Descriptor 

func (ReadinessState) Descriptor() protoreflect.EnumDescriptor

func (ReadinessState) Enum 

func (x ReadinessState) Enum() *ReadinessState

func (ReadinessState) EnumDescriptor deprecated 

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

Deprecated: Use ReadinessState.Descriptor instead.

func (ReadinessState) Number 

func (x ReadinessState) Number() protoreflect.EnumNumber

func (ReadinessState) String 

func (x ReadinessState) String() string

func (ReadinessState) Type 

func (ReadinessState) Type() protoreflect.EnumType

type SearchRequest 

type SearchRequest struct {
	IndexName    string                         `protobuf:"bytes,1,opt,name=index_name,proto3" json:"index_name,omitempty"`
	ShardNames   []string                       `protobuf:"bytes,2,rep,name=shard_names,proto3" json:"shard_names,omitempty"`
	Query        string                         `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
	Boost        float64                        `protobuf:"fixed64,4,opt,name=boost,proto3" json:"boost,omitempty"`
	Start        int32                          `protobuf:"varint,5,opt,name=start,proto3" json:"start,omitempty"`
	Num          int32                          `protobuf:"varint,6,opt,name=num,proto3" json:"num,omitempty"`
	SortBy       string                         `protobuf:"bytes,7,opt,name=sort_by,proto3" json:"sort_by,omitempty"`
	Fields       []string                       `protobuf:"bytes,8,rep,name=fields,proto3" json:"fields,omitempty"`
	Aggregations map[string]*AggregationRequest `` /* 165-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SearchRequest) Descriptor deprecated 

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

Deprecated: Use SearchRequest.ProtoReflect.Descriptor instead.

func (*SearchRequest) GetAggregations added in v0.2.0 

func (x *SearchRequest) GetAggregations() map[string]*AggregationRequest

func (*SearchRequest) GetBoost 

func (x *SearchRequest) GetBoost() float64

func (*SearchRequest) GetFields added in v0.2.0 

func (x *SearchRequest) GetFields() []string

func (*SearchRequest) GetIndexName 

func (x *SearchRequest) GetIndexName() string

func (*SearchRequest) GetNum 

func (x *SearchRequest) GetNum() int32

func (*SearchRequest) GetQuery 

func (x *SearchRequest) GetQuery() string

func (*SearchRequest) GetShardNames 

func (x *SearchRequest) GetShardNames() []string

func (*SearchRequest) GetSortBy added in v0.2.0 

func (x *SearchRequest) GetSortBy() string

func (*SearchRequest) GetStart 

func (x *SearchRequest) GetStart() int32

func (*SearchRequest) ProtoMessage 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) ProtoReflect 

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

func (*SearchRequest) Reset 

func (x *SearchRequest) Reset()

func (*SearchRequest) String 

func (x *SearchRequest) String() string

type SearchResponse 

type SearchResponse struct {
	IndexName    string                          `protobuf:"bytes,1,opt,name=index_name,proto3" json:"index_name,omitempty"`
	Hits         uint64                          `protobuf:"varint,2,opt,name=hits,proto3" json:"hits,omitempty"`
	Documents    []*Document                     `protobuf:"bytes,3,rep,name=documents,proto3" json:"documents,omitempty"`
	Aggregations map[string]*AggregationResponse `` /* 165-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SearchResponse) Descriptor deprecated 

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

Deprecated: Use SearchResponse.ProtoReflect.Descriptor instead.

func (*SearchResponse) GetAggregations added in v0.2.0 

func (x *SearchResponse) GetAggregations() map[string]*AggregationResponse

func (*SearchResponse) GetDocuments 

func (x *SearchResponse) GetDocuments() []*Document

func (*SearchResponse) GetHits 

func (x *SearchResponse) GetHits() uint64

func (*SearchResponse) GetIndexName 

func (x *SearchResponse) GetIndexName() string

func (*SearchResponse) ProtoMessage 

func (*SearchResponse) ProtoMessage()

func (*SearchResponse) ProtoReflect 

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

func (*SearchResponse) Reset 

func (x *SearchResponse) Reset()

func (*SearchResponse) String 

func (x *SearchResponse) String() string

type ShardMetadata 

type ShardMetadata struct {
	ShardUri     string `protobuf:"bytes,1,opt,name=shard_uri,json=shardUri,proto3" json:"shard_uri,omitempty"`
	ShardLockUri string `protobuf:"bytes,2,opt,name=shard_lock_uri,json=shardLockUri,proto3" json:"shard_lock_uri,omitempty"`
	// contains filtered or unexported fields
}

func (*ShardMetadata) Descriptor deprecated 

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

Deprecated: Use ShardMetadata.ProtoReflect.Descriptor instead.

func (*ShardMetadata) GetShardLockUri 

func (x *ShardMetadata) GetShardLockUri() string

func (*ShardMetadata) GetShardUri 

func (x *ShardMetadata) GetShardUri() string

func (*ShardMetadata) ProtoMessage 

func (*ShardMetadata) ProtoMessage()

func (*ShardMetadata) ProtoReflect 

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

func (*ShardMetadata) Reset 

func (x *ShardMetadata) Reset()

func (*ShardMetadata) String 

func (x *ShardMetadata) String() string

type UnimplementedIndexServer 

type UnimplementedIndexServer struct {
}

UnimplementedIndexServer must be embedded to have forward compatible implementations.

func (UnimplementedIndexServer) AddDocuments 

func (UnimplementedIndexServer) AddDocuments(context.Context, *AddDocumentsRequest) (*AddDocumentsResponse, error)

func (UnimplementedIndexServer) Cluster 

func (UnimplementedIndexServer) Cluster(context.Context, *ClusterRequest) (*ClusterResponse, error)

func (UnimplementedIndexServer) CreateIndex 

func (UnimplementedIndexServer) CreateIndex(context.Context, *CreateIndexRequest) (*CreateIndexResponse, error)

func (UnimplementedIndexServer) DeleteDocuments 

func (UnimplementedIndexServer) DeleteDocuments(context.Context, *DeleteDocumentsRequest) (*DeleteDocumentsResponse, error)

func (UnimplementedIndexServer) DeleteIndex 

func (UnimplementedIndexServer) DeleteIndex(context.Context, *DeleteIndexRequest) (*DeleteIndexResponse, error)

func (UnimplementedIndexServer) LivenessCheck 

func (UnimplementedIndexServer) LivenessCheck(context.Context, *LivenessCheckRequest) (*LivenessCheckResponse, error)

func (UnimplementedIndexServer) Metrics 

func (UnimplementedIndexServer) Metrics(context.Context, *MetricsRequest) (*MetricsResponse, error)

func (UnimplementedIndexServer) ReadinessCheck 

func (UnimplementedIndexServer) ReadinessCheck(context.Context, *ReadinessCheckRequest) (*ReadinessCheckResponse, error)

func (UnimplementedIndexServer) Search 

func (UnimplementedIndexServer) Search(context.Context, *SearchRequest) (*SearchResponse, error)

type UnsafeIndexServer 

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

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

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.