[IMPROVED] Add extra option to OrderedConsumerConfig (#1737)

Signed-off-by: Michael Wain <michael@sanity.io>

jetstream/consumer_config.go

@@ -263,6 +263,11 @@ type (
 		// Maximum number of attempts for the consumer to be recreated in a
 		// single recreation cycle. Defaults to unlimited.
 		MaxResetAttempts int
+
+		// Metadata is a set of application-defined key-value pairs for
+		// associating metadata on the consumer. This feature requires
+		// nats-server v2.10.0 or later.
+		Metadata map[string]string `json:"metadata,omitempty"`
 	}
 
 	// DeliverPolicy determines from which point to start delivering messages.

jetstream/ordered.go

@@ -611,6 +611,7 @@ func (c *orderedConsumer) getConsumerConfig() *ConsumerConfig {
 		Replicas:          1,
 		HeadersOnly:       c.cfg.HeadersOnly,
 		MemoryStorage:     true,
+		Metadata:          c.cfg.Metadata,
 	}
 	if len(c.cfg.FilterSubjects) == 1 {
 		cfg.FilterSubject = c.cfg.FilterSubjects[0]

jetstream/test/ordered_test.go

@@ -2006,6 +2006,7 @@ func TestOrderedConsumerConfig(t *testing.T) {
 				ReplayPolicy:      jetstream.ReplayOriginalPolicy,
 				InactiveThreshold: 10 * time.Second,
 				HeadersOnly:       true,
+				Metadata:          map[string]string{"foo": "a"},
 			},
 			expected: jetstream.ConsumerConfig{
 				FilterSubjects:    []string{"foo.a", "foo.b"},
@@ -2018,6 +2019,7 @@ func TestOrderedConsumerConfig(t *testing.T) {
 				Replicas:          1,
 				MemoryStorage:     true,
 				HeadersOnly:       true,
+				Metadata:          map[string]string{"foo": "a"},
 			},
 		},
 		{
@@ -2029,6 +2031,7 @@ func TestOrderedConsumerConfig(t *testing.T) {
 				ReplayPolicy:      jetstream.ReplayOriginalPolicy,
 				InactiveThreshold: 10 * time.Second,
 				HeadersOnly:       true,
+				Metadata:          map[string]string{"foo": "a"},
 			},
 			expected: jetstream.ConsumerConfig{
 				FilterSubjects:    []string{"foo.a", "foo.b"},
@@ -2041,6 +2044,7 @@ func TestOrderedConsumerConfig(t *testing.T) {
 				Replicas:          1,
 				MemoryStorage:     true,
 				HeadersOnly:       true,
+				Metadata:          map[string]string{"foo": "a"},
 			},
 		},
 		{