diags

Documentation

Overview

Package diags implements the diagnostic gRPC service for the configuration subsystem.

Index

• type Server
  • func (s Server) GetOpState(r *diags.OpStateRequest, stream diags.OpStateDiags_GetOpStateServer) error
  • func (s Server) ListDeviceChanges(r *diags.ListDeviceChangeRequest, ...) error
  • func (s Server) ListNetworkChanges(r *diags.ListNetworkChangeRequest, ...) error
• type Service
  • func NewService(deviceChangesStore device.Store, deviceCache cache.Cache, ...) Service
  • func (s Service) Register(r *grpc.Server)

Types

type Server

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

Server implements the gRPC service for diagnostic facilities.

func (Server) GetOpState

func (s Server) GetOpState(r *diags.OpStateRequest, stream diags.OpStateDiags_GetOpStateServer) error

GetOpState provides a stream of Operational and State data

func (Server) ListDeviceChanges

func (s Server) ListDeviceChanges(r *diags.ListDeviceChangeRequest, stream diags.ChangeService_ListDeviceChangesServer) error

ListDeviceChanges provides a stream of Device Changes

func (Server) ListNetworkChanges

func (s Server) ListNetworkChanges(r *diags.ListNetworkChangeRequest, stream diags.ChangeService_ListNetworkChangesServer) error

ListNetworkChanges provides a stream of Network Changes If the optional `subscribe` flag is true, then get then return the list of changes first, and then hold the connection open and send on further updates until the client hangs up

type Service

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

Service is a Service implementation for administration.

func NewService

func NewService(deviceChangesStore device.Store,
	deviceCache cache.Cache,
	networkChangesStore network.Store,
	dispatcher *dispatcher.Dispatcher,
	deviceStore devicestore.Store,
	operationalStateCache *map[topodevice.ID]devicechange.TypedValueMap,
	operationalStateCacheLock *sync.RWMutex) Service

NewService allocates a Service struct with the given parameters

func (Service) Register

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

Register registers the Service with the gRPC server.