northbound

Documentation

Index

• func NewService(store store.Store) northbound.Service
• type Server
  • func (s *Server) Create(ctx context.Context, req *topoapi.CreateRequest) (*topoapi.CreateResponse, error)
  • func (s *Server) Delete(ctx context.Context, req *topoapi.DeleteRequest) (*topoapi.DeleteResponse, error)
  • func (s *Server) Get(ctx context.Context, req *topoapi.GetRequest) (*topoapi.GetResponse, error)
  • func (s *Server) List(ctx context.Context, req *topoapi.ListRequest) (*topoapi.ListResponse, error)
  • func (s *Server) Stream(server topoapi.Topo_WatchServer, ch chan topoapi.Event) error
  • func (s *Server) Update(ctx context.Context, req *topoapi.UpdateRequest) (*topoapi.UpdateResponse, error)
  • func (s *Server) ValidateObject(ctx context.Context, object *topoapi.Object) error
  • func (s *Server) Watch(req *topoapi.WatchRequest, server topoapi.Topo_WatchServer) error
• type Service
  • func (s Service) Register(r *grpc.Server)

Functions

func NewService

func NewService(store store.Store) northbound.Service

NewService returns a new topo Service

Types

type Server

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

Server implements the gRPC service for administrative facilities.

func (*Server) Create

func (s *Server) Create(ctx context.Context, req *topoapi.CreateRequest) (*topoapi.CreateResponse, error)

Create creates a new topology object

func (*Server) Delete

func (s *Server) Delete(ctx context.Context, req *topoapi.DeleteRequest) (*topoapi.DeleteResponse, error)

Delete removes the specified topology object

func (*Server) Get

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

Get retrieves the specified topology object

func (*Server) List

func (s *Server) List(ctx context.Context, req *topoapi.ListRequest) (*topoapi.ListResponse, error)

List returns list of all objects

func (*Server) Stream

func (s *Server) Stream(server topoapi.Topo_WatchServer, ch chan topoapi.Event) error

Stream is the ongoing stream for WatchTerminations request

func (*Server) Update

func (s *Server) Update(ctx context.Context, req *topoapi.UpdateRequest) (*topoapi.UpdateResponse, error)

Update creates an existing topology object

func (*Server) ValidateObject

func (s *Server) ValidateObject(ctx context.Context, object *topoapi.Object) error

ValidateObject validates the given object

func (*Server) Watch

func (s *Server) Watch(req *topoapi.WatchRequest, server topoapi.Topo_WatchServer) error

Watch streams topology changes

type Service

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

Service is a Service implementation for administration.

func (Service) Register

func (s Service) Register(r *grpc.Server)

Register registers the Service with the gRPC server.