grpc

Documentation

Overview

Package grpc exposes the document store api in GRPC

Index

• type Handler
  • func (h *Handler) Close() error
  • func (h *Handler) CountDocuments(ctx context.Context, request *proto.ListDocumentsRequest, ...) error
  • func (h *Handler) DeleteDocuments(ctx context.Context, request *proto.DeleteDocumentsRequest, ...) error
  • func (h *Handler) GetDocument(ctx context.Context, request *proto.GetDocumentRequest, ...) error
  • func (h *Handler) ListDocuments(ctx context.Context, request *proto.ListDocumentsRequest, ...) error
  • func (h *Handler) PutDocument(ctx context.Context, request *proto.PutDocumentRequest, ...) error
  • func (h *Handler) TriggerResync(ctx context.Context, request *sync.ResyncRequest, ...) error

Types

type Handler

type Handler struct {
	Db      docstore.Store
	Indexer docstore.Indexer
}

func (*Handler) Close

func (h *Handler) Close() error

func (*Handler) CountDocuments

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

func (*Handler) DeleteDocuments

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

func (*Handler) GetDocument

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

func (*Handler) ListDocuments

func (h *Handler) ListDocuments(ctx context.Context, request *proto.ListDocumentsRequest, stream proto.DocStore_ListDocumentsStream) error

func (*Handler) PutDocument

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

func (*Handler) TriggerResync

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

TriggerResync clear search index and reindex all docs from DB