Documentation
¶
Index ¶
- func RegisterMonitorServer(s *grpc.Server, srv MonitorServer)
- type MonitorClient
- type MonitorServer
- type Monitor_BrokerDownlinkClient
- type Monitor_BrokerDownlinkServer
- type Monitor_BrokerStatusClient
- type Monitor_BrokerStatusServer
- type Monitor_BrokerUplinkClient
- type Monitor_BrokerUplinkServer
- type Monitor_GatewayDownlinkClient
- type Monitor_GatewayDownlinkServer
- type Monitor_GatewayStatusClient
- type Monitor_GatewayStatusServer
- type Monitor_GatewayUplinkClient
- type Monitor_GatewayUplinkServer
- type Monitor_HandlerDownlinkClient
- type Monitor_HandlerDownlinkServer
- type Monitor_HandlerStatusClient
- type Monitor_HandlerStatusServer
- type Monitor_HandlerUplinkClient
- type Monitor_HandlerUplinkServer
- type Monitor_NetworkServerStatusClient
- type Monitor_NetworkServerStatusServer
- type Monitor_RouterStatusClient
- type Monitor_RouterStatusServer
- type UnimplementedMonitorServer
- func (*UnimplementedMonitorServer) BrokerDownlink(srv Monitor_BrokerDownlinkServer) error
- func (*UnimplementedMonitorServer) BrokerStatus(srv Monitor_BrokerStatusServer) error
- func (*UnimplementedMonitorServer) BrokerUplink(srv Monitor_BrokerUplinkServer) error
- func (*UnimplementedMonitorServer) GatewayDownlink(srv Monitor_GatewayDownlinkServer) error
- func (*UnimplementedMonitorServer) GatewayStatus(srv Monitor_GatewayStatusServer) error
- func (*UnimplementedMonitorServer) GatewayUplink(srv Monitor_GatewayUplinkServer) error
- func (*UnimplementedMonitorServer) HandlerDownlink(srv Monitor_HandlerDownlinkServer) error
- func (*UnimplementedMonitorServer) HandlerStatus(srv Monitor_HandlerStatusServer) error
- func (*UnimplementedMonitorServer) HandlerUplink(srv Monitor_HandlerUplinkServer) error
- func (*UnimplementedMonitorServer) NetworkServerStatus(srv Monitor_NetworkServerStatusServer) error
- func (*UnimplementedMonitorServer) RouterStatus(srv Monitor_RouterStatusServer) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterMonitorServer ¶
func RegisterMonitorServer(s *grpc.Server, srv MonitorServer)
Types ¶
type MonitorClient ¶
type MonitorClient interface {
RouterStatus(ctx context.Context, opts ...grpc.CallOption) (Monitor_RouterStatusClient, error)
GatewayStatus(ctx context.Context, opts ...grpc.CallOption) (Monitor_GatewayStatusClient, error)
GatewayUplink(ctx context.Context, opts ...grpc.CallOption) (Monitor_GatewayUplinkClient, error)
GatewayDownlink(ctx context.Context, opts ...grpc.CallOption) (Monitor_GatewayDownlinkClient, error)
BrokerStatus(ctx context.Context, opts ...grpc.CallOption) (Monitor_BrokerStatusClient, error)
BrokerUplink(ctx context.Context, opts ...grpc.CallOption) (Monitor_BrokerUplinkClient, error)
BrokerDownlink(ctx context.Context, opts ...grpc.CallOption) (Monitor_BrokerDownlinkClient, error)
HandlerStatus(ctx context.Context, opts ...grpc.CallOption) (Monitor_HandlerStatusClient, error)
HandlerUplink(ctx context.Context, opts ...grpc.CallOption) (Monitor_HandlerUplinkClient, error)
HandlerDownlink(ctx context.Context, opts ...grpc.CallOption) (Monitor_HandlerDownlinkClient, error)
NetworkServerStatus(ctx context.Context, opts ...grpc.CallOption) (Monitor_NetworkServerStatusClient, error)
}
MonitorClient is the client API for Monitor service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMonitorClient ¶
func NewMonitorClient(cc *grpc.ClientConn) MonitorClient
type MonitorServer ¶
type MonitorServer interface {
RouterStatus(Monitor_RouterStatusServer) error
GatewayStatus(Monitor_GatewayStatusServer) error
GatewayUplink(Monitor_GatewayUplinkServer) error
GatewayDownlink(Monitor_GatewayDownlinkServer) error
BrokerStatus(Monitor_BrokerStatusServer) error
BrokerUplink(Monitor_BrokerUplinkServer) error
BrokerDownlink(Monitor_BrokerDownlinkServer) error
HandlerStatus(Monitor_HandlerStatusServer) error
HandlerUplink(Monitor_HandlerUplinkServer) error
HandlerDownlink(Monitor_HandlerDownlinkServer) error
NetworkServerStatus(Monitor_NetworkServerStatusServer) error
}
MonitorServer is the server API for Monitor service.
type Monitor_BrokerDownlinkClient ¶
type Monitor_BrokerDownlinkClient interface {
Send(*broker.DownlinkMessage) error
CloseAndRecv() (*types.Empty, error)
grpc.ClientStream
}
type Monitor_BrokerDownlinkServer ¶
type Monitor_BrokerDownlinkServer interface {
SendAndClose(*types.Empty) error
Recv() (*broker.DownlinkMessage, error)
grpc.ServerStream
}
type Monitor_BrokerUplinkClient ¶
type Monitor_BrokerUplinkClient interface {
Send(*broker.DeduplicatedUplinkMessage) error
CloseAndRecv() (*types.Empty, error)
grpc.ClientStream
}
type Monitor_BrokerUplinkServer ¶
type Monitor_BrokerUplinkServer interface {
SendAndClose(*types.Empty) error
Recv() (*broker.DeduplicatedUplinkMessage, error)
grpc.ServerStream
}
type Monitor_GatewayDownlinkClient ¶
type Monitor_GatewayDownlinkClient interface {
Send(*router.DownlinkMessage) error
CloseAndRecv() (*types.Empty, error)
grpc.ClientStream
}
type Monitor_GatewayDownlinkServer ¶
type Monitor_GatewayDownlinkServer interface {
SendAndClose(*types.Empty) error
Recv() (*router.DownlinkMessage, error)
grpc.ServerStream
}
type Monitor_GatewayUplinkClient ¶
type Monitor_GatewayUplinkClient interface {
Send(*router.UplinkMessage) error
CloseAndRecv() (*types.Empty, error)
grpc.ClientStream
}
type Monitor_GatewayUplinkServer ¶
type Monitor_GatewayUplinkServer interface {
SendAndClose(*types.Empty) error
Recv() (*router.UplinkMessage, error)
grpc.ServerStream
}
type Monitor_HandlerDownlinkClient ¶
type Monitor_HandlerDownlinkClient interface {
Send(*broker.DownlinkMessage) error
CloseAndRecv() (*types.Empty, error)
grpc.ClientStream
}
type Monitor_HandlerDownlinkServer ¶
type Monitor_HandlerDownlinkServer interface {
SendAndClose(*types.Empty) error
Recv() (*broker.DownlinkMessage, error)
grpc.ServerStream
}
type Monitor_HandlerUplinkClient ¶
type Monitor_HandlerUplinkClient interface {
Send(*broker.DeduplicatedUplinkMessage) error
CloseAndRecv() (*types.Empty, error)
grpc.ClientStream
}
type Monitor_HandlerUplinkServer ¶
type Monitor_HandlerUplinkServer interface {
SendAndClose(*types.Empty) error
Recv() (*broker.DeduplicatedUplinkMessage, error)
grpc.ServerStream
}
type Monitor_NetworkServerStatusClient ¶
type Monitor_NetworkServerStatusClient interface {
Send(*networkserver.Status) error
CloseAndRecv() (*types.Empty, error)
grpc.ClientStream
}
type Monitor_NetworkServerStatusServer ¶
type Monitor_NetworkServerStatusServer interface {
SendAndClose(*types.Empty) error
Recv() (*networkserver.Status, error)
grpc.ServerStream
}
type UnimplementedMonitorServer ¶
type UnimplementedMonitorServer struct {
}
UnimplementedMonitorServer can be embedded to have forward compatible implementations.
func (*UnimplementedMonitorServer) BrokerDownlink ¶
func (*UnimplementedMonitorServer) BrokerDownlink(srv Monitor_BrokerDownlinkServer) error
func (*UnimplementedMonitorServer) BrokerStatus ¶
func (*UnimplementedMonitorServer) BrokerStatus(srv Monitor_BrokerStatusServer) error
func (*UnimplementedMonitorServer) BrokerUplink ¶
func (*UnimplementedMonitorServer) BrokerUplink(srv Monitor_BrokerUplinkServer) error
func (*UnimplementedMonitorServer) GatewayDownlink ¶
func (*UnimplementedMonitorServer) GatewayDownlink(srv Monitor_GatewayDownlinkServer) error
func (*UnimplementedMonitorServer) GatewayStatus ¶
func (*UnimplementedMonitorServer) GatewayStatus(srv Monitor_GatewayStatusServer) error
func (*UnimplementedMonitorServer) GatewayUplink ¶
func (*UnimplementedMonitorServer) GatewayUplink(srv Monitor_GatewayUplinkServer) error
func (*UnimplementedMonitorServer) HandlerDownlink ¶
func (*UnimplementedMonitorServer) HandlerDownlink(srv Monitor_HandlerDownlinkServer) error
func (*UnimplementedMonitorServer) HandlerStatus ¶
func (*UnimplementedMonitorServer) HandlerStatus(srv Monitor_HandlerStatusServer) error
func (*UnimplementedMonitorServer) HandlerUplink ¶
func (*UnimplementedMonitorServer) HandlerUplink(srv Monitor_HandlerUplinkServer) error
func (*UnimplementedMonitorServer) NetworkServerStatus ¶
func (*UnimplementedMonitorServer) NetworkServerStatus(srv Monitor_NetworkServerStatusServer) error
func (*UnimplementedMonitorServer) RouterStatus ¶
func (*UnimplementedMonitorServer) RouterStatus(srv Monitor_RouterStatusServer) error
Click to show internal directories.
Click to hide internal directories.