package
1.3.2
Repository: https://github.com/numaproj/numaflow.git
Documentation: pkg.go.dev

# Packages

No description provided by the author

# Functions

NewClientPool returns a new pool of NATS clients of the given size.
NewNATSClient Create a new NATS client.
NewTestClient creates a new NATS client for testing only use this for testing.
JetStreamClient is used to get a testing JetStream client instance.
WithClientPoolSize sets the size of the NATS client pool.

# Structs

Client is a client for NATS server which be shared by multiple connections (reader, writer, kv, buffer management, etc.).
ClientPool is a pool of NATS clients used on at the initial create connection phase.
Options for NATS client pool.

# Type aliases

Option is a function on the options for a NATS client pool.