grpc

Documentation

Overview

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

Index

• type EventsSubscriber
  • func (e *EventsSubscriber) Handle(ctx context.Context, msg *tree.NodeChangeEvent) error
• type MetaServer
  • func NewMetaServer() *MetaServer
  • func (s *MetaServer) CreateNode(ctx context.Context, req *tree.CreateNodeRequest, ...) (err error)
  • func (s *MetaServer) CreateNodeChangeSubscriber(parentContext context.Context) *EventsSubscriber
  • func (s *MetaServer) DeleteNode(ctx context.Context, request *tree.DeleteNodeRequest, ...) (err error)
  • func (s *MetaServer) ListNodes(ctx context.Context, req *tree.ListNodesRequest, ...) (err error)
  • func (s *MetaServer) ReadNode(ctx context.Context, req *tree.ReadNodeRequest, resp *tree.ReadNodeResponse) (err error)
  • func (s *MetaServer) ReadNodeStream(ctx context.Context, streamer tree.NodeProviderStreamer_ReadNodeStreamStream) error
  • func (s *MetaServer) Search(ctx context.Context, request *tree.SearchRequest, ...) error
  • func (s *MetaServer) Stop()
  • func (s *MetaServer) UpdateNode(ctx context.Context, req *tree.UpdateNodeRequest, ...) (err error)

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 MetaServer

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

MetaServer definition

func NewMetaServer

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

func (s *MetaServer) ListNodes(ctx context.Context, req *tree.ListNodesRequest, resp tree.NodeProvider_ListNodesStream) (err error)

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

func (s *MetaServer) ReadNodeStream(ctx context.Context, streamer tree.NodeProviderStreamer_ReadNodeStreamStream) error

ReadNodeStream implements ReadNode 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

func (s *MetaServer) Stop()

func (*MetaServer) UpdateNode

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

UpdateNode metadata