Versions in this module Expand all Collapse all v3 v3.7.3 Apr 29, 2020 Changes in this version + type ApplicationPackagesConfig struct + Registry packages.Registry + func (c ApplicationPackagesConfig) NewApplicationPackages(ctx context.Context, server io.Server) (packages.Server, error) + type ApplicationServer struct + func New(c *component.Component, conf *Config) (as *ApplicationServer, err error) + func (as *ApplicationServer) Context() context.Context + func (as *ApplicationServer) DeleteLink(ctx context.Context, ids *ttnpb.ApplicationIdentifiers) (*types.Empty, error) + func (as *ApplicationServer) DownlinkQueueList(ctx context.Context, ids ttnpb.EndDeviceIdentifiers) ([]*ttnpb.ApplicationDownlink, error) + func (as *ApplicationServer) DownlinkQueuePush(ctx context.Context, ids ttnpb.EndDeviceIdentifiers, ...) error + func (as *ApplicationServer) DownlinkQueueReplace(ctx context.Context, ids ttnpb.EndDeviceIdentifiers, ...) error + func (as *ApplicationServer) GetConfig(ctx context.Context) (*Config, error) + func (as *ApplicationServer) GetLink(ctx context.Context, req *ttnpb.GetApplicationLinkRequest) (*ttnpb.ApplicationLink, error) + func (as *ApplicationServer) GetLinkStats(ctx context.Context, ids *ttnpb.ApplicationIdentifiers) (*ttnpb.ApplicationLinkStats, error) + func (as *ApplicationServer) GetMQTTConfig(ctx context.Context) (*config.MQTT, error) + func (as *ApplicationServer) RegisterHandlers(s *runtime.ServeMux, conn *grpc.ClientConn) + func (as *ApplicationServer) RegisterServices(s *grpc.Server) + func (as *ApplicationServer) Roles() []ttnpb.ClusterRole + func (as *ApplicationServer) SendUp(ctx context.Context, up *ttnpb.ApplicationUp) error + func (as *ApplicationServer) SetLink(ctx context.Context, req *ttnpb.SetApplicationLinkRequest) (*ttnpb.ApplicationLink, error) + func (as *ApplicationServer) Subscribe(ctx context.Context, protocol string, ids ttnpb.ApplicationIdentifiers) (*io.Subscription, error) + type Config struct + ApplicationPackages ApplicationPackagesConfig + DeviceKEKLabel string + Devices DeviceRegistry + Interop InteropConfig + LinkMode string + Links LinkRegistry + MQTT config.MQTT + PubSub PubSubConfig + Webhooks WebhooksConfig + func (c Config) GetLinkMode() (LinkMode, error) + type DeviceRegistry interface + Get func(ctx context.Context, ids ttnpb.EndDeviceIdentifiers, paths []string) (*ttnpb.EndDevice, error) + Set func(ctx context.Context, ids ttnpb.EndDeviceIdentifiers, paths []string, ...) (*ttnpb.EndDevice, error) + type InteropClient interface + GetAppSKey func(ctx context.Context, asID string, req *ttnpb.SessionKeyRequest) (*ttnpb.AppSKeyResponse, error) + type InteropConfig struct + ID string + type LinkMode int + const LinkAll + const LinkExplicit + type LinkRegistry interface + Get func(ctx context.Context, ids ttnpb.ApplicationIdentifiers, paths []string) (*ttnpb.ApplicationLink, error) + Range func(ctx context.Context, paths []string, ...) error + Set func(ctx context.Context, ids ttnpb.ApplicationIdentifiers, paths []string, ...) (*ttnpb.ApplicationLink, error) + type PubSubConfig struct + Registry pubsub.Registry + func (c PubSubConfig) NewPubSub(comp *component.Component, server io.Server) (*pubsub.PubSub, error) + type WebhooksConfig struct + Downlinks web.DownlinksConfig + QueueSize int + Registry web.WebhookRegistry + Target string + Templates web.TemplatesConfig + Timeout time.Duration + Workers int + func (c WebhooksConfig) NewWebhooks(ctx context.Context, server io.Server) (web.Webhooks, error)
Go to main page