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
  • func (e *EventsSubscriber) Start(ctx context.Context) error
• type SearchServer
  • func (s *SearchServer) Name() string
  • func (s *SearchServer) ReindexFolder(c context.Context, node *tree.Node, excludes map[string]struct{})
  • func (s *SearchServer) Search(req *tree.SearchRequest, streamer tree.Searcher_SearchServer) error
  • func (s *SearchServer) Subscriber() *EventsSubscriber
  • func (s *SearchServer) TriggerResync(c context.Context, req *protosync.ResyncRequest) (*protosync.ResyncResponse, error)

Variables

var ExposedConfigs = &forms.Form{
	I18NBundle: lang.Bundle(),
	Groups: []*forms.Group{{
		Fields: []forms.Field{
			&forms.FormField{
				Name:             "basenameAnalyzer",
				Type:             forms.ParamSelect,
				Label:            "Search.Config.BasenameAnalyze.Label",
				Description:      "Search.Config.BasenameAnalyze.Description",
				Default:          "standard",
				Mandatory:        true,
				ChoicePresetList: bleveAnalyzers,
			},
			&forms.FormField{
				Name:        "indexContent",
				Type:        forms.ParamBool,
				Label:       "Search.Config.IndexContent.Label",
				Description: "Search.Config.IndexContent.Description",
				Default:     false,
			},
			&forms.FormField{
				Name:             "contentAnalyzer",
				Type:             forms.ParamSelect,
				Label:            "Search.Config.ContentAnalyzer.Label",
				Description:      "Search.Config.ContentAnalyzer.Description",
				Default:          "en",
				Mandatory:        true,
				ChoicePresetList: bleveAnalyzers,
			},
			&forms.FormField{
				Name:        "contentRef",
				Type:        forms.ParamString,
				Label:       "Search.Config.ContentRef.Label",
				Description: "Search.Config.ContentRef.Description",
				Default:     "pydio:ContentRef",
				Mandatory:   false,
			},
			&forms.FormField{
				Name:        "plainTextExtensions",
				Type:        forms.ParamString,
				Label:       "Search.Config.PlainTextExtensions.Label",
				Description: "Search.Config.PlainTextExtensions.Description",
				Default:     "txt",
				Mandatory:   false,
			},
		},
	}},
}

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

Types

type EventsSubscriber

type EventsSubscriber struct {
	queue.Queue
	// 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

func (*EventsSubscriber) Start

func (e *EventsSubscriber) Start(ctx context.Context) error

type SearchServer

type SearchServer struct {
	tree.UnimplementedSearcherServer
	protosync.UnimplementedSyncEndpointServer
	RuntimeCtx context.Context
	Engine     dao.SearchEngine

	TreeClient       tree.NodeProviderClient
	TreeClientStream tree.NodeProviderStreamerClient
	NsProvider       *meta.NsProvider
	ReIndexThrottler chan struct{}
	// contains filtered or unexported fields
}

SearchServer implements GRPC server for index/search

func (*SearchServer) Name

func (s *SearchServer) Name() string

func (*SearchServer) ReindexFolder

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

func (*SearchServer) Search

func (s *SearchServer) Search(req *tree.SearchRequest, streamer tree.Searcher_SearchServer) error

func (*SearchServer) Subscriber

func (s *SearchServer) Subscriber() *EventsSubscriber

Subscriber create a handler that will treat events for the meta server

func (*SearchServer) TriggerResync

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