IsNatsErr determines if a error matches ID, if multiple IDs are given if the error matches any of these the function will be true.

IsNatsError checks if err is a ApiErr matching code.

IsNatsSchemaType determines if a schema type is a valid NATS type.

NewMessage creates a new instance of the structure matching schema.

ParseAndValidateMessage parses the data using ParseMessage() and validates it against the detected schema.

ParseMessage parses a typed message m and returns event as for example *api.ConsumerAckMetric, all unknown event schemas will be of type *UnknownMessage.

RenderEvent renders an event in specific format.

Schema returns the JSON schema for a NATS specific Schema type like io.nats.jetstream.advisory.v1.api_audit.

SchemaFileForType determines what file on the file system to load for a particular schema type.

SchemaForWellKnownRequestSubject searches well known subjects, like the JetStream API, and return the schema if known.

SchemaSearch searches all known schemas using a regular expression f.

SchemaTypeForMessage retrieves the schema token from a typed message byte stream it does this by doing a small JSON unmarshal and is probably not the fastest.

SchemaTypeForWellKnownRequestSubject searches well known subjects, like the JetStream API, and return a schema type that match requests made to it.

SchemaURL parses a typed message m and determines a http address for the JSON schema describing it rooted in SchemasRepo.

SchemaURLForType determines the path to the JSON Schema document describing a typed message given a token like io.nats.jetstream.metric.v1.consumer_ack.

SubjectIsSubsetMatch tests if a subject matches a standard nats wildcard.

ToCloudEventV1 turns a NATS Event into a version 1.0 Cloud Event.

ApplicationCloudEventV1Format renders as a ApplicationCloudEventV1Format v1.

ApplicationJSONFormat renders as indented JSON.

ErrPrefix is the ERR prefix response.

also update wellKnownSubjectSchemas.

Subjects used by the JetStream API.

Subjects used by the JetStream API.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

Subjects used by the JetStream API.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

JSExpectedLastMsgId only stores the message if previous Nats-Msg-Id header value matches this.

JSExpectedLastSeq only store the message if stream last sequence matched.

JSExpectedLastSubjSeq only stores the message if last sequence for this subject matched.

JSExpectedStream only store the message in this stream.

JSMessageTTL sets a TTL per message.

Subjects used by the JetStream API.

Subjects used by the JetStream API.

Subjects used by the JetStream API.

also update wellKnownSubjectSchemas.

Subjects used by the JetStream API.

JSMsgId used for tracking duplicates.

JSRollup is a header indicating the message being sent should be stored and all past messags should be discarded the value can be either `all` or `sub`.

JSRollupAll is the value for JSRollup header to replace the entire stream.

JSRollupSubject is the value for JSRollup header to replace the a single subject.

OK response.

also update wellKnownSubjectSchemas.

also update wellKnownSubjectSchemas.

TextCompactFormat renders a single line view of an event.

TextExtendedFormat renders a multi line full view of an event.

SchemasRepo is the repository holding NATS Schemas.

ClusterInfo shows information about the underlying set of servers that make up the stream or consumer.

ConsumerConfig is the configuration for a JetStream consumes NATS Schema Type io.nats.jetstream.api.v1.consumer_configuration.

ConsumerInfo reports the current state of a consumer.

ConsumerNakOptions is for optional NAK parameters, e.g.

ExternalStream allows you to qualify access to a stream source in another account.

JetStreamAccountStats returns current statistics about the account's JetStream usage.

io.nats.jetstream.api.v1.account_info_response.

io.nats.jetstream.api.v1.account_purge_response.

io.nats.jetstream.api.v1.consumer_create_request.

io.nats.jetstream.api.v1.consumer_create_response.

io.nats.jetstream.api.v1.consumer_delete_response.

JSApiConsumerGetNextRequest is for getting next messages for pull based consumers NATS Schema Type io.nats.jetstream.api.v1.consumer_getnext_request.

io.nats.jetstream.api.v1.consumer_info_response.

io.nats.jetstream.api.v1.consumer_leader_stepdown_request.

io.nats.jetstream.api.v1.consumer_leader_stepdown_response.

