index

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Mar 14, 2019 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var IndexCommand_Type_name = map[int32]string{
	0: "UNKNOWN_COMMAND",
	1: "SET_METADATA",
	2: "DELETE_METADATA",
	3: "INDEX_DOCUMENT",
	4: "DELETE_DOCUMENT",
}
View Source 
var IndexCommand_Type_value = map[string]int32{
	"UNKNOWN_COMMAND": 0,
	"SET_METADATA":    1,
	"DELETE_METADATA": 2,
	"INDEX_DOCUMENT":  3,
	"DELETE_DOCUMENT": 4,
}

Functions

func RegisterIndexServer 

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

Types

type DeleteRequest 

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

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) GetDocument 

func (m *DeleteRequest) GetDocument() *Document

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 GetRequest 

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

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetDocument 

func (m *GetRequest) GetDocument() *Document

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 `protobuf:"bytes,1,opt,name=document,proto3" json:"document,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GetResponse) Descriptor 

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

func (*GetResponse) GetDocument 

func (m *GetResponse) GetDocument() *Document

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 {
	Join(ctx context.Context, in *raft.JoinRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	Leave(ctx context.Context, in *raft.LeaveRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	GetNode(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*raft.GetNodeResponse, error)
	GetCluster(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*raft.GetClusterResponse, error)
	Snapshot(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResponse, 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)
}

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 IndexCommand 

type IndexCommand struct {
	Type                 IndexCommand_Type `protobuf:"varint,1,opt,name=type,proto3,enum=index.IndexCommand_Type" json:"type,omitempty"`
	Data                 *any.Any          `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*IndexCommand) Descriptor 

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

func (*IndexCommand) GetData 

func (m *IndexCommand) GetData() *any.Any

func (*IndexCommand) GetType 

func (m *IndexCommand) GetType() IndexCommand_Type

func (*IndexCommand) ProtoMessage 

func (*IndexCommand) ProtoMessage()

func (*IndexCommand) Reset 

func (m *IndexCommand) Reset()

func (*IndexCommand) String 

func (m *IndexCommand) String() string

func (*IndexCommand) XXX_DiscardUnknown 

func (m *IndexCommand) XXX_DiscardUnknown()

func (*IndexCommand) XXX_Marshal 

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

func (*IndexCommand) XXX_Merge 

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

func (*IndexCommand) XXX_Size 

func (m *IndexCommand) XXX_Size() int

func (*IndexCommand) XXX_Unmarshal 

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

type IndexCommand_Type 

type IndexCommand_Type int32
const (
	IndexCommand_UNKNOWN_COMMAND IndexCommand_Type = 0
	IndexCommand_SET_METADATA    IndexCommand_Type = 1
	IndexCommand_DELETE_METADATA IndexCommand_Type = 2
	IndexCommand_INDEX_DOCUMENT  IndexCommand_Type = 3
	IndexCommand_DELETE_DOCUMENT IndexCommand_Type = 4
)

func (IndexCommand_Type) EnumDescriptor 

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

func (IndexCommand_Type) String 

func (x IndexCommand_Type) String() string

type IndexRequest 

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

func (*IndexRequest) Descriptor 

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

func (*IndexRequest) GetDocument 

func (m *IndexRequest) GetDocument() *Document

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 {
	Join(context.Context, *raft.JoinRequest) (*empty.Empty, error)
	Leave(context.Context, *raft.LeaveRequest) (*empty.Empty, error)
	GetNode(context.Context, *empty.Empty) (*raft.GetNodeResponse, error)
	GetCluster(context.Context, *empty.Empty) (*raft.GetClusterResponse, error)
	Snapshot(context.Context, *empty.Empty) (*empty.Empty, error)
	Get(context.Context, *GetRequest) (*GetResponse, error)
	Search(context.Context, *SearchRequest) (*SearchResponse, error)
	Index(context.Context, *IndexRequest) (*empty.Empty, error)
	Delete(context.Context, *DeleteRequest) (*empty.Empty, error)
}

IndexServer is the server API for Index service.

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

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.