ng_rpc_server

Documentation

Index

• type RPCServer
  • func NewRPCServer(store graph.GraphStorage, status_srv state.IStatusService, ...) *RPCServer
  • func (s *RPCServer) GetAllLinks(req *rpc.LinksAllRequest, stream rpc.Backend_GetAllLinksServer) error
  • func (s *RPCServer) GetAllMetrics(req *rpc.AllMetricsRequest, stream rpc.Backend_GetAllMetricsServer) error
  • func (s *RPCServer) GetAllNodes(req *rpc.NodesAllRequest, stream rpc.Backend_GetAllNodesServer) error
  • func (s *RPCServer) GetLinkById(ctx context.Context, req *rpc.LinkByIdRequest) (*rpc.Link, error)
  • func (s *RPCServer) GetNodeById(ctx context.Context, req *rpc.NodeByIdRequest) (*rpc.Node, error)
  • func (s *RPCServer) GetStatus(ctx context.Context, req *rpc.StatusRequest) (*rpc.StatusResponse, error)

Types

type RPCServer

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

func NewRPCServer

func NewRPCServer(store graph.GraphStorage, status_srv state.IStatusService, metric_srv metric.MetricStorage) *RPCServer

func (*RPCServer) GetAllLinks

func (s *RPCServer) GetAllLinks(req *rpc.LinksAllRequest, stream rpc.Backend_GetAllLinksServer) error

func (*RPCServer) GetAllMetrics

func (s *RPCServer) GetAllMetrics(req *rpc.AllMetricsRequest, stream rpc.Backend_GetAllMetricsServer) error

func (*RPCServer) GetAllNodes

func (s *RPCServer) GetAllNodes(req *rpc.NodesAllRequest, stream rpc.Backend_GetAllNodesServer) error

func (*RPCServer) GetLinkById

func (s *RPCServer) GetLinkById(ctx context.Context, req *rpc.LinkByIdRequest) (*rpc.Link, error)

func (*RPCServer) GetNodeById

func (s *RPCServer) GetNodeById(ctx context.Context, req *rpc.NodeByIdRequest) (*rpc.Node, error)

func (*RPCServer) GetStatus

func (s *RPCServer) GetStatus(ctx context.Context, req *rpc.StatusRequest) (*rpc.StatusResponse, error)