monitor

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

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_BrokerStatusClient 

type Monitor_BrokerStatusClient interface {
	Send(*broker.Status) error
	CloseAndRecv() (*types.Empty, error)
	grpc.ClientStream
}

type Monitor_BrokerStatusServer 

type Monitor_BrokerStatusServer interface {
	SendAndClose(*types.Empty) error
	Recv() (*broker.Status, 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_GatewayStatusClient 

type Monitor_GatewayStatusClient interface {
	Send(*gateway.Status) error
	CloseAndRecv() (*types.Empty, error)
	grpc.ClientStream
}

type Monitor_GatewayStatusServer 

type Monitor_GatewayStatusServer interface {
	SendAndClose(*types.Empty) error
	Recv() (*gateway.Status, 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_HandlerStatusClient 

type Monitor_HandlerStatusClient interface {
	Send(*handler.Status) error
	CloseAndRecv() (*types.Empty, error)
	grpc.ClientStream
}

type Monitor_HandlerStatusServer 

type Monitor_HandlerStatusServer interface {
	SendAndClose(*types.Empty) error
	Recv() (*handler.Status, 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 Monitor_RouterStatusClient 

type Monitor_RouterStatusClient interface {
	Send(*router.Status) error
	CloseAndRecv() (*types.Empty, error)
	grpc.ClientStream
}

type Monitor_RouterStatusServer 

type Monitor_RouterStatusServer interface {
	SendAndClose(*types.Empty) error
	Recv() (*router.Status, error)
	grpc.ServerStream
}

type UnimplementedMonitorServer 

type UnimplementedMonitorServer struct {
}

UnimplementedMonitorServer can be embedded to have forward compatible implementations. 

func (*UnimplementedMonitorServer) BrokerDownlink(srv Monitor_BrokerDownlinkServer) error

func (*UnimplementedMonitorServer) BrokerStatus 

func (*UnimplementedMonitorServer) BrokerStatus(srv Monitor_BrokerStatusServer) error
func (*UnimplementedMonitorServer) BrokerUplink(srv Monitor_BrokerUplinkServer) error
func (*UnimplementedMonitorServer) GatewayDownlink(srv Monitor_GatewayDownlinkServer) error

func (*UnimplementedMonitorServer) GatewayStatus 

func (*UnimplementedMonitorServer) GatewayStatus(srv Monitor_GatewayStatusServer) error
func (*UnimplementedMonitorServer) GatewayUplink(srv Monitor_GatewayUplinkServer) error
func (*UnimplementedMonitorServer) HandlerDownlink(srv Monitor_HandlerDownlinkServer) error

func (*UnimplementedMonitorServer) HandlerStatus 

func (*UnimplementedMonitorServer) HandlerStatus(srv Monitor_HandlerStatusServer) error
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

Source Files

View all Source files

Directories

Path Synopsis

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.