From 72f7fec2a4096a6c2b3359df6622bda2d419665b Mon Sep 17 00:00:00 2001 From: Jarema Date: Thu, 17 Jun 2021 09:00:23 +0200 Subject: [PATCH] Add utility function for setting domain --- js.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/js.go b/js.go index f4b532b0b..a3fa70f22 100644 --- a/js.go +++ b/js.go @@ -35,6 +35,9 @@ const ( // defaultAPIPrefix is the default prefix for the JetStream API. defaultAPIPrefix = "$JS.API." + // jsDomainT is used to create JetStream API prefix by specifying only Domain + jsDomainT = "$JS.%s.API." + // apiAccountInfo is for obtaining general information about JetStream. apiAccountInfo = "INFO" @@ -200,6 +203,11 @@ func (opt jsOptFn) configureJSContext(opts *jsOpts) error { return opt(opts) } +// Domain changes the domain part of JetSteam API prefix. +func Domain(domain string) JSOpt { + return APIPrefix(fmt.Sprintf(jsDomainT, domain)) +} + // APIPrefix changes the default prefix used for the JetStream API. func APIPrefix(pre string) JSOpt { return jsOptFn(func(js *jsOpts) error {