Documentation ¶
Overview ¶
Package stream provides streaming clients used by `Consume` and `Publish` methods
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NatsFromConfig ¶
NatsFromConfig returns a nats stream from the given config
Types ¶
type Chan ¶
type Chan [2]chan interface{}
Chan is a channel based streaming clients Useful for tests or in memory applications
type NatsConfig ¶
type NatsConfig struct { Endpoint string `mapstructure:"address"` // Endpoint of the nats server Cluster string `mapstructure:"clusterID"` // CluserID of the nats cluster TLSInsecure bool `mapstructure:"tls-insecure"` // Whether to verify TLS certificates TLSRootCACertificate string `mapstructure:"tls-root-ca-cert"` // The root CA certificate used to validate the TLS certificate EnableTLS bool `mapstructure:"enable-tls"` // Enable TLS AuthUsername string `mapstructure:"username"` // Username for authentication AuthPassword string `mapstructure:"password"` // Password for authentication }
NatsConfig is the configuration needed for a NATS event stream
Click to show internal directories.
Click to hide internal directories.