12730529914

Committed 10 Jan 2025 10:21PM UTC coverage: 85.521% (-0.08%) from 85.604%

Build # 12730529914

Build Type

push

github

Committed by

web-flow

Commit Message

Test: expected a fully formed cluster error (#6364)

Cluster tests would sometimes fail with the following error message:
```
jetstream_helpers_test.go:774: Expected a fully formed cluster, only 0 of 3 peers seen
```

This was due to a logic error in the tests, where it was assumed that
once a meta leader is chosen it will remain the same. That's not always
true as the meta leader can still shift around. So, keep fetching the
latest leader and check the peers on that.

Previously it would fail by selecting a meta leader, the meta leader
would change, and the follower would then be used to request peers on.
But because of the following lines in `JetStreamClusterPeers()`:
```go
	cc := js.cluster
	if !cc.isLeader() || cc.meta == nil {
		return nil
	}
```
You'd get no peers at all, leading into that error message.

Signed-off-by: Maurice van Veen <github@mauricevanveen.com>

Coverage Stats

68601 of 80215 relevant lines covered (85.52%)

946577.03 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

52.23

/server/jetstream_errors_generated.go

// Generated code, do not edit. See errors.json and run go generate to update

package server

import "strings"

const (
        // JSAccountResourcesExceededErr resource limits exceeded for account
        JSAccountResourcesExceededErr ErrorIdentifier = 10002

        // JSBadRequestErr bad request
        JSBadRequestErr ErrorIdentifier = 10003

        // JSClusterIncompleteErr incomplete results
        JSClusterIncompleteErr ErrorIdentifier = 10004

        // JSClusterNoPeersErrF Error causing no peers to be available ({err})
        JSClusterNoPeersErrF ErrorIdentifier = 10005

        // JSClusterNotActiveErr JetStream not in clustered mode
        JSClusterNotActiveErr ErrorIdentifier = 10006

        // JSClusterNotAssignedErr JetStream cluster not assigned to this server
        JSClusterNotAssignedErr ErrorIdentifier = 10007

        // JSClusterNotAvailErr JetStream system temporarily unavailable
        JSClusterNotAvailErr ErrorIdentifier = 10008

        // JSClusterNotLeaderErr JetStream cluster can not handle request
        JSClusterNotLeaderErr ErrorIdentifier = 10009

        // JSClusterPeerNotMemberErr peer not a member
        JSClusterPeerNotMemberErr ErrorIdentifier = 10040

        // JSClusterRequiredErr JetStream clustering support required
        JSClusterRequiredErr ErrorIdentifier = 10010

        // JSClusterServerNotMemberErr server is not a member of the cluster
        JSClusterServerNotMemberErr ErrorIdentifier = 10044

        // JSClusterTagsErr tags placement not supported for operation
        JSClusterTagsErr ErrorIdentifier = 10011

        // JSClusterUnSupportFeatureErr not currently supported in clustered mode
        JSClusterUnSupportFeatureErr ErrorIdentifier = 10036

        // JSConsumerAlreadyExists action CREATE is used for a existing consumer with a different config (consumer already exists)
        JSConsumerAlreadyExists ErrorIdentifier = 10148

        // JSConsumerBadDurableNameErr durable name can not contain '.', '*', '>'
        JSConsumerBadDurableNameErr ErrorIdentifier = 10103

        // JSConsumerConfigRequiredErr consumer config required
        JSConsumerConfigRequiredErr ErrorIdentifier = 10078

        // JSConsumerCreateDurableAndNameMismatch Consumer Durable and Name have to be equal if both are provided
        JSConsumerCreateDurableAndNameMismatch ErrorIdentifier = 10132

        // JSConsumerCreateErrF General consumer creation failure string ({err})
        JSConsumerCreateErrF ErrorIdentifier = 10012

        // JSConsumerCreateFilterSubjectMismatchErr Consumer create request did not match filtered subject from create subject
        JSConsumerCreateFilterSubjectMismatchErr ErrorIdentifier = 10131

        // JSConsumerDeliverCycleErr consumer deliver subject forms a cycle
        JSConsumerDeliverCycleErr ErrorIdentifier = 10081

        // JSConsumerDeliverToWildcardsErr consumer deliver subject has wildcards
        JSConsumerDeliverToWildcardsErr ErrorIdentifier = 10079

        // JSConsumerDescriptionTooLongErrF consumer description is too long, maximum allowed is {max}
        JSConsumerDescriptionTooLongErrF ErrorIdentifier = 10107

        // JSConsumerDirectRequiresEphemeralErr consumer direct requires an ephemeral consumer
        JSConsumerDirectRequiresEphemeralErr ErrorIdentifier = 10091

        // JSConsumerDirectRequiresPushErr consumer direct requires a push based consumer
        JSConsumerDirectRequiresPushErr ErrorIdentifier = 10090

        // JSConsumerDoesNotExist action UPDATE is used for a nonexisting consumer (consumer does not exist)
        JSConsumerDoesNotExist ErrorIdentifier = 10149

        // JSConsumerDuplicateFilterSubjects consumer cannot have both FilterSubject and FilterSubjects specified
        JSConsumerDuplicateFilterSubjects ErrorIdentifier = 10136

        // JSConsumerDurableNameNotInSubjectErr consumer expected to be durable but no durable name set in subject
        JSConsumerDurableNameNotInSubjectErr ErrorIdentifier = 10016

        // JSConsumerDurableNameNotMatchSubjectErr consumer name in subject does not match durable name in request
        JSConsumerDurableNameNotMatchSubjectErr ErrorIdentifier = 10017

        // JSConsumerDurableNameNotSetErr consumer expected to be durable but a durable name was not set
        JSConsumerDurableNameNotSetErr ErrorIdentifier = 10018

        // JSConsumerEmptyFilter consumer filter in FilterSubjects cannot be empty
        JSConsumerEmptyFilter ErrorIdentifier = 10139

        // JSConsumerEmptyGroupName Group name cannot be an empty string
        JSConsumerEmptyGroupName ErrorIdentifier = 10161

        // JSConsumerEphemeralWithDurableInSubjectErr consumer expected to be ephemeral but detected a durable name set in subject
        JSConsumerEphemeralWithDurableInSubjectErr ErrorIdentifier = 10019

        // JSConsumerEphemeralWithDurableNameErr consumer expected to be ephemeral but a durable name was set in request
        JSConsumerEphemeralWithDurableNameErr ErrorIdentifier = 10020

        // JSConsumerExistingActiveErr consumer already exists and is still active
        JSConsumerExistingActiveErr ErrorIdentifier = 10105

        // JSConsumerFCRequiresPushErr consumer flow control requires a push based consumer
        JSConsumerFCRequiresPushErr ErrorIdentifier = 10089

        // JSConsumerFilterNotSubsetErr consumer filter subject is not a valid subset of the interest subjects
        JSConsumerFilterNotSubsetErr ErrorIdentifier = 10093

        // JSConsumerHBRequiresPushErr consumer idle heartbeat requires a push based consumer
        JSConsumerHBRequiresPushErr ErrorIdentifier = 10088

        // JSConsumerInactiveThresholdExcess consumer inactive threshold exceeds system limit of {limit}
        JSConsumerInactiveThresholdExcess ErrorIdentifier = 10153

        // JSConsumerInvalidDeliverSubject invalid push consumer deliver subject
        JSConsumerInvalidDeliverSubject ErrorIdentifier = 10112

        // JSConsumerInvalidGroupNameErr Valid priority group name must match A-Z, a-z, 0-9, -_/=)+ and may not exceed 16 characters
        JSConsumerInvalidGroupNameErr ErrorIdentifier = 10162

        // JSConsumerInvalidPolicyErrF Generic delivery policy error ({err})
        JSConsumerInvalidPolicyErrF ErrorIdentifier = 10094

        // JSConsumerInvalidPriorityGroupErr Provided priority group does not exist for this consumer
        JSConsumerInvalidPriorityGroupErr ErrorIdentifier = 10160

        // JSConsumerInvalidSamplingErrF failed to parse consumer sampling configuration: {err}
        JSConsumerInvalidSamplingErrF ErrorIdentifier = 10095

        // JSConsumerMaxDeliverBackoffErr max deliver is required to be > length of backoff values
        JSConsumerMaxDeliverBackoffErr ErrorIdentifier = 10116

        // JSConsumerMaxPendingAckExcessErrF consumer max ack pending exceeds system limit of {limit}
        JSConsumerMaxPendingAckExcessErrF ErrorIdentifier = 10121

        // JSConsumerMaxPendingAckPolicyRequiredErr consumer requires ack policy for max ack pending
        JSConsumerMaxPendingAckPolicyRequiredErr ErrorIdentifier = 10082

        // JSConsumerMaxRequestBatchExceededF consumer max request batch exceeds server limit of {limit}
        JSConsumerMaxRequestBatchExceededF ErrorIdentifier = 10125

        // JSConsumerMaxRequestBatchNegativeErr consumer max request batch needs to be > 0
        JSConsumerMaxRequestBatchNegativeErr ErrorIdentifier = 10114

        // JSConsumerMaxRequestExpiresToSmall consumer max request expires needs to be >= 1ms
        JSConsumerMaxRequestExpiresToSmall ErrorIdentifier = 10115

        // JSConsumerMaxWaitingNegativeErr consumer max waiting needs to be positive
        JSConsumerMaxWaitingNegativeErr ErrorIdentifier = 10087

        // JSConsumerMetadataLengthErrF consumer metadata exceeds maximum size of {limit}
        JSConsumerMetadataLengthErrF ErrorIdentifier = 10135

        // JSConsumerMultipleFiltersNotAllowed consumer with multiple subject filters cannot use subject based API
        JSConsumerMultipleFiltersNotAllowed ErrorIdentifier = 10137

        // JSConsumerNameContainsPathSeparatorsErr Consumer name can not contain path separators
        JSConsumerNameContainsPathSeparatorsErr ErrorIdentifier = 10127

        // JSConsumerNameExistErr consumer name already in use
        JSConsumerNameExistErr ErrorIdentifier = 10013

        // JSConsumerNameTooLongErrF consumer name is too long, maximum allowed is {max}
        JSConsumerNameTooLongErrF ErrorIdentifier = 10102

        // JSConsumerNotFoundErr consumer not found
        JSConsumerNotFoundErr ErrorIdentifier = 10014

        // JSConsumerOfflineErr consumer is offline
        JSConsumerOfflineErr ErrorIdentifier = 10119

        // JSConsumerOnMappedErr consumer direct on a mapped consumer
        JSConsumerOnMappedErr ErrorIdentifier = 10092

        // JSConsumerOverlappingSubjectFilters consumer subject filters cannot overlap
        JSConsumerOverlappingSubjectFilters ErrorIdentifier = 10138

        // JSConsumerPriorityPolicyWithoutGroup Setting PriorityPolicy requires at least one PriorityGroup to be set
        JSConsumerPriorityPolicyWithoutGroup ErrorIdentifier = 10159

        // JSConsumerPullNotDurableErr consumer in pull mode requires a durable name
        JSConsumerPullNotDurableErr ErrorIdentifier = 10085

        // JSConsumerPullRequiresAckErr consumer in pull mode requires explicit ack policy on workqueue stream
        JSConsumerPullRequiresAckErr ErrorIdentifier = 10084

        // JSConsumerPullWithRateLimitErr consumer in pull mode can not have rate limit set
        JSConsumerPullWithRateLimitErr ErrorIdentifier = 10086

        // JSConsumerPushMaxWaitingErr consumer in push mode can not set max waiting
        JSConsumerPushMaxWaitingErr ErrorIdentifier = 10080

        // JSConsumerReplacementWithDifferentNameErr consumer replacement durable config not the same
        JSConsumerReplacementWithDifferentNameErr ErrorIdentifier = 10106

        // JSConsumerReplicasExceedsStream consumer config replica count exceeds parent stream
        JSConsumerReplicasExceedsStream ErrorIdentifier = 10126

        // JSConsumerReplicasShouldMatchStream consumer config replicas must match interest retention stream's replicas
        JSConsumerReplicasShouldMatchStream ErrorIdentifier = 10134

        // JSConsumerSmallHeartbeatErr consumer idle heartbeat needs to be >= 100ms
        JSConsumerSmallHeartbeatErr ErrorIdentifier = 10083

        // JSConsumerStoreFailedErrF error creating store for consumer: {err}
        JSConsumerStoreFailedErrF ErrorIdentifier = 10104

        // JSConsumerWQConsumerNotDeliverAllErr consumer must be deliver all on workqueue stream
        JSConsumerWQConsumerNotDeliverAllErr ErrorIdentifier = 10101

        // JSConsumerWQConsumerNotUniqueErr filtered consumer not unique on workqueue stream
        JSConsumerWQConsumerNotUniqueErr ErrorIdentifier = 10100

        // JSConsumerWQMultipleUnfilteredErr multiple non-filtered consumers not allowed on workqueue stream
        JSConsumerWQMultipleUnfilteredErr ErrorIdentifier = 10099

        // JSConsumerWQRequiresExplicitAckErr workqueue stream requires explicit ack
        JSConsumerWQRequiresExplicitAckErr ErrorIdentifier = 10098

        // JSConsumerWithFlowControlNeedsHeartbeats consumer with flow control also needs heartbeats
        JSConsumerWithFlowControlNeedsHeartbeats ErrorIdentifier = 10108

        // JSInsufficientResourcesErr insufficient resources
        JSInsufficientResourcesErr ErrorIdentifier = 10023

        // JSInvalidJSONErr invalid JSON: {err}
        JSInvalidJSONErr ErrorIdentifier = 10025

        // JSMaximumConsumersLimitErr maximum consumers limit reached
        JSMaximumConsumersLimitErr ErrorIdentifier = 10026

        // JSMaximumStreamsLimitErr maximum number of streams reached
        JSMaximumStreamsLimitErr ErrorIdentifier = 10027

        // JSMemoryResourcesExceededErr insufficient memory resources available
        JSMemoryResourcesExceededErr ErrorIdentifier = 10028

        // JSMessageTTLInvalidErr invalid per-message TTL
        JSMessageTTLInvalidErr ErrorIdentifier = 10165

        // JSMirrorConsumerSetupFailedErrF generic mirror consumer setup failure string ({err})
        JSMirrorConsumerSetupFailedErrF ErrorIdentifier = 10029

        // JSMirrorInvalidStreamName mirrored stream name is invalid
        JSMirrorInvalidStreamName ErrorIdentifier = 10142

        // JSMirrorInvalidSubjectFilter mirror transform source: {err}
        JSMirrorInvalidSubjectFilter ErrorIdentifier = 10151

        // JSMirrorInvalidTransformDestination mirror transform: {err}
        JSMirrorInvalidTransformDestination ErrorIdentifier = 10154

        // JSMirrorMaxMessageSizeTooBigErr stream mirror must have max message size >= source
        JSMirrorMaxMessageSizeTooBigErr ErrorIdentifier = 10030

        // JSMirrorMultipleFiltersNotAllowed mirror with multiple subject transforms cannot also have a single subject filter
        JSMirrorMultipleFiltersNotAllowed ErrorIdentifier = 10150

        // JSMirrorOverlappingSubjectFilters mirror subject filters can not overlap
        JSMirrorOverlappingSubjectFilters ErrorIdentifier = 10152

        // JSMirrorWithFirstSeqErr stream mirrors can not have first sequence configured
        JSMirrorWithFirstSeqErr ErrorIdentifier = 10143

        // JSMirrorWithSourcesErr stream mirrors can not also contain other sources
        JSMirrorWithSourcesErr ErrorIdentifier = 10031

        // JSMirrorWithStartSeqAndTimeErr stream mirrors can not have both start seq and start time configured
        JSMirrorWithStartSeqAndTimeErr ErrorIdentifier = 10032

        // JSMirrorWithSubjectFiltersErr stream mirrors can not contain filtered subjects
        JSMirrorWithSubjectFiltersErr ErrorIdentifier = 10033

        // JSMirrorWithSubjectsErr stream mirrors can not contain subjects
        JSMirrorWithSubjectsErr ErrorIdentifier = 10034

        // JSNoAccountErr account not found
        JSNoAccountErr ErrorIdentifier = 10035

        // JSNoLimitsErr no JetStream default or applicable tiered limit present
        JSNoLimitsErr ErrorIdentifier = 10120

        // JSNoMessageFoundErr no message found
        JSNoMessageFoundErr ErrorIdentifier = 10037

        // JSNotEmptyRequestErr expected an empty request payload
        JSNotEmptyRequestErr ErrorIdentifier = 10038

        // JSNotEnabledErr JetStream not enabled
        JSNotEnabledErr ErrorIdentifier = 10076

        // JSNotEnabledForAccountErr JetStream not enabled for account
        JSNotEnabledForAccountErr ErrorIdentifier = 10039

        // JSPedanticErrF pedantic mode: {err}
        JSPedanticErrF ErrorIdentifier = 10157

        // JSPeerRemapErr peer remap failed
        JSPeerRemapErr ErrorIdentifier = 10075

        // JSRaftGeneralErrF General RAFT error string ({err})
        JSRaftGeneralErrF ErrorIdentifier = 10041

        // JSReplicasCountCannotBeNegative replicas count cannot be negative
        JSReplicasCountCannotBeNegative ErrorIdentifier = 10133

        // JSRestoreSubscribeFailedErrF JetStream unable to subscribe to restore snapshot {subject}: {err}
        JSRestoreSubscribeFailedErrF ErrorIdentifier = 10042

        // JSSequenceNotFoundErrF sequence {seq} not found
        JSSequenceNotFoundErrF ErrorIdentifier = 10043

        // JSSnapshotDeliverSubjectInvalidErr deliver subject not valid
        JSSnapshotDeliverSubjectInvalidErr ErrorIdentifier = 10015

        // JSSourceConsumerSetupFailedErrF General source consumer setup failure string ({err})
        JSSourceConsumerSetupFailedErrF ErrorIdentifier = 10045

        // JSSourceDuplicateDetected source stream, filter and transform (plus external if present) must form a unique combination (duplicate source configuration detected)
        JSSourceDuplicateDetected ErrorIdentifier = 10140

        // JSSourceInvalidStreamName sourced stream name is invalid
        JSSourceInvalidStreamName ErrorIdentifier = 10141

        // JSSourceInvalidSubjectFilter source transform source: {err}
        JSSourceInvalidSubjectFilter ErrorIdentifier = 10145

        // JSSourceInvalidTransformDestination source transform: {err}
        JSSourceInvalidTransformDestination ErrorIdentifier = 10146

        // JSSourceMaxMessageSizeTooBigErr stream source must have max message size >= target
        JSSourceMaxMessageSizeTooBigErr ErrorIdentifier = 10046

        // JSSourceMultipleFiltersNotAllowed source with multiple subject transforms cannot also have a single subject filter
        JSSourceMultipleFiltersNotAllowed ErrorIdentifier = 10144

        // JSSourceOverlappingSubjectFilters source filters can not overlap
        JSSourceOverlappingSubjectFilters ErrorIdentifier = 10147

        // JSStorageResourcesExceededErr insufficient storage resources available
        JSStorageResourcesExceededErr ErrorIdentifier = 10047

        // JSStreamAssignmentErrF Generic stream assignment error string ({err})
        JSStreamAssignmentErrF ErrorIdentifier = 10048

        // JSStreamCreateErrF Generic stream creation error string ({err})
        JSStreamCreateErrF ErrorIdentifier = 10049

        // JSStreamDeleteErrF General stream deletion error string ({err})
        JSStreamDeleteErrF ErrorIdentifier = 10050

        // JSStreamDuplicateMessageConflict duplicate message id is in process
        JSStreamDuplicateMessageConflict ErrorIdentifier = 10158

        // JSStreamExpectedLastSeqPerSubjectNotReady expected last sequence per subject temporarily unavailable
        JSStreamExpectedLastSeqPerSubjectNotReady ErrorIdentifier = 10163

        // JSStreamExternalApiOverlapErrF stream external api prefix {prefix} must not overlap with {subject}
        JSStreamExternalApiOverlapErrF ErrorIdentifier = 10021

        // JSStreamExternalDelPrefixOverlapsErrF stream external delivery prefix {prefix} overlaps with stream subject {subject}
        JSStreamExternalDelPrefixOverlapsErrF ErrorIdentifier = 10022

        // JSStreamGeneralErrorF General stream failure string ({err})
        JSStreamGeneralErrorF ErrorIdentifier = 10051

        // JSStreamHeaderExceedsMaximumErr header size exceeds maximum allowed of 64k
        JSStreamHeaderExceedsMaximumErr ErrorIdentifier = 10097

        // JSStreamInfoMaxSubjectsErr subject details would exceed maximum allowed
        JSStreamInfoMaxSubjectsErr ErrorIdentifier = 10117

        // JSStreamInvalidConfigF Stream configuration validation error string ({err})
        JSStreamInvalidConfigF ErrorIdentifier = 10052

        // JSStreamInvalidErr stream not valid
        JSStreamInvalidErr ErrorIdentifier = 10096

        // JSStreamInvalidExternalDeliverySubjErrF stream external delivery prefix {prefix} must not contain wildcards
        JSStreamInvalidExternalDeliverySubjErrF ErrorIdentifier = 10024

        // JSStreamLimitsErrF General stream limits exceeded error string ({err})
        JSStreamLimitsErrF ErrorIdentifier = 10053

        // JSStreamMaxBytesRequired account requires a stream config to have max bytes set
        JSStreamMaxBytesRequired ErrorIdentifier = 10113

        // JSStreamMaxStreamBytesExceeded stream max bytes exceeds account limit max stream bytes
        JSStreamMaxStreamBytesExceeded ErrorIdentifier = 10122

        // JSStreamMessageExceedsMaximumErr message size exceeds maximum allowed
        JSStreamMessageExceedsMaximumErr ErrorIdentifier = 10054

        // JSStreamMirrorNotUpdatableErr stream mirror configuration can not be updated
        JSStreamMirrorNotUpdatableErr ErrorIdentifier = 10055

        // JSStreamMismatchErr stream name in subject does not match request
        JSStreamMismatchErr ErrorIdentifier = 10056

        // JSStreamMoveAndScaleErr can not move and scale a stream in a single update
        JSStreamMoveAndScaleErr ErrorIdentifier = 10123

        // JSStreamMoveInProgressF stream move already in progress: {msg}
        JSStreamMoveInProgressF ErrorIdentifier = 10124

        // JSStreamMoveNotInProgress stream move not in progress
        JSStreamMoveNotInProgress ErrorIdentifier = 10129

        // JSStreamMsgDeleteFailedF Generic message deletion failure error string ({err})
        JSStreamMsgDeleteFailedF ErrorIdentifier = 10057

        // JSStreamNameContainsPathSeparatorsErr Stream name can not contain path separators
        JSStreamNameContainsPathSeparatorsErr ErrorIdentifier = 10128

        // JSStreamNameExistErr stream name already in use with a different configuration
        JSStreamNameExistErr ErrorIdentifier = 10058

        // JSStreamNameExistRestoreFailedErr stream name already in use, cannot restore
        JSStreamNameExistRestoreFailedErr ErrorIdentifier = 10130

        // JSStreamNotFoundErr stream not found
        JSStreamNotFoundErr ErrorIdentifier = 10059

        // JSStreamNotMatchErr expected stream does not match
        JSStreamNotMatchErr ErrorIdentifier = 10060

        // JSStreamOfflineErr stream is offline
        JSStreamOfflineErr ErrorIdentifier = 10118

        // JSStreamPurgeFailedF Generic stream purge failure error string ({err})
        JSStreamPurgeFailedF ErrorIdentifier = 10110

        // JSStreamReplicasNotSupportedErr replicas > 1 not supported in non-clustered mode
        JSStreamReplicasNotSupportedErr ErrorIdentifier = 10074

        // JSStreamReplicasNotUpdatableErr Replicas configuration can not be updated
        JSStreamReplicasNotUpdatableErr ErrorIdentifier = 10061

        // JSStreamRestoreErrF restore failed: {err}
        JSStreamRestoreErrF ErrorIdentifier = 10062

        // JSStreamRollupFailedF Generic stream rollup failure error string ({err})
        JSStreamRollupFailedF ErrorIdentifier = 10111

        // JSStreamSealedErr invalid operation on sealed stream
        JSStreamSealedErr ErrorIdentifier = 10109

        // JSStreamSequenceNotMatchErr expected stream sequence does not match
        JSStreamSequenceNotMatchErr ErrorIdentifier = 10063

        // JSStreamSnapshotErrF snapshot failed: {err}
        JSStreamSnapshotErrF ErrorIdentifier = 10064

        // JSStreamStoreFailedF Generic error when storing a message failed ({err})
        JSStreamStoreFailedF ErrorIdentifier = 10077

        // JSStreamSubjectOverlapErr subjects overlap with an existing stream
        JSStreamSubjectOverlapErr ErrorIdentifier = 10065

        // JSStreamTemplateCreateErrF Generic template creation failed string ({err})
        JSStreamTemplateCreateErrF ErrorIdentifier = 10066

        // JSStreamTemplateDeleteErrF Generic stream template deletion failed error string ({err})
        JSStreamTemplateDeleteErrF ErrorIdentifier = 10067

        // JSStreamTemplateNotFoundErr template not found
        JSStreamTemplateNotFoundErr ErrorIdentifier = 10068

        // JSStreamTransformInvalidDestination stream transform: {err}
        JSStreamTransformInvalidDestination ErrorIdentifier = 10156

        // JSStreamTransformInvalidSource stream transform source: {err}
        JSStreamTransformInvalidSource ErrorIdentifier = 10155

        // JSStreamUpdateErrF Generic stream update error string ({err})
        JSStreamUpdateErrF ErrorIdentifier = 10069

        // JSStreamWrongLastMsgIDErrF wrong last msg ID: {id}
        JSStreamWrongLastMsgIDErrF ErrorIdentifier = 10070

        // JSStreamWrongLastSequenceConstantErr wrong last sequence
        JSStreamWrongLastSequenceConstantErr ErrorIdentifier = 10164

        // JSStreamWrongLastSequenceErrF wrong last sequence: {seq}
        JSStreamWrongLastSequenceErrF ErrorIdentifier = 10071

        // JSTempStorageFailedErr JetStream unable to open temp storage for restore
        JSTempStorageFailedErr ErrorIdentifier = 10072

        // JSTemplateNameNotMatchSubjectErr template name in subject does not match request
        JSTemplateNameNotMatchSubjectErr ErrorIdentifier = 10073
)

var (
        ApiErrors = map[ErrorIdentifier]*ApiError{
                JSAccountResourcesExceededErr:              {Code: 400, ErrCode: 10002, Description: "resource limits exceeded for account"},
                JSBadRequestErr:                            {Code: 400, ErrCode: 10003, Description: "bad request"},
                JSClusterIncompleteErr:                     {Code: 503, ErrCode: 10004, Description: "incomplete results"},
                JSClusterNoPeersErrF:                       {Code: 400, ErrCode: 10005, Description: "{err}"},
                JSClusterNotActiveErr:                      {Code: 500, ErrCode: 10006, Description: "JetStream not in clustered mode"},
                JSClusterNotAssignedErr:                    {Code: 500, ErrCode: 10007, Description: "JetStream cluster not assigned to this server"},
                JSClusterNotAvailErr:                       {Code: 503, ErrCode: 10008, Description: "JetStream system temporarily unavailable"},
                JSClusterNotLeaderErr:                      {Code: 500, ErrCode: 10009, Description: "JetStream cluster can not handle request"},
                JSClusterPeerNotMemberErr:                  {Code: 400, ErrCode: 10040, Description: "peer not a member"},
                JSClusterRequiredErr:                       {Code: 503, ErrCode: 10010, Description: "JetStream clustering support required"},
                JSClusterServerNotMemberErr:                {Code: 400, ErrCode: 10044, Description: "server is not a member of the cluster"},
                JSClusterTagsErr:                           {Code: 400, ErrCode: 10011, Description: "tags placement not supported for operation"},
                JSClusterUnSupportFeatureErr:               {Code: 503, ErrCode: 10036, Description: "not currently supported in clustered mode"},
                JSConsumerAlreadyExists:                    {Code: 400, ErrCode: 10148, Description: "consumer already exists"},
                JSConsumerBadDurableNameErr:                {Code: 400, ErrCode: 10103, Description: "durable name can not contain '.', '*', '>'"},
                JSConsumerConfigRequiredErr:                {Code: 400, ErrCode: 10078, Description: "consumer config required"},
                JSConsumerCreateDurableAndNameMismatch:     {Code: 400, ErrCode: 10132, Description: "Consumer Durable and Name have to be equal if both are provided"},
                JSConsumerCreateErrF:                       {Code: 500, ErrCode: 10012, Description: "{err}"},
                JSConsumerCreateFilterSubjectMismatchErr:   {Code: 400, ErrCode: 10131, Description: "Consumer create request did not match filtered subject from create subject"},
                JSConsumerDeliverCycleErr:                  {Code: 400, ErrCode: 10081, Description: "consumer deliver subject forms a cycle"},
                JSConsumerDeliverToWildcardsErr:            {Code: 400, ErrCode: 10079, Description: "consumer deliver subject has wildcards"},
                JSConsumerDescriptionTooLongErrF:           {Code: 400, ErrCode: 10107, Description: "consumer description is too long, maximum allowed is {max}"},
                JSConsumerDirectRequiresEphemeralErr:       {Code: 400, ErrCode: 10091, Description: "consumer direct requires an ephemeral consumer"},
                JSConsumerDirectRequiresPushErr:            {Code: 400, ErrCode: 10090, Description: "consumer direct requires a push based consumer"},
                JSConsumerDoesNotExist:                     {Code: 400, ErrCode: 10149, Description: "consumer does not exist"},
                JSConsumerDuplicateFilterSubjects:          {Code: 400, ErrCode: 10136, Description: "consumer cannot have both FilterSubject and FilterSubjects specified"},
                JSConsumerDurableNameNotInSubjectErr:       {Code: 400, ErrCode: 10016, Description: "consumer expected to be durable but no durable name set in subject"},
                JSConsumerDurableNameNotMatchSubjectErr:    {Code: 400, ErrCode: 10017, Description: "consumer name in subject does not match durable name in request"},
                JSConsumerDurableNameNotSetErr:             {Code: 400, ErrCode: 10018, Description: "consumer expected to be durable but a durable name was not set"},
                JSConsumerEmptyFilter:                      {Code: 400, ErrCode: 10139, Description: "consumer filter in FilterSubjects cannot be empty"},
                JSConsumerEmptyGroupName:                   {Code: 400, ErrCode: 10161, Description: "Group name cannot be an empty string"},
                JSConsumerEphemeralWithDurableInSubjectErr: {Code: 400, ErrCode: 10019, Description: "consumer expected to be ephemeral but detected a durable name set in subject"},
                JSConsumerEphemeralWithDurableNameErr:      {Code: 400, ErrCode: 10020, Description: "consumer expected to be ephemeral but a durable name was set in request"},
                JSConsumerExistingActiveErr:                {Code: 400, ErrCode: 10105, Description: "consumer already exists and is still active"},
                JSConsumerFCRequiresPushErr:                {Code: 400, ErrCode: 10089, Description: "consumer flow control requires a push based consumer"},
                JSConsumerFilterNotSubsetErr:               {Code: 400, ErrCode: 10093, Description: "consumer filter subject is not a valid subset of the interest subjects"},
                JSConsumerHBRequiresPushErr:                {Code: 400, ErrCode: 10088, Description: "consumer idle heartbeat requires a push based consumer"},
                JSConsumerInactiveThresholdExcess:          {Code: 400, ErrCode: 10153, Description: "consumer inactive threshold exceeds system limit of {limit}"},
                JSConsumerInvalidDeliverSubject:            {Code: 400, ErrCode: 10112, Description: "invalid push consumer deliver subject"},
                JSConsumerInvalidGroupNameErr:              {Code: 400, ErrCode: 10162, Description: "Valid priority group name must match A-Z, a-z, 0-9, -_/=)+ and may not exceed 16 characters"},
                JSConsumerInvalidPolicyErrF:                {Code: 400, ErrCode: 10094, Description: "{err}"},
                JSConsumerInvalidPriorityGroupErr:          {Code: 400, ErrCode: 10160, Description: "Provided priority group does not exist for this consumer"},
                JSConsumerInvalidSamplingErrF:              {Code: 400, ErrCode: 10095, Description: "failed to parse consumer sampling configuration: {err}"},
                JSConsumerMaxDeliverBackoffErr:             {Code: 400, ErrCode: 10116, Description: "max deliver is required to be > length of backoff values"},
                JSConsumerMaxPendingAckExcessErrF:          {Code: 400, ErrCode: 10121, Description: "consumer max ack pending exceeds system limit of {limit}"},
                JSConsumerMaxPendingAckPolicyRequiredErr:   {Code: 400, ErrCode: 10082, Description: "consumer requires ack policy for max ack pending"},
                JSConsumerMaxRequestBatchExceededF:         {Code: 400, ErrCode: 10125, Description: "consumer max request batch exceeds server limit of {limit}"},
                JSConsumerMaxRequestBatchNegativeErr:       {Code: 400, ErrCode: 10114, Description: "consumer max request batch needs to be > 0"},
                JSConsumerMaxRequestExpiresToSmall:         {Code: 400, ErrCode: 10115, Description: "consumer max request expires needs to be >= 1ms"},
                JSConsumerMaxWaitingNegativeErr:            {Code: 400, ErrCode: 10087, Description: "consumer max waiting needs to be positive"},
                JSConsumerMetadataLengthErrF:               {Code: 400, ErrCode: 10135, Description: "consumer metadata exceeds maximum size of {limit}"},
                JSConsumerMultipleFiltersNotAllowed:        {Code: 400, ErrCode: 10137, Description: "consumer with multiple subject filters cannot use subject based API"},
                JSConsumerNameContainsPathSeparatorsErr:    {Code: 400, ErrCode: 10127, Description: "Consumer name can not contain path separators"},
                JSConsumerNameExistErr:                     {Code: 400, ErrCode: 10013, Description: "consumer name already in use"},
                JSConsumerNameTooLongErrF:                  {Code: 400, ErrCode: 10102, Description: "consumer name is too long, maximum allowed is {max}"},
                JSConsumerNotFoundErr:                      {Code: 404, ErrCode: 10014, Description: "consumer not found"},
                JSConsumerOfflineErr:                       {Code: 500, ErrCode: 10119, Description: "consumer is offline"},
                JSConsumerOnMappedErr:                      {Code: 400, ErrCode: 10092, Description: "consumer direct on a mapped consumer"},
                JSConsumerOverlappingSubjectFilters:        {Code: 400, ErrCode: 10138, Description: "consumer subject filters cannot overlap"},
                JSConsumerPriorityPolicyWithoutGroup:       {Code: 400, ErrCode: 10159, Description: "Setting PriorityPolicy requires at least one PriorityGroup to be set"},
                JSConsumerPullNotDurableErr:                {Code: 400, ErrCode: 10085, Description: "consumer in pull mode requires a durable name"},
                JSConsumerPullRequiresAckErr:               {Code: 400, ErrCode: 10084, Description: "consumer in pull mode requires explicit ack policy on workqueue stream"},
                JSConsumerPullWithRateLimitErr:             {Code: 400, ErrCode: 10086, Description: "consumer in pull mode can not have rate limit set"},
                JSConsumerPushMaxWaitingErr:                {Code: 400, ErrCode: 10080, Description: "consumer in push mode can not set max waiting"},
                JSConsumerReplacementWithDifferentNameErr:  {Code: 400, ErrCode: 10106, Description: "consumer replacement durable config not the same"},
                JSConsumerReplicasExceedsStream:            {Code: 400, ErrCode: 10126, Description: "consumer config replica count exceeds parent stream"},
                JSConsumerReplicasShouldMatchStream:        {Code: 400, ErrCode: 10134, Description: "consumer config replicas must match interest retention stream's replicas"},
                JSConsumerSmallHeartbeatErr:                {Code: 400, ErrCode: 10083, Description: "consumer idle heartbeat needs to be >= 100ms"},
                JSConsumerStoreFailedErrF:                  {Code: 500, ErrCode: 10104, Description: "error creating store for consumer: {err}"},
                JSConsumerWQConsumerNotDeliverAllErr:       {Code: 400, ErrCode: 10101, Description: "consumer must be deliver all on workqueue stream"},
                JSConsumerWQConsumerNotUniqueErr:           {Code: 400, ErrCode: 10100, Description: "filtered consumer not unique on workqueue stream"},
                JSConsumerWQMultipleUnfilteredErr:          {Code: 400, ErrCode: 10099, Description: "multiple non-filtered consumers not allowed on workqueue stream"},
                JSConsumerWQRequiresExplicitAckErr:         {Code: 400, ErrCode: 10098, Description: "workqueue stream requires explicit ack"},
                JSConsumerWithFlowControlNeedsHeartbeats:   {Code: 400, ErrCode: 10108, Description: "consumer with flow control also needs heartbeats"},
                JSInsufficientResourcesErr:                 {Code: 503, ErrCode: 10023, Description: "insufficient resources"},
                JSInvalidJSONErr:                           {Code: 400, ErrCode: 10025, Description: "invalid JSON: {err}"},
                JSMaximumConsumersLimitErr:                 {Code: 400, ErrCode: 10026, Description: "maximum consumers limit reached"},
                JSMaximumStreamsLimitErr:                   {Code: 400, ErrCode: 10027, Description: "maximum number of streams reached"},
                JSMemoryResourcesExceededErr:               {Code: 500, ErrCode: 10028, Description: "insufficient memory resources available"},
                JSMessageTTLInvalidErr:                     {Code: 400, ErrCode: 10165, Description: "invalid per-message TTL"},
                JSMirrorConsumerSetupFailedErrF:            {Code: 500, ErrCode: 10029, Description: "{err}"},
                JSMirrorInvalidStreamName:                  {Code: 400, ErrCode: 10142, Description: "mirrored stream name is invalid"},
                JSMirrorInvalidSubjectFilter:               {Code: 400, ErrCode: 10151, Description: "mirror transform source: {err}"},
                JSMirrorInvalidTransformDestination:        {Code: 400, ErrCode: 10154, Description: "mirror transform: {err}"},
                JSMirrorMaxMessageSizeTooBigErr:            {Code: 400, ErrCode: 10030, Description: "stream mirror must have max message size >= source"},
                JSMirrorMultipleFiltersNotAllowed:          {Code: 400, ErrCode: 10150, Description: "mirror with multiple subject transforms cannot also have a single subject filter"},
                JSMirrorOverlappingSubjectFilters:          {Code: 400, ErrCode: 10152, Description: "mirror subject filters can not overlap"},
                JSMirrorWithFirstSeqErr:                    {Code: 400, ErrCode: 10143, Description: "stream mirrors can not have first sequence configured"},
                JSMirrorWithSourcesErr:                     {Code: 400, ErrCode: 10031, Description: "stream mirrors can not also contain other sources"},
                JSMirrorWithStartSeqAndTimeErr:             {Code: 400, ErrCode: 10032, Description: "stream mirrors can not have both start seq and start time configured"},
                JSMirrorWithSubjectFiltersErr:              {Code: 400, ErrCode: 10033, Description: "stream mirrors can not contain filtered subjects"},
                JSMirrorWithSubjectsErr:                    {Code: 400, ErrCode: 10034, Description: "stream mirrors can not contain subjects"},
                JSNoAccountErr:                             {Code: 503, ErrCode: 10035, Description: "account not found"},
                JSNoLimitsErr:                              {Code: 400, ErrCode: 10120, Description: "no JetStream default or applicable tiered limit present"},
                JSNoMessageFoundErr:                        {Code: 404, ErrCode: 10037, Description: "no message found"},
                JSNotEmptyRequestErr:                       {Code: 400, ErrCode: 10038, Description: "expected an empty request payload"},
                JSNotEnabledErr:                            {Code: 503, ErrCode: 10076, Description: "JetStream not enabled"},
                JSNotEnabledForAccountErr:                  {Code: 503, ErrCode: 10039, Description: "JetStream not enabled for account"},
                JSPedanticErrF:                             {Code: 400, ErrCode: 10157, Description: "pedantic mode: {err}"},
                JSPeerRemapErr:                             {Code: 503, ErrCode: 10075, Description: "peer remap failed"},
                JSRaftGeneralErrF:                          {Code: 500, ErrCode: 10041, Description: "{err}"},
                JSReplicasCountCannotBeNegative:            {Code: 400, ErrCode: 10133, Description: "replicas count cannot be negative"},
                JSRestoreSubscribeFailedErrF:               {Code: 500, ErrCode: 10042, Description: "JetStream unable to subscribe to restore snapshot {subject}: {err}"},
                JSSequenceNotFoundErrF:                     {Code: 400, ErrCode: 10043, Description: "sequence {seq} not found"},
                JSSnapshotDeliverSubjectInvalidErr:         {Code: 400, ErrCode: 10015, Description: "deliver subject not valid"},
                JSSourceConsumerSetupFailedErrF:            {Code: 500, ErrCode: 10045, Description: "{err}"},
                JSSourceDuplicateDetected:                  {Code: 400, ErrCode: 10140, Description: "duplicate source configuration detected"},
                JSSourceInvalidStreamName:                  {Code: 400, ErrCode: 10141, Description: "sourced stream name is invalid"},
                JSSourceInvalidSubjectFilter:               {Code: 400, ErrCode: 10145, Description: "source transform source: {err}"},
                JSSourceInvalidTransformDestination:        {Code: 400, ErrCode: 10146, Description: "source transform: {err}"},
                JSSourceMaxMessageSizeTooBigErr:            {Code: 400, ErrCode: 10046, Description: "stream source must have max message size >= target"},
                JSSourceMultipleFiltersNotAllowed:          {Code: 400, ErrCode: 10144, Description: "source with multiple subject transforms cannot also have a single subject filter"},
                JSSourceOverlappingSubjectFilters:          {Code: 400, ErrCode: 10147, Description: "source filters can not overlap"},
                JSStorageResourcesExceededErr:              {Code: 500, ErrCode: 10047, Description: "insufficient storage resources available"},
                JSStreamAssignmentErrF:                     {Code: 500, ErrCode: 10048, Description: "{err}"},
                JSStreamCreateErrF:                         {Code: 500, ErrCode: 10049, Description: "{err}"},
                JSStreamDeleteErrF:                         {Code: 500, ErrCode: 10050, Description: "{err}"},
                JSStreamDuplicateMessageConflict:           {Code: 409, ErrCode: 10158, Description: "duplicate message id is in process"},
                JSStreamExpectedLastSeqPerSubjectNotReady:  {Code: 503, ErrCode: 10163, Description: "expected last sequence per subject temporarily unavailable"},
                JSStreamExternalApiOverlapErrF:             {Code: 400, ErrCode: 10021, Description: "stream external api prefix {prefix} must not overlap with {subject}"},
                JSStreamExternalDelPrefixOverlapsErrF:      {Code: 400, ErrCode: 10022, Description: "stream external delivery prefix {prefix} overlaps with stream subject {subject}"},
                JSStreamGeneralErrorF:                      {Code: 500, ErrCode: 10051, Description: "{err}"},
                JSStreamHeaderExceedsMaximumErr:            {Code: 400, ErrCode: 10097, Description: "header size exceeds maximum allowed of 64k"},
                JSStreamInfoMaxSubjectsErr:                 {Code: 500, ErrCode: 10117, Description: "subject details would exceed maximum allowed"},
                JSStreamInvalidConfigF:                     {Code: 500, ErrCode: 10052, Description: "{err}"},
                JSStreamInvalidErr:                         {Code: 500, ErrCode: 10096, Description: "stream not valid"},
                JSStreamInvalidExternalDeliverySubjErrF:    {Code: 400, ErrCode: 10024, Description: "stream external delivery prefix {prefix} must not contain wildcards"},
                JSStreamLimitsErrF:                         {Code: 500, ErrCode: 10053, Description: "{err}"},
                JSStreamMaxBytesRequired:                   {Code: 400, ErrCode: 10113, Description: "account requires a stream config to have max bytes set"},
                JSStreamMaxStreamBytesExceeded:             {Code: 400, ErrCode: 10122, Description: "stream max bytes exceeds account limit max stream bytes"},
                JSStreamMessageExceedsMaximumErr:           {Code: 400, ErrCode: 10054, Description: "message size exceeds maximum allowed"},
                JSStreamMirrorNotUpdatableErr:              {Code: 400, ErrCode: 10055, Description: "stream mirror configuration can not be updated"},
                JSStreamMismatchErr:                        {Code: 400, ErrCode: 10056, Description: "stream name in subject does not match request"},
                JSStreamMoveAndScaleErr:                    {Code: 400, ErrCode: 10123, Description: "can not move and scale a stream in a single update"},
                JSStreamMoveInProgressF:                    {Code: 400, ErrCode: 10124, Description: "stream move already in progress: {msg}"},
                JSStreamMoveNotInProgress:                  {Code: 400, ErrCode: 10129, Description: "stream move not in progress"},
                JSStreamMsgDeleteFailedF:                   {Code: 500, ErrCode: 10057, Description: "{err}"},
                JSStreamNameContainsPathSeparatorsErr:      {Code: 400, ErrCode: 10128, Description: "Stream name can not contain path separators"},
                JSStreamNameExistErr:                       {Code: 400, ErrCode: 10058, Description: "stream name already in use with a different configuration"},
                JSStreamNameExistRestoreFailedErr:          {Code: 400, ErrCode: 10130, Description: "stream name already in use, cannot restore"},
                JSStreamNotFoundErr:                        {Code: 404, ErrCode: 10059, Description: "stream not found"},
                JSStreamNotMatchErr:                        {Code: 400, ErrCode: 10060, Description: "expected stream does not match"},
                JSStreamOfflineErr:                         {Code: 500, ErrCode: 10118, Description: "stream is offline"},
                JSStreamPurgeFailedF:                       {Code: 500, ErrCode: 10110, Description: "{err}"},
                JSStreamReplicasNotSupportedErr:            {Code: 500, ErrCode: 10074, Description: "replicas > 1 not supported in non-clustered mode"},
                JSStreamReplicasNotUpdatableErr:            {Code: 400, ErrCode: 10061, Description: "Replicas configuration can not be updated"},
                JSStreamRestoreErrF:                        {Code: 500, ErrCode: 10062, Description: "restore failed: {err}"},
                JSStreamRollupFailedF:                      {Code: 500, ErrCode: 10111, Description: "{err}"},
                JSStreamSealedErr:                          {Code: 400, ErrCode: 10109, Description: "invalid operation on sealed stream"},
                JSStreamSequenceNotMatchErr:                {Code: 503, ErrCode: 10063, Description: "expected stream sequence does not match"},
                JSStreamSnapshotErrF:                       {Code: 500, ErrCode: 10064, Description: "snapshot failed: {err}"},
                JSStreamStoreFailedF:                       {Code: 503, ErrCode: 10077, Description: "{err}"},
                JSStreamSubjectOverlapErr:                  {Code: 400, ErrCode: 10065, Description: "subjects overlap with an existing stream"},
                JSStreamTemplateCreateErrF:                 {Code: 500, ErrCode: 10066, Description: "{err}"},
                JSStreamTemplateDeleteErrF:                 {Code: 500, ErrCode: 10067, Description: "{err}"},
                JSStreamTemplateNotFoundErr:                {Code: 404, ErrCode: 10068, Description: "template not found"},
                JSStreamTransformInvalidDestination:        {Code: 400, ErrCode: 10156, Description: "stream transform: {err}"},
                JSStreamTransformInvalidSource:             {Code: 400, ErrCode: 10155, Description: "stream transform source: {err}"},
                JSStreamUpdateErrF:                         {Code: 500, ErrCode: 10069, Description: "{err}"},
                JSStreamWrongLastMsgIDErrF:                 {Code: 400, ErrCode: 10070, Description: "wrong last msg ID: {id}"},
                JSStreamWrongLastSequenceConstantErr:       {Code: 400, ErrCode: 10164, Description: "wrong last sequence"},
                JSStreamWrongLastSequenceErrF:              {Code: 400, ErrCode: 10071, Description: "wrong last sequence: {seq}"},
                JSTempStorageFailedErr:                     {Code: 500, ErrCode: 10072, Description: "JetStream unable to open temp storage for restore"},
                JSTemplateNameNotMatchSubjectErr:           {Code: 400, ErrCode: 10073, Description: "template name in subject does not match request"},
        }
        // ErrJetStreamNotClustered Deprecated by JSClusterNotActiveErr ApiError, use IsNatsError() for comparisons
        ErrJetStreamNotClustered = ApiErrors[JSClusterNotActiveErr]
        // ErrJetStreamNotAssigned Deprecated by JSClusterNotAssignedErr ApiError, use IsNatsError() for comparisons
        ErrJetStreamNotAssigned = ApiErrors[JSClusterNotAssignedErr]
        // ErrJetStreamNotLeader Deprecated by JSClusterNotLeaderErr ApiError, use IsNatsError() for comparisons
        ErrJetStreamNotLeader = ApiErrors[JSClusterNotLeaderErr]
        // ErrJetStreamConsumerAlreadyUsed Deprecated by JSConsumerNameExistErr ApiError, use IsNatsError() for comparisons
        ErrJetStreamConsumerAlreadyUsed = ApiErrors[JSConsumerNameExistErr]
        // ErrJetStreamResourcesExceeded Deprecated by JSInsufficientResourcesErr ApiError, use IsNatsError() for comparisons
        ErrJetStreamResourcesExceeded = ApiErrors[JSInsufficientResourcesErr]
        // ErrMemoryResourcesExceeded Deprecated by JSMemoryResourcesExceededErr ApiError, use IsNatsError() for comparisons
        ErrMemoryResourcesExceeded = ApiErrors[JSMemoryResourcesExceededErr]
        // ErrJetStreamNotEnabled Deprecated by JSNotEnabledErr ApiError, use IsNatsError() for comparisons
        ErrJetStreamNotEnabled = ApiErrors[JSNotEnabledErr]
        // ErrStorageResourcesExceeded Deprecated by JSStorageResourcesExceededErr ApiError, use IsNatsError() for comparisons
        ErrStorageResourcesExceeded = ApiErrors[JSStorageResourcesExceededErr]
        // ErrJetStreamStreamAlreadyUsed Deprecated by JSStreamNameExistErr ApiError, use IsNatsError() for comparisons
        ErrJetStreamStreamAlreadyUsed = ApiErrors[JSStreamNameExistErr]
        // ErrJetStreamStreamNotFound Deprecated by JSStreamNotFoundErr ApiError, use IsNatsError() for comparisons
        ErrJetStreamStreamNotFound = ApiErrors[JSStreamNotFoundErr]
        // ErrReplicasNotSupported Deprecated by JSStreamReplicasNotSupportedErr ApiError, use IsNatsError() for comparisons
        ErrReplicasNotSupported = ApiErrors[JSStreamReplicasNotSupportedErr]
)

// NewJSAccountResourcesExceededError creates a new JSAccountResourcesExceededErr error: "resource limits exceeded for account"
func NewJSAccountResourcesExceededError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSAccountResourcesExceededErr]
}

