mock

Documentation

Index

• type GatewayServer
  • func NewGatewayServer(c *component.Component) (*GatewayServer, error)
  • func (gs *GatewayServer) Publish(ctx context.Context, up *ttnpb.GatewayUplinkMessage) error
  • func (gs *GatewayServer) RegisterHandlers(s *runtime.ServeMux, conn *grpc.ClientConn)
  • func (gs *GatewayServer) RegisterServices(s *grpc.Server)
  • func (gs *GatewayServer) Roles() []ttnpb.ClusterRole
  • func (gs *GatewayServer) ScheduleDownlink(ctx context.Context, req *ttnpb.DownlinkMessage) (*ttnpb.ScheduleDownlinkResponse, error)
• type NetworkServer
  • func NewNetworkServer(c *component.Component) (*NetworkServer, error)
  • func (ns *NetworkServer) HandleUplink(ctx context.Context, req *ttnpb.UplinkMessage) (*pbtypes.Empty, error)
  • func (ns *NetworkServer) Publish(ctx context.Context, down *ttnpb.DownlinkMessage) error
  • func (ns *NetworkServer) RegisterHandlers(s *runtime.ServeMux, conn *grpc.ClientConn)
  • func (ns *NetworkServer) RegisterServices(s *grpc.Server)
  • func (ns *NetworkServer) Roles() []ttnpb.ClusterRole
• type PBDataPlane
  • func NewPBDataPlane(cert tls.Certificate, clientCAs *x509.CertPool) *PBDataPlane

Types

type GatewayServer

type GatewayServer struct {
	*component.Component
	Downlink chan *ttnpb.DownlinkMessage
}

GatewayServer is a mock Gateway Server.

func NewGatewayServer

func NewGatewayServer(c *component.Component) (*GatewayServer, error)

NewGatewayServer returns a new GatewayServer.

func (*GatewayServer) Publish

func (gs *GatewayServer) Publish(ctx context.Context, up *ttnpb.GatewayUplinkMessage) error

Publish publishes the given message to Packet Broker Agent in the cluster.

func (*GatewayServer) RegisterHandlers

func (gs *GatewayServer) RegisterHandlers(s *runtime.ServeMux, conn *grpc.ClientConn)

RegisterHandlers implements rpcserver.Registerer.

func (*GatewayServer) RegisterServices

func (gs *GatewayServer) RegisterServices(s *grpc.Server)

RegisterServices implements rpcserver.Registerer.

func (*GatewayServer) Roles

func (gs *GatewayServer) Roles() []ttnpb.ClusterRole

Roles implements rpcserver.Registerer.

func (*GatewayServer) ScheduleDownlink

func (gs *GatewayServer) ScheduleDownlink(ctx context.Context, req *ttnpb.DownlinkMessage) (*ttnpb.ScheduleDownlinkResponse, error)

ScheduleDownlink implements ttnpb.NsGsServer.

type NetworkServer

type NetworkServer struct {
	*component.Component
	Uplink chan *ttnpb.UplinkMessage
}

NetworkServer is a mock Network Server.

func NewNetworkServer

func NewNetworkServer(c *component.Component) (*NetworkServer, error)

NewNetworkServer returns a new NetworkServer.

func (*NetworkServer) HandleUplink

func (ns *NetworkServer) HandleUplink(ctx context.Context, req *ttnpb.UplinkMessage) (*pbtypes.Empty, error)

HandleUplink implements ttnpb.GsNsServer.

func (*NetworkServer) Publish

func (ns *NetworkServer) Publish(ctx context.Context, down *ttnpb.DownlinkMessage) error

Publish publishes the given message to Packet Broker Agent in the cluster.

func (*NetworkServer) RegisterHandlers

func (ns *NetworkServer) RegisterHandlers(s *runtime.ServeMux, conn *grpc.ClientConn)

RegisterHandlers implements rpcserver.Registerer.

func (*NetworkServer) RegisterServices

func (ns *NetworkServer) RegisterServices(s *grpc.Server)

RegisterServices implements rpcserver.Registerer.

func (*NetworkServer) Roles

func (ns *NetworkServer) Roles() []ttnpb.ClusterRole

Roles implements rpcserver.Registerer.

type PBDataPlane

type PBDataPlane struct {
	*grpc.Server
	ForwarderUp     chan *packetbroker.RoutedUplinkMessage
	ForwarderDown   chan *packetbroker.RoutedDownlinkMessage
	HomeNetworkDown chan *packetbroker.RoutedDownlinkMessage
	HomeNetworkUp   chan *packetbroker.RoutedUplinkMessage
}

PBDataPlane is a mock Packet Broker Data Plane.

func NewPBDataPlane

func NewPBDataPlane(cert tls.Certificate, clientCAs *x509.CertPool) *PBDataPlane

NewPBDataPlane instantiates a new mock Packet Broker Data Plane.