routerclient

Documentation

Index

• Variables
• type Client
  • func NewClient(config ClientConfig) *Client
  • func (c *Client) AddServer(name string, conn *grpc.ClientConn)
  • func (c *Client) Close()
  • func (c *Client) NewGatewayStreams(id string, token string, downlinkActive bool) GenericStream
• type ClientConfig
• type GenericStream
• type RouterStreamServer
  • func NewRouterStreamServer() *RouterStreamServer
  • func (s *RouterStreamServer) GatewayStatus(stream Router_GatewayStatusServer) error
  • func (s *RouterStreamServer) SetLogger(logger log.Interface)
  • func (s *RouterStreamServer) Subscribe(req *SubscribeRequest, stream Router_SubscribeServer) (err error)
  • func (s *RouterStreamServer) Uplink(stream Router_UplinkServer) (err error)

Variables

var DefaultClientConfig = ClientConfig{
	BackgroundContext: context.Background(),
	BufferSize:        10,
}

DefaultClientConfig for router Client

var ErrDownlinkInactive = errors.New("Downlink stream not active")

ErrDownlinkInactive is returned by the Downlink func if downlink is inactive

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

Client for router

func NewClient

func NewClient(config ClientConfig) *Client

NewClient creates a new Client with the given configuration

func (*Client) AddServer

func (c *Client) AddServer(name string, conn *grpc.ClientConn)

AddServer adds a router server

func (*Client) Close

func (c *Client) Close()

Close the client and all its connections

func (*Client) NewGatewayStreams

func (c *Client) NewGatewayStreams(id string, token string, downlinkActive bool) GenericStream

NewGatewayStreams returns new streams using the given gateway ID and token

type ClientConfig

type ClientConfig struct {
	BackgroundContext context.Context
	BufferSize        int
}

ClientConfig for router Client

type GenericStream

type GenericStream interface {
	Uplink(*UplinkMessage)
	Status(*gateway.Status)
	Downlink() (<-chan *DownlinkMessage, error)
	Close()
}

GenericStream is used for sending to and receiving from the router.

type RouterStreamServer

type RouterStreamServer struct {
	UplinkChanFunc        func(md metadata.MD) (ch chan *UplinkMessage, err error)
	GatewayStatusChanFunc func(md metadata.MD) (ch chan *gateway.Status, err error)
	DownlinkChanFunc      func(md metadata.MD) (ch <-chan *DownlinkMessage, cancel func(), err error)
	// contains filtered or unexported fields
}

RouterStreamServer handles gRPC streams as channels

func NewRouterStreamServer

func NewRouterStreamServer() *RouterStreamServer

NewRouterStreamServer returns a new RouterStreamServer

func (*RouterStreamServer) GatewayStatus

func (s *RouterStreamServer) GatewayStatus(stream Router_GatewayStatusServer) error

GatewayStatus handles gateway status streams

func (*RouterStreamServer) SetLogger

func (s *RouterStreamServer) SetLogger(logger log.Interface)

SetLogger sets the logger

func (*RouterStreamServer) Subscribe

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

Subscribe handles downlink streams

func (*RouterStreamServer) Uplink

func (s *RouterStreamServer) Uplink(stream Router_UplinkServer) (err error)

Uplink handles uplink streams