// NewJSBadRequestError creates a new JSBadRequestErr error: "bad request"
func NewJSBadRequestError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSBadRequestErr]
}

// NewJSClusterIncompleteError creates a new JSClusterIncompleteErr error: "incomplete results"
func NewJSClusterIncompleteError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSClusterIncompleteErr]
}

// NewJSClusterNoPeersError creates a new JSClusterNoPeersErrF error: "{err}"
func NewJSClusterNoPeersError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSClusterNoPeersErrF]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSClusterNotActiveError creates a new JSClusterNotActiveErr error: "JetStream not in clustered mode"
func NewJSClusterNotActiveError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSClusterNotActiveErr]
}

// NewJSClusterNotAssignedError creates a new JSClusterNotAssignedErr error: "JetStream cluster not assigned to this server"
func NewJSClusterNotAssignedError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSClusterNotAssignedErr]
}

// NewJSClusterNotAvailError creates a new JSClusterNotAvailErr error: "JetStream system temporarily unavailable"
func NewJSClusterNotAvailError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSClusterNotAvailErr]
}

// NewJSClusterNotLeaderError creates a new JSClusterNotLeaderErr error: "JetStream cluster can not handle request"
func NewJSClusterNotLeaderError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSClusterNotLeaderErr]
}

// NewJSClusterPeerNotMemberError creates a new JSClusterPeerNotMemberErr error: "peer not a member"
func NewJSClusterPeerNotMemberError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSClusterPeerNotMemberErr]
}

