index

package
v0.8.0 Latest Latest
Warning

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

 Go to latest Published: Aug 28, 2019 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Overview

Package index is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var ClusterWatchResponse_Event_name = map[int32]string{
	0: "UNKNOWN",
	1: "JOIN",
	2: "LEAVE",
	3: "UPDATE",
}
View Source 
var ClusterWatchResponse_Event_value = map[string]int32{
	"UNKNOWN": 0,
	"JOIN":    1,
	"LEAVE":   2,
	"UPDATE":  3,
}
View Source 
var NodeHealthCheckRequest_Probe_name = map[int32]string{
	0: "UNKNOWN",
	1: "HEALTHINESS",
	2: "LIVENESS",
	3: "READINESS",
}
View Source 
var NodeHealthCheckRequest_Probe_value = map[string]int32{
	"UNKNOWN":     0,
	"HEALTHINESS": 1,
	"LIVENESS":    2,
	"READINESS":   3,
}
View Source 
var NodeHealthCheckResponse_State_name = map[int32]string{
	0: "UNKNOWN",
	1: "HEALTHY",
	2: "UNHEALTHY",
	3: "ALIVE",
	4: "DEAD",
	5: "READY",
	6: "NOT_READY",
}
View Source 
var NodeHealthCheckResponse_State_value = map[string]int32{
	"UNKNOWN":   0,
	"HEALTHY":   1,
	"UNHEALTHY": 2,
	"ALIVE":     3,
	"DEAD":      4,
	"READY":     5,
	"NOT_READY": 6,
}
View Source 
var Node_State_name = map[int32]string{
	0: "UNKNOWN",
	1: "FOLLOWER",
	2: "CANDIDATE",
	3: "LEADER",
	4: "SHUTDOWN",
}
View Source 
var Node_State_value = map[string]int32{
	"UNKNOWN":   0,
	"FOLLOWER":  1,
	"CANDIDATE": 2,
	"LEADER":    3,
	"SHUTDOWN":  4,
}
View Source 
var Proposal_Event_name = map[int32]string{
	0: "UNKNOWN",
	1: "SET_NODE",
	2: "DELETE_NODE",
	3: "INDEX",
	4: "DELETE",
	5: "BULK_INDEX",
	6: "BULK_DELETE",
}
View Source 
var Proposal_Event_value = map[string]int32{
	"UNKNOWN":     0,
	"SET_NODE":    1,
	"DELETE_NODE": 2,
	"INDEX":       3,
	"DELETE":      4,
	"BULK_INDEX":  5,
	"BULK_DELETE": 6,
}

Functions

func MarshalDocument added in v0.8.0 

func MarshalDocument(doc *Document) ([]byte, error)

func RegisterIndexHandler added in v0.8.0 

func RegisterIndexHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterIndexHandler registers the http handlers for service Index to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterIndexHandlerClient added in v0.8.0 

func RegisterIndexHandlerClient(ctx context.Context, mux *runtime.ServeMux, client IndexClient) error

RegisterIndexHandlerClient registers the http handlers for service Index to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "IndexClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "IndexClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "IndexClient" to call the correct interceptors.

func RegisterIndexHandlerFromEndpoint added in v0.8.0 

func RegisterIndexHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterIndexHandlerFromEndpoint is same as RegisterIndexHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterIndexServer 

func RegisterIndexServer(s *grpc.Server, srv IndexServer)

func UnmarshalDocument added in v0.8.0 

func UnmarshalDocument(data []byte, doc *Document) error

Types

type BulkDeleteRequest added in v0.8.0 

type BulkDeleteRequest struct {
	Ids                  []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BulkDeleteRequest) Descriptor added in v0.8.0 

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

func (*BulkDeleteRequest) GetIds added in v0.8.0 

func (m *BulkDeleteRequest) GetIds() []string

func (*BulkDeleteRequest) ProtoMessage added in v0.8.0 

func (*BulkDeleteRequest) ProtoMessage()

func (*BulkDeleteRequest) Reset added in v0.8.0 

func (m *BulkDeleteRequest) Reset()

func (*BulkDeleteRequest) String added in v0.8.0 

func (m *BulkDeleteRequest) String() string

func (*BulkDeleteRequest) XXX_DiscardUnknown added in v0.8.0 

func (m *BulkDeleteRequest) XXX_DiscardUnknown()

func (*BulkDeleteRequest) XXX_Marshal added in v0.8.0 

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

func (*BulkDeleteRequest) XXX_Merge added in v0.8.0 

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

func (*BulkDeleteRequest) XXX_Size added in v0.8.0 

func (m *BulkDeleteRequest) XXX_Size() int

func (*BulkDeleteRequest) XXX_Unmarshal added in v0.8.0 

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

type BulkDeleteResponse added in v0.8.0 

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

func (*BulkDeleteResponse) Descriptor added in v0.8.0 

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

func (*BulkDeleteResponse) GetCount added in v0.8.0 

func (m *BulkDeleteResponse) GetCount() int32

func (*BulkDeleteResponse) ProtoMessage added in v0.8.0 

func (*BulkDeleteResponse) ProtoMessage()

func (*BulkDeleteResponse) Reset added in v0.8.0 

func (m *BulkDeleteResponse) Reset()

func (*BulkDeleteResponse) String added in v0.8.0 

func (m *BulkDeleteResponse) String() string

