packages

Documentation

Index

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

Functions

func RegisterPackage

func RegisterPackage(p ttnpb.ApplicationPackage, create 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.ApplicationPackageDefaultAssociation, *ttnpb.ApplicationPackageAssociation, *ttnpb.ApplicationUp) error
}

ApplicationPackageHandler handles upstream traffic from the Application Server.

type AssociationRegistry

type AssociationRegistry interface {
	// GetAssociation returns the association by its identifiers.
	GetAssociation(ctx context.Context, ids ttnpb.ApplicationPackageAssociationIdentifiers, paths []string) (*ttnpb.ApplicationPackageAssociation, error)
	// ListAssociations returns all of the associations of the end device.
	ListAssociations(ctx context.Context, ids ttnpb.EndDeviceIdentifiers, paths []string) ([]*ttnpb.ApplicationPackageAssociation, error)
	// SetAssociation creates, updates or deletes the association by its identifiers.
	SetAssociation(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
}

AssociationRegistry is a registry for application package end device associations.

type CreateApplicationPackage

type CreateApplicationPackage func(io.Server, Registry) ApplicationPackageHandler

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

type DefaultAssociationRegistry

type DefaultAssociationRegistry interface {
	// GetDefaultAssociation returns the default association by its identifiers.
	GetDefaultAssociation(ctx context.Context, ids ttnpb.ApplicationPackageDefaultAssociationIdentifiers, paths []string) (*ttnpb.ApplicationPackageDefaultAssociation, error)
	// ListDefaultAssociation returns all of the default associations of the application.
	ListDefaultAssociations(ctx context.Context, ids ttnpb.ApplicationIdentifiers, paths []string) ([]*ttnpb.ApplicationPackageDefaultAssociation, error)
	// SetDefaultAssociation creates, updates or deletes the default association by its identifiers.
	SetDefaultAssociation(ctx context.Context, ids ttnpb.ApplicationPackageDefaultAssociationIdentifiers, gets []string, f func(*ttnpb.ApplicationPackageDefaultAssociation) (*ttnpb.ApplicationPackageDefaultAssociation, []string, error)) (*ttnpb.ApplicationPackageDefaultAssociation, error)
	// WithPagination adds the pagination information to the context.
	WithPagination(ctx context.Context, limit, page uint32, total *int64) context.Context
}

DefaultAssociationRegistry is a registry for application package default associations.

type Registry

type Registry interface {
	AssociationRegistry
	DefaultAssociationRegistry
}

Registry is a registry for application package 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.