// NewJSClusterRequiredError creates a new JSClusterRequiredErr error: "JetStream clustering support required"
func NewJSClusterRequiredError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSClusterRequiredErr]
}

// NewJSClusterServerNotMemberError creates a new JSClusterServerNotMemberErr error: "server is not a member of the cluster"
func NewJSClusterServerNotMemberError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSClusterServerNotMemberErr]
}

// NewJSClusterTagsError creates a new JSClusterTagsErr error: "tags placement not supported for operation"
func NewJSClusterTagsError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSClusterTagsErr]
}

// NewJSClusterUnSupportFeatureError creates a new JSClusterUnSupportFeatureErr error: "not currently supported in clustered mode"
func NewJSClusterUnSupportFeatureError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSClusterUnSupportFeatureErr]
}

// NewJSConsumerAlreadyExistsError creates a new JSConsumerAlreadyExists error: "consumer already exists"
func NewJSConsumerAlreadyExistsError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerAlreadyExists]
}

// NewJSConsumerBadDurableNameError creates a new JSConsumerBadDurableNameErr error: "durable name can not contain '.', '*', '>'"
func NewJSConsumerBadDurableNameError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerBadDurableNameErr]
}

// NewJSConsumerConfigRequiredError creates a new JSConsumerConfigRequiredErr error: "consumer config required"
func NewJSConsumerConfigRequiredError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerConfigRequiredErr]
}

// NewJSConsumerCreateDurableAndNameMismatchError creates a new JSConsumerCreateDurableAndNameMismatch error: "Consumer Durable and Name have to be equal if both are provided"
func NewJSConsumerCreateDurableAndNameMismatchError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerCreateDurableAndNameMismatch]
}

// NewJSConsumerCreateError creates a new JSConsumerCreateErrF error: "{err}"
func NewJSConsumerCreateError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSConsumerCreateErrF]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSConsumerCreateFilterSubjectMismatchError creates a new JSConsumerCreateFilterSubjectMismatchErr error: "Consumer create request did not match filtered subject from create subject"
func NewJSConsumerCreateFilterSubjectMismatchError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerCreateFilterSubjectMismatchErr]
}

// NewJSConsumerDeliverCycleError creates a new JSConsumerDeliverCycleErr error: "consumer deliver subject forms a cycle"
func NewJSConsumerDeliverCycleError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerDeliverCycleErr]
}

// NewJSConsumerDeliverToWildcardsError creates a new JSConsumerDeliverToWildcardsErr error: "consumer deliver subject has wildcards"
func NewJSConsumerDeliverToWildcardsError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerDeliverToWildcardsErr]
}

// NewJSConsumerDescriptionTooLongError creates a new JSConsumerDescriptionTooLongErrF error: "consumer description is too long, maximum allowed is {max}"
func NewJSConsumerDescriptionTooLongError(max interface{}, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSConsumerDescriptionTooLongErrF]
        args := e.toReplacerArgs([]interface{}{"{max}", max})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSConsumerDirectRequiresEphemeralError creates a new JSConsumerDirectRequiresEphemeralErr error: "consumer direct requires an ephemeral consumer"
