Version: v0.9.4 Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: Mar 9, 2022 License: Apache-2.0 Imports: 9 Imported by: 0




This section is empty.


This section is empty.


func NewService

func NewService(store store.Store) northbound.Service

NewService returns a new topo Service


type Server

type Server struct {
	// contains filtered or unexported fields

Server implements the gRPC service for administrative facilities.

func (*Server) Create

Create creates a new topology object

func (*Server) Delete

Delete removes the specified topology object

func (*Server) Get

Get retrieves the specified topology object

func (*Server) List

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

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.

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL