Categorygithub.com/snapp-incubator/stan-js-replicator/v2internalpipe
package
2.0.0
Repository: https://github.com/snapp-incubator/stan-js-replicator.git
Documentation: pkg.go.dev
Overview
Versions
3
Dependencies
13
Dependents
1
Files
177 SLOC

# Functions

New create pipe to pipe data from nats to jetstream.
NewPiped creates piped metrics based on topic name with const labels.
New create pipe to pipe data from streaming to jetstream.

# Structs

No description provided by the author
Piped contains metrics to meter the number of piped messages.
No description provided by the author

# Interfaces

Pipe interface pipes data from input to output.