func NewJSConsumerDirectRequiresEphemeralError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerDirectRequiresEphemeralErr]
}

// NewJSConsumerDirectRequiresPushError creates a new JSConsumerDirectRequiresPushErr error: "consumer direct requires a push based consumer"
func NewJSConsumerDirectRequiresPushError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerDirectRequiresPushErr]
}

// NewJSConsumerDoesNotExistError creates a new JSConsumerDoesNotExist error: "consumer does not exist"
func NewJSConsumerDoesNotExistError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerDoesNotExist]
}

// NewJSConsumerDuplicateFilterSubjectsError creates a new JSConsumerDuplicateFilterSubjects error: "consumer cannot have both FilterSubject and FilterSubjects specified"
func NewJSConsumerDuplicateFilterSubjectsError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerDuplicateFilterSubjects]
}

// NewJSConsumerDurableNameNotInSubjectError creates a new JSConsumerDurableNameNotInSubjectErr error: "consumer expected to be durable but no durable name set in subject"
func NewJSConsumerDurableNameNotInSubjectError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerDurableNameNotInSubjectErr]
}

// NewJSConsumerDurableNameNotMatchSubjectError creates a new JSConsumerDurableNameNotMatchSubjectErr error: "consumer name in subject does not match durable name in request"
func NewJSConsumerDurableNameNotMatchSubjectError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerDurableNameNotMatchSubjectErr]
}

