Jetstream Provider

# Pulumi.yaml provider configuration file
name: configuration-example
runtime: nodejs
config:
    jetstream:credentials:
        value: /home/you/ngs_stream_admin.creds
    jetstream:servers:
        value: connect.ngs.global:4222

import * as pulumi from "@pulumi/pulumi";
import * as jetstream from "@pulumi/jetstream";

const ORDERS = new jetstream.Stream("ORDERS", {
    name: "ORDERS",
    subjects: ["ORDERS.*"],
    storage: "file",
    maxAge: 60 * 60 * 24 * 365,
});
const ORDERS_NEW = new jetstream.Consumer("ORDERS_NEW", {
    streamId: ORDERS.streamId,
    durableName: "NEW",
    deliverAll: true,
    filterSubject: "ORDERS.received",
    sampleFreq: 100,
});

# Pulumi.yaml provider configuration file
name: configuration-example
runtime: python
config:
    jetstream:credentials:
        value: /home/you/ngs_stream_admin.creds
    jetstream:servers:
        value: connect.ngs.global:4222

import pulumi
import pulumi_jetstream as jetstream

orders = jetstream.Stream("ORDERS",
    name="ORDERS",
    subjects=["ORDERS.*"],
    storage="file",
    max_age=60 * 60 * 24 * 365)
order_s__new = jetstream.Consumer("ORDERS_NEW",
    stream_id=orders.stream_id,
    durable_name="NEW",
    deliver_all=True,
    filter_subject="ORDERS.received",
    sample_freq=100)

# Pulumi.yaml provider configuration file
name: configuration-example
runtime: dotnet
config:
    jetstream:credentials:
        value: /home/you/ngs_stream_admin.creds
    jetstream:servers:
        value: connect.ngs.global:4222

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Jetstream = Pulumi.Jetstream;

return await Deployment.RunAsync(() =>
{
    var ORDERS = new Jetstream.Stream("ORDERS", new()
    {
        Name = "ORDERS",
        Subjects = new[]
        {
            "ORDERS.*",
        },
        Storage = "file",
        MaxAge = 60 * 60 * 24 * 365,
    });

    var ORDERS_NEW = new Jetstream.Consumer("ORDERS_NEW", new()
    {
        StreamId = ORDERS.StreamId,
        DurableName = "NEW",
        DeliverAll = true,
        FilterSubject = "ORDERS.received",
        SampleFreq = 100,
    });

});

# Pulumi.yaml provider configuration file
name: configuration-example
runtime: go
config:
    jetstream:credentials:
        value: /home/you/ngs_stream_admin.creds
    jetstream:servers:
        value: connect.ngs.global:4222

package main

import (
	"github.com/pulumi/pulumi-pulumi-provider/sdks/go/jetstream/jetstream"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		ORDERS, err := jetstream.NewStream(ctx, "ORDERS", &jetstream.StreamArgs{
			Name: pulumi.String("ORDERS"),
			Subjects: pulumi.StringArray{
				pulumi.String("ORDERS.*"),
			},
			Storage: pulumi.String("file"),
			MaxAge:  60 * 60 * 24 * 365,
		})
		if err != nil {
			return err
		}
		_, err = jetstream.NewConsumer(ctx, "ORDERS_NEW", &jetstream.ConsumerArgs{
			StreamId:      ORDERS.StreamId,
			DurableName:   pulumi.String("NEW"),
			DeliverAll:    pulumi.Bool(true),
			FilterSubject: pulumi.String("ORDERS.received"),
			SampleFreq:    pulumi.Float64(100),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

# Pulumi.yaml provider configuration file
name: configuration-example
runtime: yaml
config:
    jetstream:credentials:
        value: /home/you/ngs_stream_admin.creds
    jetstream:servers:
        value: connect.ngs.global:4222

Example currently unavailable in this language

# Pulumi.yaml provider configuration file
name: configuration-example
runtime: java
config:
    jetstream:credentials:
        value: /home/you/ngs_stream_admin.creds
    jetstream:servers:
        value: connect.ngs.global:4222

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.jetstream.Stream;
import com.pulumi.jetstream.StreamArgs;
import com.pulumi.jetstream.Consumer;
import com.pulumi.jetstream.ConsumerArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        var oRDERS = new Stream("ORDERS", StreamArgs.builder()
            .name("ORDERS")
            .subjects("ORDERS.*")
            .storage("file")
            .maxAge(60 * 60 * 24 * 365)
            .build());

        var oRDERS_NEW = new Consumer("ORDERS_NEW", ConsumerArgs.builder()
            .streamId(ORDERS.streamId())
            .durableName("NEW")
            .deliverAll(true)
            .filterSubject("ORDERS.received")
            .sampleFreq(100)
            .build());

    }
}