GetBackendJetStreamTypes gets the original event type and the consumer name for all the subscriptions and this slice is set as the backend specific status for JetStream.

GetCleanEventTypes returns a list of clean eventTypes from the unique types in the subscription.

NewSubscriptionSubjectIdentifier returns a new SubscriptionSubjectIdentifier instance.

ConnectionBuilder helps in establishing a connection to NATS.

SubscriptionSubjectIdentifier is used to uniquely identify a Subscription subject.

TestEnvironment provides mocked resources for tests.

go:generate go run github.com/vektra/mockery/v2 --name Backend.

ConnectionInterface is a contract for a NATS connection object.