// NewJSConsumerDurableNameNotSetError creates a new JSConsumerDurableNameNotSetErr error: "consumer expected to be durable but a durable name was not set"
func NewJSConsumerDurableNameNotSetError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerDurableNameNotSetErr]
}

// NewJSConsumerEmptyFilterError creates a new JSConsumerEmptyFilter error: "consumer filter in FilterSubjects cannot be empty"
func NewJSConsumerEmptyFilterError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerEmptyFilter]
}

// NewJSConsumerEmptyGroupNameError creates a new JSConsumerEmptyGroupName error: "Group name cannot be an empty string"
func NewJSConsumerEmptyGroupNameError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerEmptyGroupName]
}

// NewJSConsumerEphemeralWithDurableInSubjectError creates a new JSConsumerEphemeralWithDurableInSubjectErr error: "consumer expected to be ephemeral but detected a durable name set in subject"
func NewJSConsumerEphemeralWithDurableInSubjectError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerEphemeralWithDurableInSubjectErr]
}

// NewJSConsumerEphemeralWithDurableNameError creates a new JSConsumerEphemeralWithDurableNameErr error: "consumer expected to be ephemeral but a durable name was set in request"
func NewJSConsumerEphemeralWithDurableNameError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerEphemeralWithDurableNameErr]
}

// NewJSConsumerExistingActiveError creates a new JSConsumerExistingActiveErr error: "consumer already exists and is still active"
func NewJSConsumerExistingActiveError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerExistingActiveErr]
}

// NewJSConsumerFCRequiresPushError creates a new JSConsumerFCRequiresPushErr error: "consumer flow control requires a push based consumer"
func NewJSConsumerFCRequiresPushError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerFCRequiresPushErr]
}

// NewJSConsumerFilterNotSubsetError creates a new JSConsumerFilterNotSubsetErr error: "consumer filter subject is not a valid subset of the interest subjects"
func NewJSConsumerFilterNotSubsetError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerFilterNotSubsetErr]
}

// NewJSConsumerHBRequiresPushError creates a new JSConsumerHBRequiresPushErr error: "consumer idle heartbeat requires a push based consumer"
func NewJSConsumerHBRequiresPushError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerHBRequiresPushErr]
}

// NewJSConsumerInactiveThresholdExcessError creates a new JSConsumerInactiveThresholdExcess error: "consumer inactive threshold exceeds system limit of {limit}"
func NewJSConsumerInactiveThresholdExcessError(limit interface{}, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSConsumerInactiveThresholdExcess]
        args := e.toReplacerArgs([]interface{}{"{limit}", limit})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSConsumerInvalidDeliverSubjectError creates a new JSConsumerInvalidDeliverSubject error: "invalid push consumer deliver subject"
func NewJSConsumerInvalidDeliverSubjectError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerInvalidDeliverSubject]
}

// NewJSConsumerInvalidGroupNameError creates a new JSConsumerInvalidGroupNameErr error: "Valid priority group name must match A-Z, a-z, 0-9, -_/=)+ and may not exceed 16 characters"
func NewJSConsumerInvalidGroupNameError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerInvalidGroupNameErr]
}

// NewJSConsumerInvalidPolicyError creates a new JSConsumerInvalidPolicyErrF error: "{err}"
func NewJSConsumerInvalidPolicyError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSConsumerInvalidPolicyErrF]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSConsumerInvalidPriorityGroupError creates a new JSConsumerInvalidPriorityGroupErr error: "Provided priority group does not exist for this consumer"
func NewJSConsumerInvalidPriorityGroupError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerInvalidPriorityGroupErr]
}

// NewJSConsumerInvalidSamplingError creates a new JSConsumerInvalidSamplingErrF error: "failed to parse consumer sampling configuration: {err}"
func NewJSConsumerInvalidSamplingError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSConsumerInvalidSamplingErrF]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSConsumerMaxDeliverBackoffError creates a new JSConsumerMaxDeliverBackoffErr error: "max deliver is required to be > length of backoff values"
func NewJSConsumerMaxDeliverBackoffError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerMaxDeliverBackoffErr]
}

// NewJSConsumerMaxPendingAckExcessError creates a new JSConsumerMaxPendingAckExcessErrF error: "consumer max ack pending exceeds system limit of {limit}"
func NewJSConsumerMaxPendingAckExcessError(limit interface{}, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSConsumerMaxPendingAckExcessErrF]
        args := e.toReplacerArgs([]interface{}{"{limit}", limit})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSConsumerMaxPendingAckPolicyRequiredError creates a new JSConsumerMaxPendingAckPolicyRequiredErr error: "consumer requires ack policy for max ack pending"
func NewJSConsumerMaxPendingAckPolicyRequiredError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerMaxPendingAckPolicyRequiredErr]
}

// NewJSConsumerMaxRequestBatchExceededError creates a new JSConsumerMaxRequestBatchExceededF error: "consumer max request batch exceeds server limit of {limit}"
func NewJSConsumerMaxRequestBatchExceededError(limit interface{}, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSConsumerMaxRequestBatchExceededF]
        args := e.toReplacerArgs([]interface{}{"{limit}", limit})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSConsumerMaxRequestBatchNegativeError creates a new JSConsumerMaxRequestBatchNegativeErr error: "consumer max request batch needs to be > 0"
func NewJSConsumerMaxRequestBatchNegativeError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerMaxRequestBatchNegativeErr]
}

// NewJSConsumerMaxRequestExpiresToSmallError creates a new JSConsumerMaxRequestExpiresToSmall error: "consumer max request expires needs to be >= 1ms"
func NewJSConsumerMaxRequestExpiresToSmallError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerMaxRequestExpiresToSmall]
}

// NewJSConsumerMaxWaitingNegativeError creates a new JSConsumerMaxWaitingNegativeErr error: "consumer max waiting needs to be positive"
func NewJSConsumerMaxWaitingNegativeError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerMaxWaitingNegativeErr]
}

// NewJSConsumerMetadataLengthError creates a new JSConsumerMetadataLengthErrF error: "consumer metadata exceeds maximum size of {limit}"
func NewJSConsumerMetadataLengthError(limit interface{}, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSConsumerMetadataLengthErrF]
        args := e.toReplacerArgs([]interface{}{"{limit}", limit})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSConsumerMultipleFiltersNotAllowedError creates a new JSConsumerMultipleFiltersNotAllowed error: "consumer with multiple subject filters cannot use subject based API"
func NewJSConsumerMultipleFiltersNotAllowedError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerMultipleFiltersNotAllowed]
}

// NewJSConsumerNameContainsPathSeparatorsError creates a new JSConsumerNameContainsPathSeparatorsErr error: "Consumer name can not contain path separators"
func NewJSConsumerNameContainsPathSeparatorsError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerNameContainsPathSeparatorsErr]
}

// NewJSConsumerNameExistError creates a new JSConsumerNameExistErr error: "consumer name already in use"
func NewJSConsumerNameExistError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerNameExistErr]
}

// NewJSConsumerNameTooLongError creates a new JSConsumerNameTooLongErrF error: "consumer name is too long, maximum allowed is {max}"
func NewJSConsumerNameTooLongError(max interface{}, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSConsumerNameTooLongErrF]
        args := e.toReplacerArgs([]interface{}{"{max}", max})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSConsumerNotFoundError creates a new JSConsumerNotFoundErr error: "consumer not found"
func NewJSConsumerNotFoundError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerNotFoundErr]
}

// NewJSConsumerOfflineError creates a new JSConsumerOfflineErr error: "consumer is offline"
func NewJSConsumerOfflineError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerOfflineErr]
}

// NewJSConsumerOnMappedError creates a new JSConsumerOnMappedErr error: "consumer direct on a mapped consumer"
func NewJSConsumerOnMappedError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerOnMappedErr]
}

// NewJSConsumerOverlappingSubjectFiltersError creates a new JSConsumerOverlappingSubjectFilters error: "consumer subject filters cannot overlap"
func NewJSConsumerOverlappingSubjectFiltersError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerOverlappingSubjectFilters]
}

// NewJSConsumerPriorityPolicyWithoutGroupError creates a new JSConsumerPriorityPolicyWithoutGroup error: "Setting PriorityPolicy requires at least one PriorityGroup to be set"
func NewJSConsumerPriorityPolicyWithoutGroupError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerPriorityPolicyWithoutGroup]
}

// NewJSConsumerPullNotDurableError creates a new JSConsumerPullNotDurableErr error: "consumer in pull mode requires a durable name"
func NewJSConsumerPullNotDurableError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerPullNotDurableErr]
}

// NewJSConsumerPullRequiresAckError creates a new JSConsumerPullRequiresAckErr error: "consumer in pull mode requires explicit ack policy on workqueue stream"
func NewJSConsumerPullRequiresAckError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerPullRequiresAckErr]
}

// NewJSConsumerPullWithRateLimitError creates a new JSConsumerPullWithRateLimitErr error: "consumer in pull mode can not have rate limit set"
func NewJSConsumerPullWithRateLimitError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerPullWithRateLimitErr]
}

// NewJSConsumerPushMaxWaitingError creates a new JSConsumerPushMaxWaitingErr error: "consumer in push mode can not set max waiting"
func NewJSConsumerPushMaxWaitingError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerPushMaxWaitingErr]
}

// NewJSConsumerReplacementWithDifferentNameError creates a new JSConsumerReplacementWithDifferentNameErr error: "consumer replacement durable config not the same"
func NewJSConsumerReplacementWithDifferentNameError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerReplacementWithDifferentNameErr]
}

// NewJSConsumerReplicasExceedsStreamError creates a new JSConsumerReplicasExceedsStream error: "consumer config replica count exceeds parent stream"
func NewJSConsumerReplicasExceedsStreamError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerReplicasExceedsStream]
}

