pubsub/natspubsub: added examples and gathered examples to internal/w…

…ebsite/data/examples.json

pubsub/natspubsub/example_test.go

@@ -19,6 +19,7 @@ import (
 	"log"
 
 	"github.com/nats-io/nats.go"
+
 	"gocloud.dev/pubsub"
 	"gocloud.dev/pubsub/natspubsub"
 )
@@ -131,3 +132,79 @@ func Example_openQueueSubscriptionFromURL() {
 	}
 	defer subscription.Shutdown(ctx)
 }
+
+func ExampleOpenSubscriptionV2() {
+	// PRAGMA: This example is used on gocloud.dev; PRAGMA comments adjust how it is shown and can be ignored.
+	// PRAGMA: On gocloud.dev, add a blank import: _ "gocloud.dev/pubsub/natspubsub"
+	// PRAGMA: On gocloud.dev, hide lines until the next blank line.
+	ctx := context.Background()
+	natsConn, err := nats.Connect("nats://nats.example.com")
+	if err != nil {
+		log.Fatal(err)
+	}
+	defer natsConn.Close()
+
+	subscription, err := natspubsub.OpenSubscriptionV2(
+		natsConn,
+		"example.mysubject",
+		nil)
+	if err != nil {
+		log.Fatal(err)
+	}
+	defer subscription.Shutdown(ctx)
+}
+
+func ExampleOpenTopicV2() {
+	// PRAGMA: This example is used on gocloud.dev; PRAGMA comments adjust how it is shown and can be ignored.
+	// PRAGMA: On gocloud.dev, add a blank import: _ "gocloud.dev/pubsub/natspubsub"
+	// PRAGMA: On gocloud.dev, hide lines until the next blank line.
+	ctx := context.Background()
+
+	natsConn, err := nats.Connect("nats://nats.example.com")
+	if err != nil {
+		log.Fatal(err)
+	}
+	defer natsConn.Close()
+
+	topic, err := natspubsub.OpenTopicV2(natsConn, "example.mysubject", nil)
+	if err != nil {
+		log.Fatal(err)
+	}
+	defer topic.Shutdown(ctx)
+}
+
+func Example_openTopicV2FromUrl() {
+	// PRAGMA: This example is used on gocloud.dev; PRAGMA comments adjust how it is shown and can be ignored.
+	// PRAGMA: On gocloud.dev, add a blank import: _ "gocloud.dev/pubsub/natspubsub"
+	// PRAGMA: On gocloud.dev, hide lines until the next blank line.
+	ctx := context.Background()
+
+	// pubsub.OpenTopic creates a *pubsub.Topic from a URL.
+	// This URL will Dial the NATS server at the URL in the environment variable
+	// NATS_SERVER_URL and send messages with subject "example.mysubject".
+	// This URL will be parsed and the natsv2 attribute will be used to
+	// use NATS v2.2.0+ native message headers as the message metadata.
+	topic, err := pubsub.OpenTopic(ctx, "nats://example.mysubject?natsv2")
+	if err != nil {
+		log.Fatal(err)
+	}
+	defer topic.Shutdown(ctx)
+}
+
+func Example_openSubscriptionV2FromURL() {
+	// PRAGMA: This example is used on gocloud.dev; PRAGMA comments adjust how it is shown and can be ignored.
+	// PRAGMA: On gocloud.dev, add a blank import: _ "gocloud.dev/pubsub/natspubsub"
+	// PRAGMA: On gocloud.dev, hide lines until the next blank line.
+	ctx := context.Background()
+
+	// pubsub.OpenSubscription creates a *pubsub.Subscription from a URL.
+	// This URL will Dial the NATS server at the URL in the environment variable
+	// NATS_SERVER_URL and receive messages with subject "example.mysubject".
+	// This URL will be parsed and the natsv2 attribute will be used to
+	// use NATS v2.2.0+ native message headers as the message metadata.
+	subscription, err := pubsub.OpenSubscription(ctx, "nats://example.mysubject?natsv2")
+	if err != nil {
+		log.Fatal(err)
+	}
+	defer subscription.Shutdown(ctx)
+}