func (*BulkDeleteResponse) XXX_DiscardUnknown added in v0.8.0 

func (m *BulkDeleteResponse) XXX_DiscardUnknown()

func (*BulkDeleteResponse) XXX_Marshal added in v0.8.0 

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

func (*BulkDeleteResponse) XXX_Merge added in v0.8.0 

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

func (*BulkDeleteResponse) XXX_Size added in v0.8.0 

func (m *BulkDeleteResponse) XXX_Size() int

func (*BulkDeleteResponse) XXX_Unmarshal added in v0.8.0 

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

type BulkIndexRequest added in v0.8.0 

type BulkIndexRequest struct {
	Documents            []*Document `protobuf:"bytes,1,rep,name=documents,proto3" json:"documents,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*BulkIndexRequest) Descriptor added in v0.8.0 

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

func (*BulkIndexRequest) GetDocuments added in v0.8.0 

func (m *BulkIndexRequest) GetDocuments() []*Document

func (*BulkIndexRequest) ProtoMessage added in v0.8.0 

func (*BulkIndexRequest) ProtoMessage()

func (*BulkIndexRequest) Reset added in v0.8.0 

func (m *BulkIndexRequest) Reset()

func (*BulkIndexRequest) String added in v0.8.0 

func (m *BulkIndexRequest) String() string

func (*BulkIndexRequest) XXX_DiscardUnknown added in v0.8.0 

func (m *BulkIndexRequest) XXX_DiscardUnknown()

func (*BulkIndexRequest) XXX_Marshal added in v0.8.0 

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

func (*BulkIndexRequest) XXX_Merge added in v0.8.0 

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

func (*BulkIndexRequest) XXX_Size added in v0.8.0 

func (m *BulkIndexRequest) XXX_Size() int

func (*BulkIndexRequest) XXX_Unmarshal added in v0.8.0 

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

type BulkIndexResponse added in v0.8.0 

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

func (*BulkIndexResponse) Descriptor added in v0.8.0 

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

func (*BulkIndexResponse) GetCount added in v0.8.0 

func (m *BulkIndexResponse) GetCount() int32

func (*BulkIndexResponse) ProtoMessage added in v0.8.0 

func (*BulkIndexResponse) ProtoMessage()

func (*BulkIndexResponse) Reset added in v0.8.0 

func (m *BulkIndexResponse) Reset()

func (*BulkIndexResponse) String added in v0.8.0 

func (m *BulkIndexResponse) String() string

func (*BulkIndexResponse) XXX_DiscardUnknown added in v0.8.0 

func (m *BulkIndexResponse) XXX_DiscardUnknown()

func (*BulkIndexResponse) XXX_Marshal added in v0.8.0 

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

func (*BulkIndexResponse) XXX_Merge added in v0.8.0 

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

func (*BulkIndexResponse) XXX_Size added in v0.8.0 

func (m *BulkIndexResponse) XXX_Size() int

func (*BulkIndexResponse) XXX_Unmarshal added in v0.8.0 

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

type Cluster added in v0.8.0 

type Cluster struct {
	Nodes                map[string]*Node `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*Cluster) Descriptor added in v0.8.0 

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

func (*Cluster) GetNodes added in v0.8.0 

func (m *Cluster) GetNodes() map[string]*Node

func (*Cluster) ProtoMessage added in v0.8.0 

func (*Cluster) ProtoMessage()

func (*Cluster) Reset added in v0.8.0 

func (m *Cluster) Reset()

func (*Cluster) String added in v0.8.0 

func (m *Cluster) String() string

func (*Cluster) XXX_DiscardUnknown added in v0.8.0 

func (m *Cluster) XXX_DiscardUnknown()

func (*Cluster) XXX_Marshal added in v0.8.0 

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

func (*Cluster) XXX_Merge added in v0.8.0 

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

func (*Cluster) XXX_Size added in v0.8.0 

func (m *Cluster) XXX_Size() int

func (*Cluster) XXX_Unmarshal added in v0.8.0 

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

type ClusterInfoResponse added in v0.8.0 

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

func (*ClusterInfoResponse) Descriptor added in v0.8.0 

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

func (*ClusterInfoResponse) GetCluster added in v0.8.0 

func (m *ClusterInfoResponse) GetCluster() *Cluster

func (*ClusterInfoResponse) ProtoMessage added in v0.8.0 

func (*ClusterInfoResponse) ProtoMessage()

func (*ClusterInfoResponse) Reset added in v0.8.0 

func (m *ClusterInfoResponse) Reset()

func (*ClusterInfoResponse) String added in v0.8.0 

func (m *ClusterInfoResponse) String() string

func (*ClusterInfoResponse) XXX_DiscardUnknown added in v0.8.0 

func (m *ClusterInfoResponse) XXX_DiscardUnknown()

func (*ClusterInfoResponse) XXX_Marshal added in v0.8.0 

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

func (*ClusterInfoResponse) XXX_Merge added in v0.8.0 

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

func (*ClusterInfoResponse) XXX_Size added in v0.8.0 

func (m *ClusterInfoResponse) XXX_Size() int

func (*ClusterInfoResponse) XXX_Unmarshal added in v0.8.0 

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

type ClusterJoinRequest added in v0.8.0 

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

func (*ClusterJoinRequest) Descriptor added in v0.8.0 

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

func (*ClusterJoinRequest) GetNode added in v0.8.0 

func (m *ClusterJoinRequest) GetNode() *Node

func (*ClusterJoinRequest) ProtoMessage added in v0.8.0 

func (*ClusterJoinRequest) ProtoMessage()

func (*ClusterJoinRequest) Reset added in v0.8.0 

func (m *ClusterJoinRequest) Reset()

func (*ClusterJoinRequest) String added in v0.8.0 

func (m *ClusterJoinRequest) String() string

func (*ClusterJoinRequest) XXX_DiscardUnknown added in v0.8.0 

func (m *ClusterJoinRequest) XXX_DiscardUnknown()

func (*ClusterJoinRequest) XXX_Marshal added in v0.8.0 

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

func (*ClusterJoinRequest) XXX_Merge added in v0.8.0 

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

func (*ClusterJoinRequest) XXX_Size added in v0.8.0 

func (m *ClusterJoinRequest) XXX_Size() int

func (*ClusterJoinRequest) XXX_Unmarshal added in v0.8.0 

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

type ClusterLeaveRequest added in v0.8.0 

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

func (*ClusterLeaveRequest) Descriptor added in v0.8.0 

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

func (*ClusterLeaveRequest) GetId added in v0.8.0 

func (m *ClusterLeaveRequest) GetId() string

func (*ClusterLeaveRequest) ProtoMessage added in v0.8.0 

func (*ClusterLeaveRequest) ProtoMessage()

func (*ClusterLeaveRequest) Reset added in v0.8.0 

func (m *ClusterLeaveRequest) Reset()

func (*ClusterLeaveRequest) String added in v0.8.0 

func (m *ClusterLeaveRequest) String() string

func (*ClusterLeaveRequest) XXX_DiscardUnknown added in v0.8.0 

func (m *ClusterLeaveRequest) XXX_DiscardUnknown()

func (*ClusterLeaveRequest) XXX_Marshal added in v0.8.0 

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

func (*ClusterLeaveRequest) XXX_Merge added in v0.8.0 

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

func (*ClusterLeaveRequest) XXX_Size added in v0.8.0 

func (m *ClusterLeaveRequest) XXX_Size() int

func (*ClusterLeaveRequest) XXX_Unmarshal added in v0.8.0 

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

type ClusterWatchResponse added in v0.8.0 

