MCPcopy Create free account
hub / github.com/TheThingsNetwork/lorawan-stack / Subscribe

Method Subscribe

pkg/events/pubsub.go:41–41  ·  view source on GitHub ↗

Subscribe to events that match the names and identifiers. The subscription continues until the context is canceled. Events matching _any_ of the names or identifiers will get sent to the handler. The handler must be non-blocking.

(ctx context.Context, names []string, identifiers []*ttnpb.EntityIdentifiers, hdl Handler)

Source from the content-addressed store, hash-verified

39 // Events matching _any_ of the names or identifiers will get sent to the handler.
40 // The handler must be non-blocking.
41 Subscribe(ctx context.Context, names []string, identifiers []*ttnpb.EntityIdentifiers, hdl Handler) error
42}
43
44// Subscription is the interface for PubSub subscriptions.

Callers 15

subscribeUplinkStreamMethod · 0.65
TestFrontendFunction · 0.65
StreamEventsMethod · 0.65
SubscribeFunction · 0.65
SubscribeMethod · 0.65
SubscribeMethod · 0.65
SubscribeWithHistoryMethod · 0.65
SubscribeMethod · 0.65
TestMultiplexingFunction · 0.65
StreamMethod · 0.65
TestBackendFunction · 0.65

Implementers 15

mockServerpkg/rpcserver/rpcserver_test.go
mockSubscriptionspkg/console/internal/events/eventsmux/
mockSubscriberpkg/console/internal/events/subscripti
mockPubSubStorepkg/console/internal/events/subscripti
subscriptionspkg/console/internal/events/subscripti
routerForwarderServerpkg/packetbrokeragent/mock/pbdataplane
routerHomeNetworkServerpkg/packetbrokeragent/mock/pbdataplane
asImplementationpkg/component/grpc_test.go
connectionpkg/gatewayserver/io/mqtt/mqtt.go
clientpkg/gatewayconfigurationserver/managed
noopPubSubpkg/events/default.go
PubSubpkg/events/cloud/cloud.go

Calls

no outgoing calls

Tested by 4

TestFrontendFunction · 0.52
SubscribeMethod · 0.52
TestMultiplexingFunction · 0.52
TestBackendFunction · 0.52