CreateConnector builds a connector from the supplied configuration.

NewConnectorStatsHolder creates an empty stats holder, and initializes the request time histogram.

NewHistogram returns a new Histogram with a maximum of n bins.

NewJetStream2KafkaConnector create a new stan to kafka.

NewKafka2JetStreamConnector create a new Kafka to JetStream connector.

NewKafka2NATSConnector create a new Kafka to NATS connector.

NewKafka2StanConnector create a new Kafka to STAN connector.

NewNATS2KafkaConnector create a nats to MQ connector.

NewNATSKafkaBridge creates a new account server with a default logger.

NewStan2KafkaConnector create a new stan to kafka.

HTTP endpoints.

HTTP endpoints.

HTTP endpoints.

Version specifies the command version.

Bin holds a float64 value and count.

BridgeConnector is the base type used for connectors so that they can share code The config, bridge and stats are all fixed at creation, so no lock is required on the connector at this level.

BridgeStats wraps the current status of the bridge and all of its connectors.

ConnectorStats captures the statistics for a single connector times are in nanoseconds, use a holder to get the protection of a lock and to fill in the quantiles.

ConnectorStatsHolder provides a lock and histogram for a connector to updated it's stats.

Flags defines the various flags you can call the account server with.

Histogram stores N bins using the streaming approximate histogram approach The histogram is not thread safe.

JetStream2KafkaConnector connects a JetStream stream to Kafka.

Kafka2JetStreamConnector connects Kafka topic to JetStream.

Kafka2NATSConnector connects Kafka topic to a NATS subject.

Kafka2StanConnector connects Kafka topic to a nats streaming channel.

NATS2KafkaConnector connects a NATS subject to a Kafka topic.

NATSKafkaBridge is the core structure for the server.

Stan2KafkaConnector connects a STAN channel to Kafka.

Connector is the abstraction for all of the bridge connector types.

NATSCallback used by conn-nats connectors in an conn library callback The lock will be held by the caller!.

ShutdownCallback is returned when setting up a callback or polling so the connector can shut it down.