grpc

Documentation

Index

• type MetaServer
  • func NewMetaServer(ctx context.Context, srvName string) *MetaServer
  • func (s *MetaServer) CreateNode(ctx context.Context, req *tree.CreateNodeRequest) (resp *tree.CreateNodeResponse, err error)
  • func (s *MetaServer) DeleteNode(ctx context.Context, request *tree.DeleteNodeRequest) (result *tree.DeleteNodeResponse, err error)
  • func (s *MetaServer) ListNodes(req *tree.ListNodesRequest, resp tree.NodeProvider_ListNodesServer) (err error)
  • func (s *MetaServer) ProcessEvent(ctx context.Context, e *tree.NodeChangeEvent) error
  • func (s *MetaServer) ReadNode(ctx context.Context, req *tree.ReadNodeRequest) (resp *tree.ReadNodeResponse, err error)
  • func (s *MetaServer) ReadNodeStream(streamer tree.NodeProviderStreamer_ReadNodeStreamServer) error
  • func (s *MetaServer) Stop()
  • func (s *MetaServer) UpdateNode(ctx context.Context, req *tree.UpdateNodeRequest) (resp *tree.UpdateNodeResponse, err error)

Types

type MetaServer

type MetaServer struct {
	tree.UnimplementedNodeProviderServer
	tree.UnimplementedNodeProviderStreamerServer
	tree.UnimplementedNodeReceiverServer
	// contains filtered or unexported fields
}

MetaServer definition

func NewMetaServer

func NewMetaServer(ctx context.Context, srvName string) *MetaServer

func (*MetaServer) CreateNode

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

CreateNode metadata

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(req *tree.ListNodesRequest, resp tree.NodeProvider_ListNodesServer) (err error)

ListNodes information from the meta server (Not implemented)

func (*MetaServer) ProcessEvent

func (s *MetaServer) ProcessEvent(ctx context.Context, e *tree.NodeChangeEvent) error

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(streamer tree.NodeProviderStreamer_ReadNodeStreamServer) error

ReadNodeStream implements ReadNode as a bidirectional stream

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