io.nats.jetstream.api.v1.consumer_list_request.

io.nats.jetstream.api.v1.consumer_list_response.

io.nats.jetstream.api.v1.consumer_names_request.

io.nats.jetstream.api.v1.consumer_names_response.

io.nats.jetstream.api.v1.consumer_pause_request.

io.nats.jetstream.api.v1.consumer_pause_response.

io.nats.jetstream.api.v1.consumer_unpin_response.

io.nats.jetstream.api.v1.consumer_unpin_response.

io.nats.jetstream.api.v1.meta_leader_stepdown_request.

io.nats.jetstream.api.v1.meta_leader_stepdown_response.

io.nats.jetstream.api.v1.meta_server_remove_request.

io.nats.jetstream.api.v1.meta_server_remove_response.

io.nats.jetstream.api.v1.stream_msg_delete_request.

io.nats.jetstream.api.v1.stream_msg_delete_response.

io.nats.jetstream.api.v1.stream_msg_get_request.

io.nats.jetstream.api.v1.stream_msg_get_response.

io.nats.jetstream.api.v1.stream_create_request.

io.nats.jetstream.api.v1.stream_create_response.

io.nats.jetstream.api.v1.stream_delete_response.

io.nats.jetstream.api.v1.stream_info_request.

io.nats.jetstream.api.v1.stream_info_response.

io.nats.jetstream.api.v1.stream_leader_stepdown_request.

io.nats.jetstream.api.v1.stream_leader_stepdown_response.

io.nats.jetstream.api.v1.stream_list_request.

io.nats.jetstream.api.v1.stream_list_response.

io.nats.jetstream.api.v1.stream_names_request.

io.nats.jetstream.api.v1.stream_names_response.

JSApiStreamPurgeRequest is optional request information to the purge API.

io.nats.jetstream.api.v1.stream_purge_response.

io.nats.jetstream.api.v1.stream_remove_peer_request.

io.nats.jetstream.api.v1.stream_remove_peer_response.

io.nats.jetstream.api.v1.stream_restore_request.

io.nats.jetstream.api.v1.stream_restore_response.

io.nats.jetstream.api.v1.stream_snapshot_request.

io.nats.jetstream.api.v1.stream_snapshot_response.

io.nats.jetstream.api.v1.stream_template_create_request.

io.nats.jetstream.api.v1.stream_template_create_response.

io.nats.jetstream.api.v1.stream_template_delete_response.

io.nats.jetstream.api.v1.stream_template_info_response.

io.nats.jetstream.api.v1.stream_template_names_request.

io.nats.jetstream.api.v1.stream_template_names_response.

io.nats.jetstream.api.v1.stream_update_response.

io.nats.jetstream.api.v1.pub_ack_response.

LostStreamData indicates msgs that have been lost during file checks and recover due to corruption.

PeerInfo shows information about all the peers in the cluster that are supporting the stream or consumer.

Placement describes stream placement requirements for a stream or leader.

PriorityGroupState is the state of a consumer group.

PubAck is the detail you get back from a publish to a stream that was successful.

RePublish allows a source subject to be mapped to a destination subject for republishing.

SequenceInfo is the consumer and stream sequence that uniquely identify a message.

StreamConfig is the configuration for a JetStream Stream Template NATS Schema Type io.nats.jetstream.api.v1.stream_configuration.

StreamConsumerLimits describes limits and defaults for consumers created on a stream.

StreamSource dictates how streams can source from other streams.

StreamSourceInfo shows information about an upstream stream source.

StreamTemplateConfig is the configuration for a JetStream Stream Template NATS Schema Type io.nats.jetstream.api.v1.stream_template_configuration.

StreamTemplateInfo.

SubjectTransformConfig is for applying a subject transform (to matching messages) before doing anything else when a new message is received.

Event is a generic NATS Event capable of being converted to CloudEvents format.

StructValidator is used to validate API structures.

PriorityPolicy determines policy for selecting messages based on priority.

RenderFormat indicates the format to render templates in.

UnknownMessage is a type returned when parsing an unknown type of event.