object store with domains

object_old.go

package main

import (
	"os"

	"github.com/nats-io/nats.go"
)

func main() {
	nc, err := nats.Connect("nats://demo.nats.io")
	if err != nil {
		panic(err)
	}

	js, err := nc.JetStream(nats.Domain("DEVCO"))
	if err != nil {
		panic(err)
	}

	bucket, err := js.ObjectStore("X")
	if err != nil {
		panic(err)
	}

	f, err := os.Open("x")
	if err != nil {
		panic(err)
	}

	_, err = bucket.Put(&nats.ObjectMeta{Name: "X"}, f)
	if err != nil {
		panic(err)
	}

	return
}

objtest_new.go

package main

import (
	"context"
	"os"

	"github.com/nats-io/nats.go"
	"github.com/nats-io/nats.go/jetstream"
)

func main() {
	nc, err := nats.Connect("nats://demo.nats.io")
	if err != nil {
		panic(err)
	}

	js, err := jetstream.NewWithDomain(nc, "DEVCO")
	if err != nil {
		panic(err)
	}

	bucket, err := js.ObjectStore(context.TODO(), "X")
	if err != nil {
		panic(err)
	}

	f, err := os.Open("x")
	if err != nil {
		panic(err)
	}

	_, err = bucket.Put(context.TODO(), jetstream.ObjectMeta{Name: "X"}, f)
	if err != nil {
		panic(err)
	}

	return
}