cloud

package main

import (
	"context"

	"github.com/rvolosatovs/lorawan-stack/v3/pkg/events"
	"github.com/rvolosatovs/lorawan-stack/v3/pkg/events/cloud"

	_ "gocloud.dev/pubsub/mempubsub"
)

func main() {
	// Import the desired cloud pub-sub drivers (see godoc.org/gocloud.dev).
	// In this example we use "gocloud.dev/pubsub/mempubsub".

	// This sends all events received from a Go Cloud pub sub to the default pubsub.
	cloudPubSub, err := cloud.WrapPubSub(context.TODO(), events.DefaultPubSub(), "mem://events", "mem://events")
	if err != nil {
		// Handle error.
	}

	// Replace the default pubsub so that we will now publish to a Go Cloud pub sub.
	events.SetDefaultPubSub(cloudPubSub)
}

Output: