grpc

Documentation

Overview

Package grpc exposes the document store api in GRPC

Index

• Variables
• type Handler
  • func (h *Handler) CountDocuments(ctx context.Context, request *proto.ListDocumentsRequest) (*proto.CountDocumentsResponse, error)
  • func (h *Handler) DeleteDocuments(ctx context.Context, request *proto.DeleteDocumentsRequest) (*proto.DeleteDocumentsResponse, error)
  • func (h *Handler) GetDocument(ctx context.Context, request *proto.GetDocumentRequest) (*proto.GetDocumentResponse, error)
  • func (h *Handler) ListDocuments(request *proto.ListDocumentsRequest, stream proto.DocStore_ListDocumentsServer) error
  • func (h *Handler) Name() string
  • func (h *Handler) PutDocument(ctx context.Context, request *proto.PutDocumentRequest) (*proto.PutDocumentResponse, error)
  • func (h *Handler) TriggerResync(ctx context.Context, request *sync.ResyncRequest) (*sync.ResyncResponse, error)

Variables

var (
	Name = common.ServiceGrpcNamespace_ + common.ServiceDocStore
)

Types

type Handler

type Handler struct {
	proto.UnimplementedDocStoreServer
	sync.UnimplementedSyncEndpointServer
	DAO docstore.DAO
}

func (*Handler) CountDocuments

func (h *Handler) CountDocuments(ctx context.Context, request *proto.ListDocumentsRequest) (*proto.CountDocumentsResponse, error)

func (*Handler) DeleteDocuments

func (h *Handler) DeleteDocuments(ctx context.Context, request *proto.DeleteDocumentsRequest) (*proto.DeleteDocumentsResponse, error)

func (*Handler) GetDocument

func (h *Handler) GetDocument(ctx context.Context, request *proto.GetDocumentRequest) (*proto.GetDocumentResponse, error)

func (*Handler) ListDocuments

func (h *Handler) ListDocuments(request *proto.ListDocumentsRequest, stream proto.DocStore_ListDocumentsServer) error

func (*Handler) Name

func (h *Handler) Name() string

func (*Handler) PutDocument

func (h *Handler) PutDocument(ctx context.Context, request *proto.PutDocumentRequest) (*proto.PutDocumentResponse, error)

func (*Handler) TriggerResync

func (h *Handler) TriggerResync(ctx context.Context, request *sync.ResyncRequest) (*sync.ResyncResponse, error)

TriggerResync clear search index and reindex all docs from DB