ns

Documentation

Overview

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

Index

• type Cluster
• type ContextDecoupler
• type Handler
  • func NewHandler(ctx context.Context, cluster Cluster, contextDecoupler ContextDecoupler, ...) *Handler
  • func (h *Handler) ConnectGateway(ctx context.Context, ids *ttnpb.GatewayIdentifiers, conn *io.Connection) error
  • func (h *Handler) DevAddrPrefixes() []types.DevAddrPrefix
  • func (h *Handler) HandleStatus(context.Context, *ttnpb.GatewayIdentifiers, *ttnpb.GatewayStatus) error
  • func (h *Handler) HandleTxAck(ctx context.Context, ids *ttnpb.GatewayIdentifiers, ...) 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 cluster.EntityIdentifiers) (*grpc.ClientConn, error)
	WithClusterAuth() grpc.CallOption
	ClaimIDs(ctx context.Context, ids cluster.EntityIdentifiers) error
	UnclaimIDs(ctx context.Context, ids cluster.EntityIdentifiers) error
}

Cluster provides cluster operations.

type ContextDecoupler

type ContextDecoupler interface {
	FromRequestContext(ctx context.Context) context.Context
}

ContextDecoupler decouples the request context from its values.

type Handler

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

Handler is the upstream handler.

func NewHandler

func NewHandler(ctx context.Context, cluster Cluster, contextDecoupler ContextDecoupler, 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) DevAddrPrefixes

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

DevAddrPrefixes 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.