grpc

package
v4.0.0-beta3 Latest Latest
Warning

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

Go to latest
Published: Jun 16, 2022 License: AGPL-3.0 Imports: 26 Imported by: 0

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

Constants

This section is empty.

Variables

View Source
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,
			},
		},
	}},
}

Functions

This section is empty.

Types

type EventsSubscriber

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

EventsSubscriber definition

func (*EventsSubscriber) Handle

Handle the events received and send them to the subscriber

type SearchServer

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

	TreeClient       tree.NodeProviderClient
	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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL