Rename SetMemoryStorage to ConsumerMemoryStorage

example_test.go

@@ -634,7 +634,7 @@ func ExampleSubOpt() {
 	// Force memory storage while subscribing.
 	js.Subscribe("foo", func(msg *nats.Msg) {
 		fmt.Printf("Received a message: %s\n", string(msg.Data))
-	}, nats.Durable("FOO"), nats.SetMemoryStorage())
+	}, nats.Durable("FOO"), nats.ConsumerMemoryStorage())
 }
 
 func ExampleMaxWait() {

js.go

@@ -2488,8 +2488,8 @@ func ConsumerReplicas(replicas int) SubOpt {
 	})
 }
 
-// SetMemoryStorage sets the memory storage to true for a consumer.
-func SetMemoryStorage() SubOpt {
+// ConsumerMemoryStorage sets the memory storage to true for a consumer.
+func ConsumerMemoryStorage() SubOpt {
 	return subOptFn(func(opts *subOpts) error {
 		opts.cfg.MemoryStorage = true
 		return nil

js_test.go

@@ -1097,7 +1097,7 @@ func TestJetStreamConvertDirectMsgResponseToMsg(t *testing.T) {
 	}
 }
 
-func TestJetStreamSetMemoryStorage(t *testing.T) {
+func TestJetStreamConsumerMemoryStorage(t *testing.T) {
 	opts := natsserver.DefaultTestOptions
 	opts.Port = -1
 	opts.JetStream = true
@@ -1112,7 +1112,7 @@ func TestJetStreamSetMemoryStorage(t *testing.T) {
 	}
 
 	// Pull ephemeral consumer with memory storage.
-	sub, err := js.PullSubscribe("foo", "", SetMemoryStorage())
+	sub, err := js.PullSubscribe("foo", "", ConsumerMemoryStorage())
 	if err != nil {
 		t.Fatalf("Error on subscribe: %v", err)
 	}
@@ -1127,7 +1127,7 @@ func TestJetStreamSetMemoryStorage(t *testing.T) {
 	}
 
 	// Create a sync subscription with an in-memory ephemeral consumer.
-	sub, err = js.SubscribeSync("foo", SetMemoryStorage())
+	sub, err = js.SubscribeSync("foo", ConsumerMemoryStorage())
 	if err != nil {
 		t.Fatalf("Error on subscribe: %v", err)
 	}
@@ -1143,7 +1143,7 @@ func TestJetStreamSetMemoryStorage(t *testing.T) {
 
 	// Async subscription with an in-memory ephemeral consumer.
 	cb := func(msg *Msg) {}
-	sub, err = js.Subscribe("foo", cb, SetMemoryStorage())
+	sub, err = js.Subscribe("foo", cb, ConsumerMemoryStorage())
 	if err != nil {
 		t.Fatalf("Error on subscribe: %v", err)
 	}