WithIdempotencyKey option

options.go

@@ -16,6 +16,14 @@ func WithHistory(size int, ttl time.Duration, metaTTL ...time.Duration) PublishO
 	}
 }
 
+// WithIdempotencyKey tells Broker the idempotency key for the publication.
+// See PublishOptions.IdempotencyKey.
+func WithIdempotencyKey(key string) PublishOption {
+	return func(opts *PublishOptions) {
+		opts.IdempotencyKey = key
+	}
+}
+
 // WithClientInfo adds ClientInfo to Publication.
 func WithClientInfo(info *ClientInfo) PublishOption {
 	return func(opts *PublishOptions) {

options_test.go

@@ -15,6 +15,13 @@ func TestWithHistory(t *testing.T) {
 	require.Equal(t, time.Second, opts.HistoryTTL)
 }
 
+func TestWithIdempotencyKey(t *testing.T) {
+	opt := WithIdempotencyKey("ik")
+	opts := &PublishOptions{}
+	opt(opts)
+	require.Equal(t, "ik", opts.IdempotencyKey)
+}
+
 func TestWithMeta(t *testing.T) {
 	opt := WithTags(map[string]string{"test": "value"})
 	opts := &PublishOptions{}