The highest tagged major version is
v2 .
Discover Packages
github.com/snapp-incubator/stan-js-replicator
internal
pipe
package
Version:
v1.3.1
Opens a new window with list of versions in this module.
Published: Sep 22, 2021
License: GPL-3.0
Opens a new window with license information.
Imports: 13
Opens a new window with list of imports.
Imported by: 0
Opens a new window with list of known importers.
Documentation Source Files Index Constants Variables Functions Types type Pipe type Piped New(c, s, logger, tracer) (p) Pipe(topic) NewPiped(name)
Documentation
¶
New create pipe to pipe data from streaming to jetstream.
you can use a single pipe instance for mutiple topics.
Pipe start piping messages from streaming to jetstream based on given topic.
its subscription on streaming isn't durable and it always start from 1 second behind.
the reason here is to reduce load on the streaming server as much as possible.
Piped contains metrics to meter the number of piped messages.
NewPiped creates piped metrics based on topic name with const labels.
nolint: funlen
Source Files
¶
Click to show internal directories.
Click to hide internal directories.