router

Documentation

Index

• type Metrics
• type ReferenceRouterServer
  • func NewReferenceRouterServer(bufferSize int) *ReferenceRouterServer
  • func (s *ReferenceRouterServer) Activate(ctx context.Context, req *DeviceActivationRequest) (*DeviceActivationResponse, error)
  • func (s *ReferenceRouterServer) GatewayStatus(stream Router_GatewayStatusServer) (err error)
  • func (s *ReferenceRouterServer) Subscribe(req *SubscribeRequest, stream Router_SubscribeServer) error
  • func (s *ReferenceRouterServer) Uplink(stream Router_UplinkServer) error

Types

type Metrics

type Metrics struct {
	GatewayStatuses uint64
	UplinkMessages  uint64
}

type ReferenceRouterServer

type ReferenceRouterServer struct {
	GatewayStatuses chan *gateway.Status
	UplinkMessages  chan *UplinkMessage

	Downlink map[string]*downlinkSubscription

	Metrics *Metrics
	// contains filtered or unexported fields
}

ReferenceRouterServer is a new reference router server

func NewReferenceRouterServer

func NewReferenceRouterServer(bufferSize int) *ReferenceRouterServer

NewReferenceRouterServer creates a new reference router server

func (*ReferenceRouterServer) Activate

func (s *ReferenceRouterServer) Activate(ctx context.Context, req *DeviceActivationRequest) (*DeviceActivationResponse, error)

Activate RPC

func (*ReferenceRouterServer) GatewayStatus

func (s *ReferenceRouterServer) GatewayStatus(stream Router_GatewayStatusServer) (err error)

GatewayStatus RPC

func (*ReferenceRouterServer) Subscribe

func (s *ReferenceRouterServer) Subscribe(req *SubscribeRequest, stream Router_SubscribeServer) error

Subscribe RPC

func (*ReferenceRouterServer) Uplink

func (s *ReferenceRouterServer) Uplink(stream Router_UplinkServer) error

Uplink RPC