monitorserver

Documentation

Index

• type Metrics
• type ReferenceMonitorServer
  • func NewReferenceMonitorServer(bufferSize int) *ReferenceMonitorServer
  • func (s *ReferenceMonitorServer) BrokerDownlink(stream monitor.Monitor_BrokerDownlinkServer) error
  • func (s *ReferenceMonitorServer) BrokerStatus(stream monitor.Monitor_BrokerStatusServer) (err error)
  • func (s *ReferenceMonitorServer) BrokerUplink(stream monitor.Monitor_BrokerUplinkServer) error
  • func (s *ReferenceMonitorServer) GatewayDownlink(stream monitor.Monitor_GatewayDownlinkServer) error
  • func (s *ReferenceMonitorServer) GatewayStatus(stream monitor.Monitor_GatewayStatusServer) (err error)
  • func (s *ReferenceMonitorServer) GatewayUplink(stream monitor.Monitor_GatewayUplinkServer) error
  • func (s *ReferenceMonitorServer) HandlerDownlink(stream monitor.Monitor_HandlerDownlinkServer) error
  • func (s *ReferenceMonitorServer) HandlerStatus(stream monitor.Monitor_HandlerStatusServer) (err error)
  • func (s *ReferenceMonitorServer) HandlerUplink(stream monitor.Monitor_HandlerUplinkServer) error
  • func (s *ReferenceMonitorServer) NetworkServerStatus(stream monitor.Monitor_NetworkServerStatusServer) (err error)
  • func (s *ReferenceMonitorServer) RouterStatus(stream monitor.Monitor_RouterStatusServer) (err error)

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 (*ReferenceMonitorServer) BrokerDownlink

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 (*ReferenceMonitorServer) BrokerUplink

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

BrokerUplink RPC

func (*ReferenceMonitorServer) GatewayDownlink

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 (*ReferenceMonitorServer) GatewayUplink

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

GatewayUplink RPC

func (*ReferenceMonitorServer) HandlerDownlink

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 (*ReferenceMonitorServer) HandlerUplink

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