dcp

Dec 14, 2023

Changes in this version

type Dcp

+ GetVersion func() *couchbase.Version

Sep 27, 2023

Changes in this version

type Dcp

+ func NewDcpWithLogger(cfg any, listener models.Listener, logrus *logrus.Logger) (Dcp, error)

Jul 17, 2023

Changes in this version

type Dcp

+ SetEventHandler func(handler models.EventHandler)

Jul 11, 2023

Changes in this version

+ type Dcp interface

+ Close func()

+ Commit func()

+ GetConfig func() *config.Dcp

+ SetMetadata func(metadata metadata.Metadata)

+ SetMetricCollectors func(collectors ...prometheus.Collector)

+ Start func()

+ WaitUntilReady func() chan struct{}

+ func NewDcp(cfg any, listener models.Listener) (Dcp, error)

+ func NewDcpWithLoggers(cfg any, listener models.Listener, infoLogger logger.Logger, ...) (Dcp, error)