type ClusterWatchResponse struct {
	Event                ClusterWatchResponse_Event `protobuf:"varint,1,opt,name=event,proto3,enum=index.ClusterWatchResponse_Event" json:"event,omitempty"`
	Node                 *Node                      `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"`
	Cluster              *Cluster                   `protobuf:"bytes,3,opt,name=cluster,proto3" json:"cluster,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*ClusterWatchResponse) Descriptor added in v0.8.0 

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

func (*ClusterWatchResponse) GetCluster added in v0.8.0 

func (m *ClusterWatchResponse) GetCluster() *Cluster

func (*ClusterWatchResponse) GetEvent added in v0.8.0 

func (m *ClusterWatchResponse) GetEvent() ClusterWatchResponse_Event

func (*ClusterWatchResponse) GetNode added in v0.8.0 

func (m *ClusterWatchResponse) GetNode() *Node

func (*ClusterWatchResponse) ProtoMessage added in v0.8.0 

func (*ClusterWatchResponse) ProtoMessage()

func (*ClusterWatchResponse) Reset added in v0.8.0 

func (m *ClusterWatchResponse) Reset()

func (*ClusterWatchResponse) String added in v0.8.0 

func (m *ClusterWatchResponse) String() string

func (*ClusterWatchResponse) XXX_DiscardUnknown added in v0.8.0 

func (m *ClusterWatchResponse) XXX_DiscardUnknown()

func (*ClusterWatchResponse) XXX_Marshal added in v0.8.0 

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

func (*ClusterWatchResponse) XXX_Merge added in v0.8.0 

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

func (*ClusterWatchResponse) XXX_Size added in v0.8.0 

func (m *ClusterWatchResponse) XXX_Size() int

func (*ClusterWatchResponse) XXX_Unmarshal added in v0.8.0 

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

type ClusterWatchResponse_Event added in v0.8.0 

type ClusterWatchResponse_Event int32
const (
	ClusterWatchResponse_UNKNOWN ClusterWatchResponse_Event = 0
	ClusterWatchResponse_JOIN    ClusterWatchResponse_Event = 1
	ClusterWatchResponse_LEAVE   ClusterWatchResponse_Event = 2
	ClusterWatchResponse_UPDATE  ClusterWatchResponse_Event = 3
)

func (ClusterWatchResponse_Event) EnumDescriptor added in v0.8.0 

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

func (ClusterWatchResponse_Event) String added in v0.8.0 

func (x ClusterWatchResponse_Event) String() string

type DeleteRequest 

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

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) GetId added in v0.8.0 

func (m *DeleteRequest) GetId() string

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (m *DeleteRequest) String() string

func (*DeleteRequest) XXX_DiscardUnknown 

func (m *DeleteRequest) XXX_DiscardUnknown()

func (*DeleteRequest) XXX_Marshal 

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

func (*DeleteRequest) XXX_Merge 

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

func (*DeleteRequest) XXX_Size 

func (m *DeleteRequest) XXX_Size() int

func (*DeleteRequest) XXX_Unmarshal 

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

type Document 

type Document struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Fields               *any.Any `protobuf:"bytes,2,opt,name=fields,proto3" json:"fields,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Document) Descriptor 

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

func (*Document) GetFields 

func (m *Document) GetFields() *any.Any

func (*Document) GetId 

func (m *Document) GetId() string

func (*Document) ProtoMessage 

func (*Document) ProtoMessage()

func (*Document) Reset 

func (m *Document) Reset()

func (*Document) String 

func (m *Document) String() string

func (*Document) XXX_DiscardUnknown 

func (m *Document) XXX_DiscardUnknown()

func (*Document) XXX_Marshal 

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

func (*Document) XXX_Merge 

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

func (*Document) XXX_Size 

func (m *Document) XXX_Size() int

func (*Document) XXX_Unmarshal 

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

type GetIndexConfigResponse added in v0.8.0 

type GetIndexConfigResponse struct {
	IndexConfig          *IndexConfig `protobuf:"bytes,1,opt,name=index_config,json=indexConfig,proto3" json:"index_config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetIndexConfigResponse) Descriptor added in v0.8.0 

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

func (*GetIndexConfigResponse) GetIndexConfig added in v0.8.0 

func (m *GetIndexConfigResponse) GetIndexConfig() *IndexConfig

func (*GetIndexConfigResponse) ProtoMessage added in v0.8.0 

func (*GetIndexConfigResponse) ProtoMessage()

func (*GetIndexConfigResponse) Reset added in v0.8.0 

func (m *GetIndexConfigResponse) Reset()

func (*GetIndexConfigResponse) String added in v0.8.0 

func (m *GetIndexConfigResponse) String() string

func (*GetIndexConfigResponse) XXX_DiscardUnknown added in v0.8.0 

func (m *GetIndexConfigResponse) XXX_DiscardUnknown()

func (*GetIndexConfigResponse) XXX_Marshal added in v0.8.0 

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

func (*GetIndexConfigResponse) XXX_Merge added in v0.8.0 

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

func (*GetIndexConfigResponse) XXX_Size added in v0.8.0 

func (m *GetIndexConfigResponse) XXX_Size() int

func (*GetIndexConfigResponse) XXX_Unmarshal added in v0.8.0 

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

type GetIndexStatsResponse added in v0.8.0 

type GetIndexStatsResponse struct {
	IndexStats           *any.Any `protobuf:"bytes,1,opt,name=index_stats,json=indexStats,proto3" json:"index_stats,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetIndexStatsResponse) Descriptor added in v0.8.0 

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

func (*GetIndexStatsResponse) GetIndexStats added in v0.8.0 

func (m *GetIndexStatsResponse) GetIndexStats() *any.Any

func (*GetIndexStatsResponse) ProtoMessage added in v0.8.0 

func (*GetIndexStatsResponse) ProtoMessage()

func (*GetIndexStatsResponse) Reset added in v0.8.0 

func (m *GetIndexStatsResponse) Reset()

func (*GetIndexStatsResponse) String added in v0.8.0 

func (m *GetIndexStatsResponse) String() string

func (*GetIndexStatsResponse) XXX_DiscardUnknown added in v0.8.0 

func (m *GetIndexStatsResponse) XXX_DiscardUnknown()

func (*GetIndexStatsResponse) XXX_Marshal added in v0.8.0 

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

func (*GetIndexStatsResponse) XXX_Merge added in v0.8.0 

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

func (*GetIndexStatsResponse) XXX_Size added in v0.8.0 

func (m *GetIndexStatsResponse) XXX_Size() int

func (*GetIndexStatsResponse) XXX_Unmarshal added in v0.8.0 

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

type GetRequest 

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

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetId added in v0.8.0 

func (m *GetRequest) GetId() string

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) String 

func (m *GetRequest) String() string

func (*GetRequest) XXX_DiscardUnknown 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal 

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

func (*GetRequest) XXX_Merge 

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

func (*GetRequest) XXX_Size 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal 

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

type GetResponse 

type GetResponse struct {
	//    Document document = 1;
	Fields               *any.Any `protobuf:"bytes,1,opt,name=fields,proto3" json:"fields,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetResponse) Descriptor 

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

func (*GetResponse) GetFields added in v0.8.0 

func (m *GetResponse) GetFields() *any.Any

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset 

func (m *GetResponse) Reset()

func (*GetResponse) String 

func (m *GetResponse) String() string

func (*GetResponse) XXX_DiscardUnknown 

func (m *GetResponse) XXX_DiscardUnknown()

func (*GetResponse) XXX_Marshal 

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

func (*GetResponse) XXX_Merge 

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

func (*GetResponse) XXX_Size 

func (m *GetResponse) XXX_Size() int

func (*GetResponse) XXX_Unmarshal 

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

type IndexClient 

type IndexClient interface {
	NodeHealthCheck(ctx context.Context, in *NodeHealthCheckRequest, opts ...grpc.CallOption) (*NodeHealthCheckResponse, error)
	NodeInfo(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*NodeInfoResponse, error)
	ClusterJoin(ctx context.Context, in *ClusterJoinRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	ClusterLeave(ctx context.Context, in *ClusterLeaveRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	ClusterInfo(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ClusterInfoResponse, error)
	ClusterWatch(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (Index_ClusterWatchClient, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	Index(ctx context.Context, in *IndexRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	BulkIndex(ctx context.Context, in *BulkIndexRequest, opts ...grpc.CallOption) (*BulkIndexResponse, error)
	BulkDelete(ctx context.Context, in *BulkDeleteRequest, opts ...grpc.CallOption) (*BulkDeleteResponse, error)
	Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResponse, error)
	GetIndexConfig(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetIndexConfigResponse, error)
	GetIndexStats(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetIndexStatsResponse, error)
	Snapshot(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
}

IndexClient is the client API for Index service.

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

func NewIndexClient 

func NewIndexClient(cc *grpc.ClientConn) IndexClient

type IndexConfig added in v0.8.0 

type IndexConfig struct {
	IndexMapping         *any.Any `protobuf:"bytes,1,opt,name=index_mapping,json=indexMapping,proto3" json:"index_mapping,omitempty"`
	IndexType            string   `protobuf:"bytes,2,opt,name=index_type,json=indexType,proto3" json:"index_type,omitempty"`
	IndexStorageType     string   `protobuf:"bytes,3,opt,name=index_storage_type,json=indexStorageType,proto3" json:"index_storage_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IndexConfig) Descriptor added in v0.8.0 

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

func (*IndexConfig) GetIndexMapping added in v0.8.0 

func (m *IndexConfig) GetIndexMapping() *any.Any

func (*IndexConfig) GetIndexStorageType added in v0.8.0 

func (m *IndexConfig) GetIndexStorageType() string

func (*IndexConfig) GetIndexType added in v0.8.0 

func (m *IndexConfig) GetIndexType() string

func (*IndexConfig) ProtoMessage added in v0.8.0 

func (*IndexConfig) ProtoMessage()

func (*IndexConfig) Reset added in v0.8.0 

func (m *IndexConfig) Reset()

func (*IndexConfig) String added in v0.8.0 

func (m *IndexConfig) String() string

func (*IndexConfig) XXX_DiscardUnknown added in v0.8.0 

func (m *IndexConfig) XXX_DiscardUnknown()

func (*IndexConfig) XXX_Marshal added in v0.8.0 

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

func (*IndexConfig) XXX_Merge added in v0.8.0 

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

func (*IndexConfig) XXX_Size added in v0.8.0 

func (m *IndexConfig) XXX_Size() int

func (*IndexConfig) XXX_Unmarshal added in v0.8.0 

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

type IndexRequest 

type IndexRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Fields               *any.Any `protobuf:"bytes,2,opt,name=fields,proto3" json:"fields,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IndexRequest) Descriptor 

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

func (*IndexRequest) GetFields added in v0.8.0 

func (m *IndexRequest) GetFields() *any.Any

func (*IndexRequest) GetId added in v0.8.0 

func (m *IndexRequest) GetId() string

func (*IndexRequest) ProtoMessage 

func (*IndexRequest) ProtoMessage()

func (*IndexRequest) Reset 

func (m *IndexRequest) Reset()

func (*IndexRequest) String 

func (m *IndexRequest) String() string

func (*IndexRequest) XXX_DiscardUnknown 

func (m *IndexRequest) XXX_DiscardUnknown()

func (*IndexRequest) XXX_Marshal 

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

func (*IndexRequest) XXX_Merge 

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

func (*IndexRequest) XXX_Size 

func (m *IndexRequest) XXX_Size() int

func (*IndexRequest) XXX_Unmarshal 

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

type IndexServer 

type IndexServer interface {
	NodeHealthCheck(context.Context, *NodeHealthCheckRequest) (*NodeHealthCheckResponse, error)
	NodeInfo(context.Context, *empty.Empty) (*NodeInfoResponse, error)
	ClusterJoin(context.Context, *ClusterJoinRequest) (*empty.Empty, error)
	ClusterLeave(context.Context, *ClusterLeaveRequest) (*empty.Empty, error)
	ClusterInfo(context.Context, *empty.Empty) (*ClusterInfoResponse, error)
	ClusterWatch(*empty.Empty, Index_ClusterWatchServer) error
	Get(context.Context, *GetRequest) (*GetResponse, error)
	Index(context.Context, *IndexRequest) (*empty.Empty, error)
	Delete(context.Context, *DeleteRequest) (*empty.Empty, error)
	BulkIndex(context.Context, *BulkIndexRequest) (*BulkIndexResponse, error)
	BulkDelete(context.Context, *BulkDeleteRequest) (*BulkDeleteResponse, error)
	Search(context.Context, *SearchRequest) (*SearchResponse, error)
	GetIndexConfig(context.Context, *empty.Empty) (*GetIndexConfigResponse, error)
	GetIndexStats(context.Context, *empty.Empty) (*GetIndexStatsResponse, error)
	Snapshot(context.Context, *empty.Empty) (*empty.Empty, error)
}

IndexServer is the server API for Index service.

type Index_ClusterWatchClient added in v0.8.0 

type Index_ClusterWatchClient interface {
	Recv() (*ClusterWatchResponse, error)
	grpc.ClientStream
}

type Index_ClusterWatchServer added in v0.8.0 

type Index_ClusterWatchServer interface {
	Send(*ClusterWatchResponse) error
	grpc.ServerStream
}

type Metadata added in v0.8.0 

type Metadata struct {
	GrpcAddress          string   `protobuf:"bytes,1,opt,name=grpc_address,json=grpcAddress,proto3" json:"grpc_address,omitempty"`
	GrpcGatewayAddress   string   `protobuf:"bytes,2,opt,name=grpc_gateway_address,json=grpcGatewayAddress,proto3" json:"grpc_gateway_address,omitempty"`
	HttpAddress          string   `protobuf:"bytes,3,opt,name=http_address,json=httpAddress,proto3" json:"http_address,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Metadata) Descriptor added in v0.8.0 

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

func (*Metadata) GetGrpcAddress added in v0.8.0 

func (m *Metadata) GetGrpcAddress() string

func (*Metadata) GetGrpcGatewayAddress added in v0.8.0 

func (m *Metadata) GetGrpcGatewayAddress() string

func (*Metadata) GetHttpAddress added in v0.8.0 

func (m *Metadata) GetHttpAddress() string

func (*Metadata) ProtoMessage added in v0.8.0 

func (*Metadata) ProtoMessage()

func (*Metadata) Reset added in v0.8.0 

func (m *Metadata) Reset()

func (*Metadata) String added in v0.8.0 

func (m *Metadata) String() string

func (*Metadata) XXX_DiscardUnknown added in v0.8.0 

func (m *Metadata) XXX_DiscardUnknown()

func (*Metadata) XXX_Marshal added in v0.8.0 

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

func (*Metadata) XXX_Merge added in v0.8.0 

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

func (*Metadata) XXX_Size added in v0.8.0 

func (m *Metadata) XXX_Size() int

func (*Metadata) XXX_Unmarshal added in v0.8.0 

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

type Node added in v0.8.0 

type Node struct {
	Id                   string     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	BindAddress          string     `protobuf:"bytes,2,opt,name=bind_address,json=bindAddress,proto3" json:"bind_address,omitempty"`
	State                Node_State `protobuf:"varint,3,opt,name=state,proto3,enum=index.Node_State" json:"state,omitempty"`
	Metadata             *Metadata  `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Node) Descriptor added in v0.8.0 

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

func (*Node) GetBindAddress added in v0.8.0 

func (m *Node) GetBindAddress() string

func (*Node) GetId added in v0.8.0 

func (m *Node) GetId() string

func (*Node) GetMetadata added in v0.8.0 

func (m *Node) GetMetadata() *Metadata

func (*Node) GetState added in v0.8.0 

func (m *Node) GetState() Node_State

func (*Node) ProtoMessage added in v0.8.0 

func (*Node) ProtoMessage()

func (*Node) Reset added in v0.8.0 

func (m *Node) Reset()

func (*Node) String added in v0.8.0 

func (m *Node) String() string

func (*Node) XXX_DiscardUnknown added in v0.8.0 

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal added in v0.8.0 

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

func (*Node) XXX_Merge added in v0.8.0 

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

func (*Node) XXX_Size added in v0.8.0 

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal added in v0.8.0 

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

type NodeHealthCheckRequest added in v0.8.0 

type NodeHealthCheckRequest struct {
	Probe                NodeHealthCheckRequest_Probe `protobuf:"varint,1,opt,name=probe,proto3,enum=index.NodeHealthCheckRequest_Probe" json:"probe,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*NodeHealthCheckRequest) Descriptor added in v0.8.0 

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

func (*NodeHealthCheckRequest) GetProbe added in v0.8.0 

func (m *NodeHealthCheckRequest) GetProbe() NodeHealthCheckRequest_Probe

func (*NodeHealthCheckRequest) ProtoMessage added in v0.8.0 

func (*NodeHealthCheckRequest) ProtoMessage()

func (*NodeHealthCheckRequest) Reset added in v0.8.0 

func (m *NodeHealthCheckRequest) Reset()

func (*NodeHealthCheckRequest) String added in v0.8.0 

func (m *NodeHealthCheckRequest) String() string

func (*NodeHealthCheckRequest) XXX_DiscardUnknown added in v0.8.0 

func (m *NodeHealthCheckRequest) XXX_DiscardUnknown()

func (*NodeHealthCheckRequest) XXX_Marshal added in v0.8.0 

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

func (*NodeHealthCheckRequest) XXX_Merge added in v0.8.0 

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

func (*NodeHealthCheckRequest) XXX_Size added in v0.8.0 

func (m *NodeHealthCheckRequest) XXX_Size() int

func (*NodeHealthCheckRequest) XXX_Unmarshal added in v0.8.0 

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

type NodeHealthCheckRequest_Probe added in v0.8.0 

type NodeHealthCheckRequest_Probe int32
const (
	NodeHealthCheckRequest_UNKNOWN     NodeHealthCheckRequest_Probe = 0
	NodeHealthCheckRequest_HEALTHINESS NodeHealthCheckRequest_Probe = 1
	NodeHealthCheckRequest_LIVENESS    NodeHealthCheckRequest_Probe = 2
	NodeHealthCheckRequest_READINESS   NodeHealthCheckRequest_Probe = 3
)

func (NodeHealthCheckRequest_Probe) EnumDescriptor added in v0.8.0 

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

func (NodeHealthCheckRequest_Probe) String added in v0.8.0 

func (x NodeHealthCheckRequest_Probe) String() string

type NodeHealthCheckResponse added in v0.8.0 

type NodeHealthCheckResponse struct {
	State                NodeHealthCheckResponse_State `protobuf:"varint,1,opt,name=state,proto3,enum=index.NodeHealthCheckResponse_State" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*NodeHealthCheckResponse) Descriptor added in v0.8.0 

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

func (*NodeHealthCheckResponse) GetState added in v0.8.0 

func (m *NodeHealthCheckResponse) GetState() NodeHealthCheckResponse_State

func (*NodeHealthCheckResponse) ProtoMessage added in v0.8.0 

func (*NodeHealthCheckResponse) ProtoMessage()

func (*NodeHealthCheckResponse) Reset added in v0.8.0 

func (m *NodeHealthCheckResponse) Reset()

func (*NodeHealthCheckResponse) String added in v0.8.0 

func (m *NodeHealthCheckResponse) String() string

func (*NodeHealthCheckResponse) XXX_DiscardUnknown added in v0.8.0 

func (m *NodeHealthCheckResponse) XXX_DiscardUnknown()

func (*NodeHealthCheckResponse) XXX_Marshal added in v0.8.0 

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

func (*NodeHealthCheckResponse) XXX_Merge added in v0.8.0 

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

func (*NodeHealthCheckResponse) XXX_Size added in v0.8.0 

func (m *NodeHealthCheckResponse) XXX_Size() int

func (*NodeHealthCheckResponse) XXX_Unmarshal added in v0.8.0 

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

type NodeHealthCheckResponse_State added in v0.8.0 

type NodeHealthCheckResponse_State int32
const (
	NodeHealthCheckResponse_UNKNOWN   NodeHealthCheckResponse_State = 0
	NodeHealthCheckResponse_HEALTHY   NodeHealthCheckResponse_State = 1
	NodeHealthCheckResponse_UNHEALTHY NodeHealthCheckResponse_State = 2
	NodeHealthCheckResponse_ALIVE     NodeHealthCheckResponse_State = 3
	NodeHealthCheckResponse_DEAD      NodeHealthCheckResponse_State = 4
	NodeHealthCheckResponse_READY     NodeHealthCheckResponse_State = 5
	NodeHealthCheckResponse_NOT_READY NodeHealthCheckResponse_State = 6
)

func (NodeHealthCheckResponse_State) EnumDescriptor added in v0.8.0 

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

func (NodeHealthCheckResponse_State) String added in v0.8.0 

func (x NodeHealthCheckResponse_State) String() string

type NodeInfoResponse added in v0.8.0 

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

func (*NodeInfoResponse) Descriptor added in v0.8.0 

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

func (*NodeInfoResponse) GetNode added in v0.8.0 

func (m *NodeInfoResponse) GetNode() *Node

func (*NodeInfoResponse) ProtoMessage added in v0.8.0 

func (*NodeInfoResponse) ProtoMessage()

func (*NodeInfoResponse) Reset added in v0.8.0 

func (m *NodeInfoResponse) Reset()

func (*NodeInfoResponse) String added in v0.8.0 

func (m *NodeInfoResponse) String() string

func (*NodeInfoResponse) XXX_DiscardUnknown added in v0.8.0 

func (m *NodeInfoResponse) XXX_DiscardUnknown()

func (*NodeInfoResponse) XXX_Marshal added in v0.8.0 

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

func (*NodeInfoResponse) XXX_Merge added in v0.8.0 

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

func (*NodeInfoResponse) XXX_Size added in v0.8.0 

func (m *NodeInfoResponse) XXX_Size() int

func (*NodeInfoResponse) XXX_Unmarshal added in v0.8.0 

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

type Node_State added in v0.8.0 

type Node_State int32
const (
	Node_UNKNOWN   Node_State = 0
	Node_FOLLOWER  Node_State = 1
	Node_CANDIDATE Node_State = 2
	Node_LEADER    Node_State = 3
	Node_SHUTDOWN  Node_State = 4
)

func (Node_State) EnumDescriptor added in v0.8.0 

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

func (Node_State) String added in v0.8.0 

func (x Node_State) String() string

type Proposal added in v0.8.0 

type Proposal struct {
	Event                Proposal_Event `protobuf:"varint,1,opt,name=event,proto3,enum=index.Proposal_Event" json:"event,omitempty"`
	Node                 *Node          `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"`
	Document             *Document      `protobuf:"bytes,3,opt,name=document,proto3" json:"document,omitempty"`
	Id                   string         `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"`
	Documents            []*Document    `protobuf:"bytes,5,rep,name=documents,proto3" json:"documents,omitempty"`
	Ids                  []string       `protobuf:"bytes,6,rep,name=ids,proto3" json:"ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*Proposal) Descriptor added in v0.8.0 

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

func (*Proposal) GetDocument added in v0.8.0 

func (m *Proposal) GetDocument() *Document

func (*Proposal) GetDocuments added in v0.8.0 

func (m *Proposal) GetDocuments() []*Document

func (*Proposal) GetEvent added in v0.8.0 

func (m *Proposal) GetEvent() Proposal_Event

func (*Proposal) GetId added in v0.8.0 

func (m *Proposal) GetId() string

func (*Proposal) GetIds added in v0.8.0 

func (m *Proposal) GetIds() []string

func (*Proposal) GetNode added in v0.8.0 

func (m *Proposal) GetNode() *Node

func (*Proposal) ProtoMessage added in v0.8.0 

func (*Proposal) ProtoMessage()

func (*Proposal) Reset added in v0.8.0 

func (m *Proposal) Reset()

func (*Proposal) String added in v0.8.0 

func (m *Proposal) String() string

func (*Proposal) XXX_DiscardUnknown added in v0.8.0 

func (m *Proposal) XXX_DiscardUnknown()

func (*Proposal) XXX_Marshal added in v0.8.0 

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

func (*Proposal) XXX_Merge added in v0.8.0 

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

func (*Proposal) XXX_Size added in v0.8.0 

func (m *Proposal) XXX_Size() int

func (*Proposal) XXX_Unmarshal added in v0.8.0 

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

type Proposal_Event added in v0.8.0 

type Proposal_Event int32
const (
	Proposal_UNKNOWN     Proposal_Event = 0
	Proposal_SET_NODE    Proposal_Event = 1
	Proposal_DELETE_NODE Proposal_Event = 2
	Proposal_INDEX       Proposal_Event = 3
	Proposal_DELETE      Proposal_Event = 4
	Proposal_BULK_INDEX  Proposal_Event = 5
	Proposal_BULK_DELETE Proposal_Event = 6
)

func (Proposal_Event) EnumDescriptor added in v0.8.0 

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

func (Proposal_Event) String added in v0.8.0 

func (x Proposal_Event) String() string

type SearchRequest 

type SearchRequest struct {
	SearchRequest        *any.Any `protobuf:"bytes,1,opt,name=search_request,json=searchRequest,proto3" json:"search_request,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SearchRequest) Descriptor 

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

func (*SearchRequest) GetSearchRequest 

func (m *SearchRequest) GetSearchRequest() *any.Any

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 SearchResponse 

type SearchResponse struct {
	SearchResult         *any.Any `protobuf:"bytes,1,opt,name=search_result,json=searchResult,proto3" json:"search_result,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SearchResponse) Descriptor 

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

func (*SearchResponse) GetSearchResult 

func (m *SearchResponse) GetSearchResult() *any.Any

func (*SearchResponse) ProtoMessage 

func (*SearchResponse) ProtoMessage()

func (*SearchResponse) Reset 

func (m *SearchResponse) Reset()

func (*SearchResponse) String 

func (m *SearchResponse) String() string

func (*SearchResponse) XXX_DiscardUnknown 

func (m *SearchResponse) XXX_DiscardUnknown()

func (*SearchResponse) XXX_Marshal 

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

func (*SearchResponse) XXX_Merge 

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

func (*SearchResponse) XXX_Size 

func (m *SearchResponse) XXX_Size() int

func (*SearchResponse) XXX_Unmarshal 

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

type UnimplementedIndexServer added in v0.8.0 

type UnimplementedIndexServer struct {
}

UnimplementedIndexServer can be embedded to have forward compatible implementations.

func (*UnimplementedIndexServer) BulkDelete added in v0.8.0 

func (*UnimplementedIndexServer) BulkDelete(ctx context.Context, req *BulkDeleteRequest) (*BulkDeleteResponse, error)

func (*UnimplementedIndexServer) BulkIndex added in v0.8.0 

func (*UnimplementedIndexServer) BulkIndex(ctx context.Context, req *BulkIndexRequest) (*BulkIndexResponse, error)

func (*UnimplementedIndexServer) ClusterInfo added in v0.8.0 

func (*UnimplementedIndexServer) ClusterInfo(ctx context.Context, req *empty.Empty) (*ClusterInfoResponse, error)

func (*UnimplementedIndexServer) ClusterJoin added in v0.8.0 

func (*UnimplementedIndexServer) ClusterJoin(ctx context.Context, req *ClusterJoinRequest) (*empty.Empty, error)

func (*UnimplementedIndexServer) ClusterLeave added in v0.8.0 

func (*UnimplementedIndexServer) ClusterLeave(ctx context.Context, req *ClusterLeaveRequest) (*empty.Empty, error)

func (*UnimplementedIndexServer) ClusterWatch added in v0.8.0 

func (*UnimplementedIndexServer) ClusterWatch(req *empty.Empty, srv Index_ClusterWatchServer) error

func (*UnimplementedIndexServer) Delete added in v0.8.0 

func (*UnimplementedIndexServer) Delete(ctx context.Context, req *DeleteRequest) (*empty.Empty, error)

func (*UnimplementedIndexServer) Get added in v0.8.0 

func (*UnimplementedIndexServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)

func (*UnimplementedIndexServer) GetIndexConfig added in v0.8.0 

func (*UnimplementedIndexServer) GetIndexConfig(ctx context.Context, req *empty.Empty) (*GetIndexConfigResponse, error)

func (*UnimplementedIndexServer) GetIndexStats added in v0.8.0 

func (*UnimplementedIndexServer) GetIndexStats(ctx context.Context, req *empty.Empty) (*GetIndexStatsResponse, error)

func (*UnimplementedIndexServer) Index added in v0.8.0 

func (*UnimplementedIndexServer) Index(ctx context.Context, req *IndexRequest) (*empty.Empty, error)

func (*UnimplementedIndexServer) NodeHealthCheck added in v0.8.0 

func (*UnimplementedIndexServer) NodeHealthCheck(ctx context.Context, req *NodeHealthCheckRequest) (*NodeHealthCheckResponse, error)

func (*UnimplementedIndexServer) NodeInfo added in v0.8.0 

func (*UnimplementedIndexServer) NodeInfo(ctx context.Context, req *empty.Empty) (*NodeInfoResponse, error)

func (*UnimplementedIndexServer) Search added in v0.8.0 

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

func (*UnimplementedIndexServer) Snapshot added in v0.8.0 

func (*UnimplementedIndexServer) Snapshot(ctx context.Context, req *empty.Empty) (*empty.Empty, 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.