package
1.0.1
Repository: https://github.com/nelio2k/goxdcr.git
Documentation: pkg.go.dev

# Packages

No description provided by the author

# Functions

there is no lock on genericPipeline.asyncEventListenerMap and care must be taken to avoid concurrency issues As of now, this method is called by xdcr_factory right after pipeline is constructed and async listeners are registered on parts This is the only time when genericPipeline.asyncEventListenerMap is initialized/modified, when concurrent access is not possible.
No description provided by the author
No description provided by the author
Used for testing only.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author

# Constants

No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author

# Variables

No description provided by the author
No description provided by the author
In certain scenarios, e.g., incorrect bucket password, a large number of parts may return error when starting.
No description provided by the author
temporary custom settings that need to be cleared after pipeline update.

# Structs

GenericPipeline is the generic implementation of a data processing pipeline The assumption here is all the processing steps are self-connected, soonce incoming nozzle is open, it will propel the data through allprocessing steps.
No description provided by the author
No description provided by the author
The pipeline events mgr's job is to handle the exporting of events and also remember the user's preference on dismissing events.
No description provided by the author

# Interfaces

No description provided by the author
No description provided by the author

# Type aliases

No description provided by the author
No description provided by the author
the function constructs update settings for connectors of the pipeline.
the function constructs start settings for parts of the pipeline.
the function constructs update settings for parts of the pipeline.
No description provided by the author
No description provided by the author
No description provided by the author
the function constructs start settings for parts of the pipeline.
No description provided by the author