grpc

Documentation

Index

• Variables
• type EventsSubscriber
  • func (e *EventsSubscriber) Handle(ctx context.Context, msg *tree.NodeChangeEvent) error
• type SearchServer
  • func (s *SearchServer) ReindexFolder(ctx context.Context, node *tree.Node)
  • func (s *SearchServer) Search(req *tree.SearchRequest, streamer tree.Searcher_SearchServer) error
  • func (s *SearchServer) Subscriber() *EventsSubscriber
  • func (s *SearchServer) TriggerResync(ctx 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,
			},
		},
	}},
}

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 {
	tree.UnimplementedSearcherServer
	protosync.UnimplementedSyncEndpointServer
	RuntimeCtx context.Context

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

SearchServer implements GRPC server for index/search

func (*SearchServer) ReindexFolder

func (s *SearchServer) ReindexFolder(ctx context.Context, node *tree.Node)

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(ctx context.Context, req *protosync.ResyncRequest) (*protosync.ResyncResponse, error)