Method Subscribe

pkg/events/cloud/cloud.go:132–145

Subscribe to events from Go Cloud.

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

// Subscribe to events from Go Cloud.
func (ps *PubSub) Subscribe(
	ctx context.Context, names []string, ids []*ttnpb.EntityIdentifiers, hdl events.Handler,
) error {
	ps.subOnce.Do(func() {
		ps.taskStarter.StartTask(&task.Config{
			Context: ps.ctx,
			ID:      "events_cloud_subscribe",
			Func:    ps.subscribeTask,
			Restart: task.RestartOnFailure,
			Backoff: task.DefaultBackoffConfig,
		})
	})
	return ps.PubSub.Subscribe(ctx, names, ids, hdl)
}

func (ps *PubSub) getMetadata(evt events.Event) map[string]string {
	ids := make(map[string][]string, 10)