packages

Documentation

Index

• func RegisterPackage(p ttnpb.ApplicationPackage, new CreateApplicationPackage) error
• type ApplicationPackageHandler
• type CreateApplicationPackage
• type Registry
• type Server
  • func New(ctx context.Context, io io.Server, registry Registry) (Server, error)

Functions

func RegisterPackage

func RegisterPackage(p ttnpb.ApplicationPackage, new CreateApplicationPackage) error

RegisterPackage registers the given package on the application packages frontend.

Types

type ApplicationPackageHandler

type ApplicationPackageHandler interface {
	RegisterServices(s *grpc.Server)
	RegisterHandlers(s *runtime.ServeMux, conn *grpc.ClientConn)
	HandleUp(context.Context, *ttnpb.ApplicationPackageAssociation, *ttnpb.ApplicationUp) error
}

ApplicationPackageHandler handles upstream traffic from the Application Server.

type CreateApplicationPackage

type CreateApplicationPackage func(io.Server, Registry) ApplicationPackageHandler

CreateApplicationPackage is a function that creates a traffic handler for a given package.

type Registry

type Registry interface {
	// Get returns the association by its identifiers.
	Get(ctx context.Context, ids ttnpb.ApplicationPackageAssociationIdentifiers, paths []string) (*ttnpb.ApplicationPackageAssociation, error)
	// List returns all of the associations of the end device.
	List(ctx context.Context, ids ttnpb.EndDeviceIdentifiers, paths []string) ([]*ttnpb.ApplicationPackageAssociation, error)
	// Set creates, updates or deletes the association by its identifiers.
	Set(ctx context.Context, ids ttnpb.ApplicationPackageAssociationIdentifiers, gets []string, f func(*ttnpb.ApplicationPackageAssociation) (*ttnpb.ApplicationPackageAssociation, []string, error)) (*ttnpb.ApplicationPackageAssociation, error)
	// WithPagination adds the pagination information to the context.
	WithPagination(ctx context.Context, limit, page uint32, total *int64) context.Context
}

Registry is a registry for application packages data and associations.

type Server

type Server interface {
	rpcserver.Registerer
	NewSubscription() *io.Subscription
}

Server is an application packages frontend.

func New

func New(ctx context.Context, io io.Server, registry Registry) (Server, error)

New returns an application packages server wrapping the given registries.