grpc

package
v2.2.3+incompatible Latest Latest
Warning

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

Go to latest
Published: Mar 9, 2021 License: AGPL-3.0 Imports: 24 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 {
	Engine dao.SearchEngine

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

SearchServer implements GRPC server for index/search

func (*SearchServer) CreateNodeChangeSubscriber

func (s *SearchServer) CreateNodeChangeSubscriber() *EventsSubscriber

CreateNodeChangeSubscriber that will treat events for the meta server

func (*SearchServer) NamespacesProvider added in v1.5.0

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

func (*SearchServer) ReindexFolder added in v1.5.0

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

func (*SearchServer) Search

func (*SearchServer) TriggerResync

Jump to

Keyboard shortcuts

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