// NewJSConsumerReplicasShouldMatchStreamError creates a new JSConsumerReplicasShouldMatchStream error: "consumer config replicas must match interest retention stream's replicas"
func NewJSConsumerReplicasShouldMatchStreamError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerReplicasShouldMatchStream]
}

// NewJSConsumerSmallHeartbeatError creates a new JSConsumerSmallHeartbeatErr error: "consumer idle heartbeat needs to be >= 100ms"
func NewJSConsumerSmallHeartbeatError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerSmallHeartbeatErr]
}

// NewJSConsumerStoreFailedError creates a new JSConsumerStoreFailedErrF error: "error creating store for consumer: {err}"
func NewJSConsumerStoreFailedError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSConsumerStoreFailedErrF]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSConsumerWQConsumerNotDeliverAllError creates a new JSConsumerWQConsumerNotDeliverAllErr error: "consumer must be deliver all on workqueue stream"
func NewJSConsumerWQConsumerNotDeliverAllError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerWQConsumerNotDeliverAllErr]
}

// NewJSConsumerWQConsumerNotUniqueError creates a new JSConsumerWQConsumerNotUniqueErr error: "filtered consumer not unique on workqueue stream"
func NewJSConsumerWQConsumerNotUniqueError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerWQConsumerNotUniqueErr]
}

// NewJSConsumerWQMultipleUnfilteredError creates a new JSConsumerWQMultipleUnfilteredErr error: "multiple non-filtered consumers not allowed on workqueue stream"
func NewJSConsumerWQMultipleUnfilteredError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerWQMultipleUnfilteredErr]
}

// NewJSConsumerWQRequiresExplicitAckError creates a new JSConsumerWQRequiresExplicitAckErr error: "workqueue stream requires explicit ack"
func NewJSConsumerWQRequiresExplicitAckError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerWQRequiresExplicitAckErr]
}

// NewJSConsumerWithFlowControlNeedsHeartbeatsError creates a new JSConsumerWithFlowControlNeedsHeartbeats error: "consumer with flow control also needs heartbeats"
func NewJSConsumerWithFlowControlNeedsHeartbeatsError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSConsumerWithFlowControlNeedsHeartbeats]
}

// NewJSInsufficientResourcesError creates a new JSInsufficientResourcesErr error: "insufficient resources"
func NewJSInsufficientResourcesError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSInsufficientResourcesErr]
}

// NewJSInvalidJSONError creates a new JSInvalidJSONErr error: "invalid JSON: {err}"
func NewJSInvalidJSONError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSInvalidJSONErr]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSMaximumConsumersLimitError creates a new JSMaximumConsumersLimitErr error: "maximum consumers limit reached"
func NewJSMaximumConsumersLimitError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSMaximumConsumersLimitErr]
}

// NewJSMaximumStreamsLimitError creates a new JSMaximumStreamsLimitErr error: "maximum number of streams reached"
func NewJSMaximumStreamsLimitError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSMaximumStreamsLimitErr]
}

// NewJSMemoryResourcesExceededError creates a new JSMemoryResourcesExceededErr error: "insufficient memory resources available"
func NewJSMemoryResourcesExceededError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSMemoryResourcesExceededErr]
}

// NewJSMessageTTLInvalidError creates a new JSMessageTTLInvalidErr error: "invalid per-message TTL"
func NewJSMessageTTLInvalidError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSMessageTTLInvalidErr]
}

// NewJSMirrorConsumerSetupFailedError creates a new JSMirrorConsumerSetupFailedErrF error: "{err}"
func NewJSMirrorConsumerSetupFailedError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSMirrorConsumerSetupFailedErrF]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSMirrorInvalidStreamNameError creates a new JSMirrorInvalidStreamName error: "mirrored stream name is invalid"
func NewJSMirrorInvalidStreamNameError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSMirrorInvalidStreamName]
}

// NewJSMirrorInvalidSubjectFilterError creates a new JSMirrorInvalidSubjectFilter error: "mirror transform source: {err}"
func NewJSMirrorInvalidSubjectFilterError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSMirrorInvalidSubjectFilter]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSMirrorInvalidTransformDestinationError creates a new JSMirrorInvalidTransformDestination error: "mirror transform: {err}"
func NewJSMirrorInvalidTransformDestinationError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSMirrorInvalidTransformDestination]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSMirrorMaxMessageSizeTooBigError creates a new JSMirrorMaxMessageSizeTooBigErr error: "stream mirror must have max message size >= source"
func NewJSMirrorMaxMessageSizeTooBigError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSMirrorMaxMessageSizeTooBigErr]
}

// NewJSMirrorMultipleFiltersNotAllowedError creates a new JSMirrorMultipleFiltersNotAllowed error: "mirror with multiple subject transforms cannot also have a single subject filter"
func NewJSMirrorMultipleFiltersNotAllowedError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSMirrorMultipleFiltersNotAllowed]
}

// NewJSMirrorOverlappingSubjectFiltersError creates a new JSMirrorOverlappingSubjectFilters error: "mirror subject filters can not overlap"
func NewJSMirrorOverlappingSubjectFiltersError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSMirrorOverlappingSubjectFilters]
}

// NewJSMirrorWithFirstSeqError creates a new JSMirrorWithFirstSeqErr error: "stream mirrors can not have first sequence configured"
func NewJSMirrorWithFirstSeqError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSMirrorWithFirstSeqErr]
}

// NewJSMirrorWithSourcesError creates a new JSMirrorWithSourcesErr error: "stream mirrors can not also contain other sources"
func NewJSMirrorWithSourcesError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSMirrorWithSourcesErr]
}

// NewJSMirrorWithStartSeqAndTimeError creates a new JSMirrorWithStartSeqAndTimeErr error: "stream mirrors can not have both start seq and start time configured"
func NewJSMirrorWithStartSeqAndTimeError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSMirrorWithStartSeqAndTimeErr]
}

// NewJSMirrorWithSubjectFiltersError creates a new JSMirrorWithSubjectFiltersErr error: "stream mirrors can not contain filtered subjects"
func NewJSMirrorWithSubjectFiltersError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSMirrorWithSubjectFiltersErr]
}

// NewJSMirrorWithSubjectsError creates a new JSMirrorWithSubjectsErr error: "stream mirrors can not contain subjects"
func NewJSMirrorWithSubjectsError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSMirrorWithSubjectsErr]
}

// NewJSNoAccountError creates a new JSNoAccountErr error: "account not found"
func NewJSNoAccountError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSNoAccountErr]
}

// NewJSNoLimitsError creates a new JSNoLimitsErr error: "no JetStream default or applicable tiered limit present"
func NewJSNoLimitsError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSNoLimitsErr]
}

// NewJSNoMessageFoundError creates a new JSNoMessageFoundErr error: "no message found"
func NewJSNoMessageFoundError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSNoMessageFoundErr]
}

// NewJSNotEmptyRequestError creates a new JSNotEmptyRequestErr error: "expected an empty request payload"
func NewJSNotEmptyRequestError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSNotEmptyRequestErr]
}

// NewJSNotEnabledError creates a new JSNotEnabledErr error: "JetStream not enabled"
func NewJSNotEnabledError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSNotEnabledErr]
}

// NewJSNotEnabledForAccountError creates a new JSNotEnabledForAccountErr error: "JetStream not enabled for account"
func NewJSNotEnabledForAccountError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSNotEnabledForAccountErr]
}

// NewJSPedanticError creates a new JSPedanticErrF error: "pedantic mode: {err}"
func NewJSPedanticError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSPedanticErrF]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSPeerRemapError creates a new JSPeerRemapErr error: "peer remap failed"
func NewJSPeerRemapError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSPeerRemapErr]
}

// NewJSRaftGeneralError creates a new JSRaftGeneralErrF error: "{err}"
func NewJSRaftGeneralError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSRaftGeneralErrF]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSReplicasCountCannotBeNegativeError creates a new JSReplicasCountCannotBeNegative error: "replicas count cannot be negative"
func NewJSReplicasCountCannotBeNegativeError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSReplicasCountCannotBeNegative]
}

// NewJSRestoreSubscribeFailedError creates a new JSRestoreSubscribeFailedErrF error: "JetStream unable to subscribe to restore snapshot {subject}: {err}"
func NewJSRestoreSubscribeFailedError(err error, subject interface{}, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSRestoreSubscribeFailedErrF]
        args := e.toReplacerArgs([]interface{}{"{err}", err, "{subject}", subject})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSSequenceNotFoundError creates a new JSSequenceNotFoundErrF error: "sequence {seq} not found"
func NewJSSequenceNotFoundError(seq uint64, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSSequenceNotFoundErrF]
        args := e.toReplacerArgs([]interface{}{"{seq}", seq})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSSnapshotDeliverSubjectInvalidError creates a new JSSnapshotDeliverSubjectInvalidErr error: "deliver subject not valid"
func NewJSSnapshotDeliverSubjectInvalidError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSSnapshotDeliverSubjectInvalidErr]
}

// NewJSSourceConsumerSetupFailedError creates a new JSSourceConsumerSetupFailedErrF error: "{err}"
func NewJSSourceConsumerSetupFailedError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSSourceConsumerSetupFailedErrF]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSSourceDuplicateDetectedError creates a new JSSourceDuplicateDetected error: "duplicate source configuration detected"
func NewJSSourceDuplicateDetectedError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSSourceDuplicateDetected]
}

// NewJSSourceInvalidStreamNameError creates a new JSSourceInvalidStreamName error: "sourced stream name is invalid"
func NewJSSourceInvalidStreamNameError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSSourceInvalidStreamName]
}

// NewJSSourceInvalidSubjectFilterError creates a new JSSourceInvalidSubjectFilter error: "source transform source: {err}"
func NewJSSourceInvalidSubjectFilterError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSSourceInvalidSubjectFilter]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSSourceInvalidTransformDestinationError creates a new JSSourceInvalidTransformDestination error: "source transform: {err}"
func NewJSSourceInvalidTransformDestinationError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSSourceInvalidTransformDestination]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSSourceMaxMessageSizeTooBigError creates a new JSSourceMaxMessageSizeTooBigErr error: "stream source must have max message size >= target"
func NewJSSourceMaxMessageSizeTooBigError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSSourceMaxMessageSizeTooBigErr]
}

// NewJSSourceMultipleFiltersNotAllowedError creates a new JSSourceMultipleFiltersNotAllowed error: "source with multiple subject transforms cannot also have a single subject filter"
func NewJSSourceMultipleFiltersNotAllowedError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSSourceMultipleFiltersNotAllowed]
}

// NewJSSourceOverlappingSubjectFiltersError creates a new JSSourceOverlappingSubjectFilters error: "source filters can not overlap"
func NewJSSourceOverlappingSubjectFiltersError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSSourceOverlappingSubjectFilters]
}

// NewJSStorageResourcesExceededError creates a new JSStorageResourcesExceededErr error: "insufficient storage resources available"
func NewJSStorageResourcesExceededError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSStorageResourcesExceededErr]
}

