monitorserver

package
v0.0.0-...-228f33a Latest Latest
Warning

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

 Go to latest Published: Aug 18, 2021 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Metrics 

type Metrics struct {
	GatewayStatuses         uint64
	UplinkMessages          uint64
	DownlinkMessages        uint64
	BrokerStatuses          uint64
	BrokerUplinkMessages    uint64
	BrokerDownlinkMessages  uint64
	HandlerStatuses         uint64
	HandlerUplinkMessages   uint64
	HandlerDownlinkMessages uint64
	RouterStatuses          uint64
	NetworkServerStatuses   uint64
}

type ReferenceMonitorServer 

type ReferenceMonitorServer struct {
	Metrics *Metrics
	// contains filtered or unexported fields
}

ReferenceMonitorServer is a new reference monitor server

func NewReferenceMonitorServer 

func NewReferenceMonitorServer(bufferSize int) *ReferenceMonitorServer

NewReferenceMonitorServer creates a new reference monitor server 

func (s *ReferenceMonitorServer) BrokerDownlink(stream monitor.Monitor_BrokerDownlinkServer) error

BrokerDownlink RPC

func (*ReferenceMonitorServer) BrokerStatus 

func (s *ReferenceMonitorServer) BrokerStatus(stream monitor.Monitor_BrokerStatusServer) (err error)

BrokerStatus RPC 

func (s *ReferenceMonitorServer) BrokerUplink(stream monitor.Monitor_BrokerUplinkServer) error

BrokerUplink RPC 

func (s *ReferenceMonitorServer) GatewayDownlink(stream monitor.Monitor_GatewayDownlinkServer) error

GatewayDownlink RPC

func (*ReferenceMonitorServer) GatewayStatus 

func (s *ReferenceMonitorServer) GatewayStatus(stream monitor.Monitor_GatewayStatusServer) (err error)

GatewayStatus RPC 

func (s *ReferenceMonitorServer) GatewayUplink(stream monitor.Monitor_GatewayUplinkServer) error

GatewayUplink RPC 

func (s *ReferenceMonitorServer) HandlerDownlink(stream monitor.Monitor_HandlerDownlinkServer) error

HandlerDownlink RPC

func (*ReferenceMonitorServer) HandlerStatus 

func (s *ReferenceMonitorServer) HandlerStatus(stream monitor.Monitor_HandlerStatusServer) (err error)

HandlerStatus RPC 

func (s *ReferenceMonitorServer) HandlerUplink(stream monitor.Monitor_HandlerUplinkServer) error

HandlerUplink RPC

func (*ReferenceMonitorServer) NetworkServerStatus 

func (s *ReferenceMonitorServer) NetworkServerStatus(stream monitor.Monitor_NetworkServerStatusServer) (err error)

NetworkServerStatus RPC

func (*ReferenceMonitorServer) RouterStatus 

func (s *ReferenceMonitorServer) RouterStatus(stream monitor.Monitor_RouterStatusServer) (err error)

RouterStatus RPC

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.