grpc

Documentation

Overview

Package grpc provides the Pydio grpc service for querying indexer.

Insertion in the index is not performed directly but via events broadcasted by the broker.

Index

• Variables
• type EventsSubscriber
  • func (e *EventsSubscriber) Handle(ctx context.Context, msg *tree.NodeChangeEvent) error
• type SearchServer
  • func (s *SearchServer) CreateNodeChangeSubscriber() *EventsSubscriber
  • func (s *SearchServer) NamespacesProvider() *meta.NamespacesProvider
  • func (s *SearchServer) ReindexFolder(c context.Context, node *tree.Node, excludes map[string]struct{})
  • func (s *SearchServer) Search(ctx context.Context, req *tree.SearchRequest, ...) error
  • func (s *SearchServer) TriggerResync(c context.Context, req *protosync.ResyncRequest, ...) error

Variables

var (
	Name = common.SERVICE_GRPC_NAMESPACE_ + common.SERVICE_SEARCH
)

Types

type EventsSubscriber

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

EventsSubscriber definition

func (*EventsSubscriber) Handle

func (e *EventsSubscriber) Handle(ctx context.Context, msg *tree.NodeChangeEvent) error

Handle the events received and send them to the subscriber

type SearchServer

type SearchServer struct {
	Engine dao.SearchEngine

	TreeClient tree.NodeProviderClient
	NsProvider *meta.NamespacesProvider
	// contains filtered or unexported fields
}

func (*SearchServer) CreateNodeChangeSubscriber

func (s *SearchServer) CreateNodeChangeSubscriber() *EventsSubscriber

CreateNodeChangeSubscriber that will treat events for the meta server

func (*SearchServer) NamespacesProvider

func (s *SearchServer) NamespacesProvider() *meta.NamespacesProvider

func (*SearchServer) ReindexFolder

func (s *SearchServer) ReindexFolder(c context.Context, node *tree.Node, excludes map[string]struct{})

func (*SearchServer) Search

func (s *SearchServer) Search(ctx context.Context, req *tree.SearchRequest, streamer tree.Searcher_SearchStream) error

func (*SearchServer) TriggerResync

func (s *SearchServer) TriggerResync(c context.Context, req *protosync.ResyncRequest, resp *protosync.ResyncResponse) error