risserver

Documentation

Index

• type RequestWithVRF
• type Server
  • func NewServer(b server.BMPServerInterface) *Server
  • func (s *Server) DumpRIB(req *pb.DumpRIBRequest, stream pb.RoutingInformationService_DumpRIBServer) error
  • func (s *Server) Get(ctx context.Context, req *pb.GetRequest) (*pb.GetResponse, error)
  • func (s *Server) GetLonger(ctx context.Context, req *pb.GetLongerRequest) (*pb.GetLongerResponse, error)
  • func (s *Server) GetRouters(c context.Context, request *pb.GetRoutersRequest) (*pb.GetRoutersResponse, error)
  • func (s *Server) LPM(ctx context.Context, req *pb.LPMRequest) (*pb.LPMResponse, error)
  • func (s *Server) ObserveRIB(req *pb.ObserveRIBRequest, ...) error

Types

type RequestWithVRF

type RequestWithVRF interface {
	GetVrfId() uint64
	GetVrf() string
}

type Server

type Server struct {
	pb.UnimplementedRoutingInformationServiceServer
	// contains filtered or unexported fields
}

Server represents an RoutingInformationService server

func NewServer

func NewServer(b server.BMPServerInterface) *Server

NewServer creates a new server

func (*Server) DumpRIB

func (s *Server) DumpRIB(req *pb.DumpRIBRequest, stream pb.RoutingInformationService_DumpRIBServer) error

DumpRIB implements the DumpRIB RPC

func (*Server) Get

func (s *Server) Get(ctx context.Context, req *pb.GetRequest) (*pb.GetResponse, error)

Get gets a prefix (exact match)

func (*Server) GetLonger

func (s *Server) GetLonger(ctx context.Context, req *pb.GetLongerRequest) (*pb.GetLongerResponse, error)

GetLonger gets all more specifics of a prefix

func (*Server) GetRouters

func (s *Server) GetRouters(c context.Context, request *pb.GetRoutersRequest) (*pb.GetRoutersResponse, error)

GetRouters implements the GetRouters RPC

func (*Server) LPM

func (s *Server) LPM(ctx context.Context, req *pb.LPMRequest) (*pb.LPMResponse, error)

LPM provides a longest prefix match service

func (*Server) ObserveRIB

func (s *Server) ObserveRIB(req *pb.ObserveRIBRequest, stream pb.RoutingInformationService_ObserveRIBServer) error

ObserveRIB implements the ObserveRIB RPC