grpc

package
v2.2.5+incompatible Latest Latest
Warning

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

Go to latest
Published: Apr 6, 2021 License: AGPL-3.0 Imports: 17 Imported by: 0

Documentation

Overview

Package meta provides a GRPC access to the underlying persistence layer for files metadata

Index

Constants

This section is empty.

Variables

This section is empty.

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 MetaServer

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

MetaServer definition

func NewMetaServer added in v1.2.0

func NewMetaServer() *MetaServer

func (*MetaServer) CreateNode

func (s *MetaServer) CreateNode(ctx context.Context, req *tree.CreateNodeRequest, resp *tree.CreateNodeResponse) (err error)

CreateNode metadata

func (*MetaServer) CreateNodeChangeSubscriber

func (s *MetaServer) CreateNodeChangeSubscriber(parentContext context.Context) *EventsSubscriber

CreateNodeChangeSubscriber that will treat events for the meta server

func (*MetaServer) DeleteNode

func (s *MetaServer) DeleteNode(ctx context.Context, request *tree.DeleteNodeRequest, result *tree.DeleteNodeResponse) (err error)

DeleteNode metadata (Not implemented)

func (*MetaServer) ListNodes

ListNodes information from the meta server (Not implemented)

func (*MetaServer) ReadNode

func (s *MetaServer) ReadNode(ctx context.Context, req *tree.ReadNodeRequest, resp *tree.ReadNodeResponse) (err error)

ReadNode information off the meta server

func (*MetaServer) ReadNodeStream

ReadNode implementation as a bidirectional stream

func (*MetaServer) Search

func (s *MetaServer) Search(ctx context.Context, request *tree.SearchRequest, result tree.Searcher_SearchStream) error

Search a stream of nodes based on its metadata

func (*MetaServer) Stop added in v1.4.1

func (s *MetaServer) Stop()

func (*MetaServer) UpdateNode

func (s *MetaServer) UpdateNode(ctx context.Context, req *tree.UpdateNodeRequest, resp *tree.UpdateNodeResponse) (err error)

UpdateNode metadata

Jump to

Keyboard shortcuts

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