// NewJSStreamAssignmentError creates a new JSStreamAssignmentErrF error: "{err}"
func NewJSStreamAssignmentError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSStreamAssignmentErrF]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSStreamCreateError creates a new JSStreamCreateErrF error: "{err}"
func NewJSStreamCreateError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSStreamCreateErrF]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSStreamDeleteError creates a new JSStreamDeleteErrF error: "{err}"
func NewJSStreamDeleteError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSStreamDeleteErrF]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSStreamDuplicateMessageConflictError creates a new JSStreamDuplicateMessageConflict error: "duplicate message id is in process"
func NewJSStreamDuplicateMessageConflictError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSStreamDuplicateMessageConflict]
}

// NewJSStreamExpectedLastSeqPerSubjectNotReadyError creates a new JSStreamExpectedLastSeqPerSubjectNotReady error: "expected last sequence per subject temporarily unavailable"
func NewJSStreamExpectedLastSeqPerSubjectNotReadyError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSStreamExpectedLastSeqPerSubjectNotReady]
}

// NewJSStreamExternalApiOverlapError creates a new JSStreamExternalApiOverlapErrF error: "stream external api prefix {prefix} must not overlap with {subject}"
func NewJSStreamExternalApiOverlapError(prefix interface{}, subject interface{}, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSStreamExternalApiOverlapErrF]
        args := e.toReplacerArgs([]interface{}{"{prefix}", prefix, "{subject}", subject})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSStreamExternalDelPrefixOverlapsError creates a new JSStreamExternalDelPrefixOverlapsErrF error: "stream external delivery prefix {prefix} overlaps with stream subject {subject}"
func NewJSStreamExternalDelPrefixOverlapsError(prefix interface{}, subject interface{}, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSStreamExternalDelPrefixOverlapsErrF]
        args := e.toReplacerArgs([]interface{}{"{prefix}", prefix, "{subject}", subject})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSStreamGeneralError creates a new JSStreamGeneralErrorF error: "{err}"
func NewJSStreamGeneralError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSStreamGeneralErrorF]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSStreamHeaderExceedsMaximumError creates a new JSStreamHeaderExceedsMaximumErr error: "header size exceeds maximum allowed of 64k"
func NewJSStreamHeaderExceedsMaximumError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSStreamHeaderExceedsMaximumErr]
}

// NewJSStreamInfoMaxSubjectsError creates a new JSStreamInfoMaxSubjectsErr error: "subject details would exceed maximum allowed"
func NewJSStreamInfoMaxSubjectsError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSStreamInfoMaxSubjectsErr]
}

// NewJSStreamInvalidConfigError creates a new JSStreamInvalidConfigF error: "{err}"
func NewJSStreamInvalidConfigError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSStreamInvalidConfigF]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSStreamInvalidError creates a new JSStreamInvalidErr error: "stream not valid"
func NewJSStreamInvalidError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSStreamInvalidErr]
}

// NewJSStreamInvalidExternalDeliverySubjError creates a new JSStreamInvalidExternalDeliverySubjErrF error: "stream external delivery prefix {prefix} must not contain wildcards"
func NewJSStreamInvalidExternalDeliverySubjError(prefix interface{}, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSStreamInvalidExternalDeliverySubjErrF]
        args := e.toReplacerArgs([]interface{}{"{prefix}", prefix})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSStreamLimitsError creates a new JSStreamLimitsErrF error: "{err}"
func NewJSStreamLimitsError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSStreamLimitsErrF]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSStreamMaxBytesRequiredError creates a new JSStreamMaxBytesRequired error: "account requires a stream config to have max bytes set"
func NewJSStreamMaxBytesRequiredError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSStreamMaxBytesRequired]
}

// NewJSStreamMaxStreamBytesExceededError creates a new JSStreamMaxStreamBytesExceeded error: "stream max bytes exceeds account limit max stream bytes"
func NewJSStreamMaxStreamBytesExceededError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSStreamMaxStreamBytesExceeded]
}

// NewJSStreamMessageExceedsMaximumError creates a new JSStreamMessageExceedsMaximumErr error: "message size exceeds maximum allowed"
func NewJSStreamMessageExceedsMaximumError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSStreamMessageExceedsMaximumErr]
}

// NewJSStreamMirrorNotUpdatableError creates a new JSStreamMirrorNotUpdatableErr error: "stream mirror configuration can not be updated"
func NewJSStreamMirrorNotUpdatableError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSStreamMirrorNotUpdatableErr]
}

// NewJSStreamMismatchError creates a new JSStreamMismatchErr error: "stream name in subject does not match request"
func NewJSStreamMismatchError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSStreamMismatchErr]
}

// NewJSStreamMoveAndScaleError creates a new JSStreamMoveAndScaleErr error: "can not move and scale a stream in a single update"
func NewJSStreamMoveAndScaleError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSStreamMoveAndScaleErr]
}

// NewJSStreamMoveInProgressError creates a new JSStreamMoveInProgressF error: "stream move already in progress: {msg}"
func NewJSStreamMoveInProgressError(msg interface{}, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSStreamMoveInProgressF]
        args := e.toReplacerArgs([]interface{}{"{msg}", msg})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSStreamMoveNotInProgressError creates a new JSStreamMoveNotInProgress error: "stream move not in progress"
func NewJSStreamMoveNotInProgressError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSStreamMoveNotInProgress]
}

// NewJSStreamMsgDeleteFailedError creates a new JSStreamMsgDeleteFailedF error: "{err}"
func NewJSStreamMsgDeleteFailedError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSStreamMsgDeleteFailedF]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSStreamNameContainsPathSeparatorsError creates a new JSStreamNameContainsPathSeparatorsErr error: "Stream name can not contain path separators"
func NewJSStreamNameContainsPathSeparatorsError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSStreamNameContainsPathSeparatorsErr]
}

// NewJSStreamNameExistError creates a new JSStreamNameExistErr error: "stream name already in use with a different configuration"
func NewJSStreamNameExistError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSStreamNameExistErr]
}

// NewJSStreamNameExistRestoreFailedError creates a new JSStreamNameExistRestoreFailedErr error: "stream name already in use, cannot restore"
func NewJSStreamNameExistRestoreFailedError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSStreamNameExistRestoreFailedErr]
}

// NewJSStreamNotFoundError creates a new JSStreamNotFoundErr error: "stream not found"
func NewJSStreamNotFoundError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSStreamNotFoundErr]
}

// NewJSStreamNotMatchError creates a new JSStreamNotMatchErr error: "expected stream does not match"
func NewJSStreamNotMatchError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSStreamNotMatchErr]
}

// NewJSStreamOfflineError creates a new JSStreamOfflineErr error: "stream is offline"
func NewJSStreamOfflineError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSStreamOfflineErr]
}

// NewJSStreamPurgeFailedError creates a new JSStreamPurgeFailedF error: "{err}"
func NewJSStreamPurgeFailedError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSStreamPurgeFailedF]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSStreamReplicasNotSupportedError creates a new JSStreamReplicasNotSupportedErr error: "replicas > 1 not supported in non-clustered mode"
func NewJSStreamReplicasNotSupportedError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSStreamReplicasNotSupportedErr]
}

// NewJSStreamReplicasNotUpdatableError creates a new JSStreamReplicasNotUpdatableErr error: "Replicas configuration can not be updated"
func NewJSStreamReplicasNotUpdatableError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSStreamReplicasNotUpdatableErr]
}

// NewJSStreamRestoreError creates a new JSStreamRestoreErrF error: "restore failed: {err}"
func NewJSStreamRestoreError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSStreamRestoreErrF]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSStreamRollupFailedError creates a new JSStreamRollupFailedF error: "{err}"
func NewJSStreamRollupFailedError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSStreamRollupFailedF]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSStreamSealedError creates a new JSStreamSealedErr error: "invalid operation on sealed stream"
func NewJSStreamSealedError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSStreamSealedErr]
}

// NewJSStreamSequenceNotMatchError creates a new JSStreamSequenceNotMatchErr error: "expected stream sequence does not match"
func NewJSStreamSequenceNotMatchError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSStreamSequenceNotMatchErr]
}

// NewJSStreamSnapshotError creates a new JSStreamSnapshotErrF error: "snapshot failed: {err}"
func NewJSStreamSnapshotError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSStreamSnapshotErrF]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSStreamStoreFailedError creates a new JSStreamStoreFailedF error: "{err}"
func NewJSStreamStoreFailedError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSStreamStoreFailedF]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSStreamSubjectOverlapError creates a new JSStreamSubjectOverlapErr error: "subjects overlap with an existing stream"
func NewJSStreamSubjectOverlapError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSStreamSubjectOverlapErr]
}

// NewJSStreamTemplateCreateError creates a new JSStreamTemplateCreateErrF error: "{err}"
func NewJSStreamTemplateCreateError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSStreamTemplateCreateErrF]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSStreamTemplateDeleteError creates a new JSStreamTemplateDeleteErrF error: "{err}"
func NewJSStreamTemplateDeleteError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSStreamTemplateDeleteErrF]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSStreamTemplateNotFoundError creates a new JSStreamTemplateNotFoundErr error: "template not found"
func NewJSStreamTemplateNotFoundError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSStreamTemplateNotFoundErr]
}

// NewJSStreamTransformInvalidDestinationError creates a new JSStreamTransformInvalidDestination error: "stream transform: {err}"
func NewJSStreamTransformInvalidDestinationError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSStreamTransformInvalidDestination]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSStreamTransformInvalidSourceError creates a new JSStreamTransformInvalidSource error: "stream transform source: {err}"
func NewJSStreamTransformInvalidSourceError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSStreamTransformInvalidSource]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSStreamUpdateError creates a new JSStreamUpdateErrF error: "{err}"
func NewJSStreamUpdateError(err error, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSStreamUpdateErrF]
        args := e.toReplacerArgs([]interface{}{"{err}", err})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSStreamWrongLastMsgIDError creates a new JSStreamWrongLastMsgIDErrF error: "wrong last msg ID: {id}"
func NewJSStreamWrongLastMsgIDError(id interface{}, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSStreamWrongLastMsgIDErrF]
        args := e.toReplacerArgs([]interface{}{"{id}", id})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSStreamWrongLastSequenceConstantError creates a new JSStreamWrongLastSequenceConstantErr error: "wrong last sequence"
func NewJSStreamWrongLastSequenceConstantError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSStreamWrongLastSequenceConstantErr]
}

// NewJSStreamWrongLastSequenceError creates a new JSStreamWrongLastSequenceErrF error: "wrong last sequence: {seq}"
func NewJSStreamWrongLastSequenceError(seq uint64, opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        e := ApiErrors[JSStreamWrongLastSequenceErrF]
        args := e.toReplacerArgs([]interface{}{"{seq}", seq})
        return &ApiError{
                Code:        e.Code,
                ErrCode:     e.ErrCode,
                Description: strings.NewReplacer(args...).Replace(e.Description),
        }
}

// NewJSTempStorageFailedError creates a new JSTempStorageFailedErr error: "JetStream unable to open temp storage for restore"
func NewJSTempStorageFailedError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSTempStorageFailedErr]
}

// NewJSTemplateNameNotMatchSubjectError creates a new JSTemplateNameNotMatchSubjectErr error: "template name in subject does not match request"
func NewJSTemplateNameNotMatchSubjectError(opts ...ErrorOption) *ApiError {
        eopts := parseOpts(opts)
        if ae, ok := eopts.err.(*ApiError); ok {
                return ae
        }

        return ApiErrors[JSTemplateNameNotMatchSubjectErr]
}

nats-io / nats-server / 12730529914

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous