ns

Documentation

Overview

Package ns abstracts the V3 Network Server to the upstream.Handler interface.

Index

• type Cluster
• type Handler
  • func NewHandler(ctx context.Context, cluster Cluster, devAddrPrefixes []types.DevAddrPrefix) *Handler
  • func (h *Handler) ConnectGateway(ctx context.Context, ids ttnpb.GatewayIdentifiers, conn *io.Connection) error
  • func (h *Handler) GetDevAddrPrefixes() []types.DevAddrPrefix
  • func (h *Handler) HandleStatus(context.Context, ttnpb.GatewayIdentifiers, *ttnpb.GatewayStatus) error
  • func (h *Handler) HandleTxAck(ctx context.Context, ids ttnpb.GatewayIdentifiers, msg *ttnpb.TxAcknowledgment) error
  • func (h *Handler) HandleUplink(ctx context.Context, _ ttnpb.GatewayIdentifiers, ...) error
  • func (h *Handler) Setup(context.Context) error

Types

type Cluster

type Cluster interface {
	GetPeerConn(ctx context.Context, role ttnpb.ClusterRole, ids ttnpb.Identifiers) (*grpc.ClientConn, error)
	WithClusterAuth() grpc.CallOption
	ClaimIDs(ctx context.Context, ids ttnpb.Identifiers) error
	UnclaimIDs(ctx context.Context, ids ttnpb.Identifiers) error
	FromRequestContext(ctx context.Context) context.Context
}

Cluster provides cluster operations.

type Handler

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

Handler is the upstream handler.

func NewHandler

func NewHandler(ctx context.Context, cluster Cluster, devAddrPrefixes []types.DevAddrPrefix) *Handler

NewHandler returns a new upstream handler.

func (*Handler) ConnectGateway

func (h *Handler) ConnectGateway(ctx context.Context, ids ttnpb.GatewayIdentifiers, conn *io.Connection) error

ConnectGateway implements upstream.Handler.

func (*Handler) GetDevAddrPrefixes

func (h *Handler) GetDevAddrPrefixes() []types.DevAddrPrefix

GetDevAddrPrefixes implements upstream.Handler.

func (*Handler) HandleStatus

func (h *Handler) HandleStatus(context.Context, ttnpb.GatewayIdentifiers, *ttnpb.GatewayStatus) error

HandleStatus implements upstream.Handler.

func (*Handler) HandleTxAck

func (h *Handler) HandleTxAck(ctx context.Context, ids ttnpb.GatewayIdentifiers, msg *ttnpb.TxAcknowledgment) error

HandleTxAck implements upstream.Handler.

func (*Handler) HandleUplink

func (h *Handler) HandleUplink(ctx context.Context, _ ttnpb.GatewayIdentifiers, ids ttnpb.EndDeviceIdentifiers, msg *ttnpb.GatewayUplinkMessage) error

HandleUplink implements upstream.Handler.

func (*Handler) Setup

func (h *Handler) Setup(context.Context) error

Setup implements upstream.Handler.