Versions in this module Expand all Collapse all v2 v2.0.0 Sep 28, 2021 Changes in this version + type NATSPipe struct + CMQ *cmq.CMQ + Logger *zap.Logger + NATS *cmq.CMQ + Tracer trace.Tracer + func (p *NATSPipe) Pipe(topic, group string) + type Pipe interface + Pipe func(topic, group string) + func NewNATS(c *cmq.CMQ, n *cmq.CMQ, logger *zap.Logger, tracer trace.Tracer) Pipe + func NewSTAN(c *cmq.CMQ, s *streaming.Streaming, logger *zap.Logger, tracer trace.Tracer) Pipe + type Piped struct + FailedMessages prometheus.Counter + PipedMessages prometheus.Counter + func NewPiped(name string) Piped + type STANPipe struct + CMQ *cmq.CMQ + Logger *zap.Logger + Streaming *streaming.Streaming + Tracer trace.Tracer + func (p *STANPipe) Pipe(topic, group string) Other modules containing this package github.com/snapp-incubator/stan-js-replicator
Go to main page