Documentation ¶
Index ¶
- type Metrics
- type 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)
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 (*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
Click to show internal directories.
Click to hide internal directories.