Code generated by mockery v1.0.0.

CreateReplication create the replication specification in metadata store and start the replication pipeline.

decode parameters from create replication request.

decode replicationId from create replication response.

decode dynamic paramater from the path of http request.

this func assumes that the request.ParseForm() has already been called, which should be the case since justValidate always come with some other required parameters As a result, the error returned by this func is always a validation error.

decode parameters from create remote cluster request.

decode replication settings related parameters from http request.

DeleteReplication stops the running replication of given replicationId and delete the replication specification from the metadata store.

encode a byte array into Response object with default status code of StatusOK.

encode a byte array into Response object with specified status code.

encode the error message of an error, without any wrapping, into Response object.

encode a map of validation errors into a Response object, which can then be returned in a http response when withErrorsWrapper is false, simply return a map of error messages -- this is needed by remote cluster rest APIs when withErrorsWrapper is true, wrap the map of error messages in an outer map -- this is needed by replication rest APIs.

encode an arbitrary object into Response object with default status code of StatusOK.

encode an arbitrary object into Response object with specified status code.

Remote cluster related errors can be internal server error or less servere invalid/unknown remote cluster errors, return different Response for them.

Replication spec related errors can be internal server error or less servere replication spec not found/already exists errors, return different Response for them.

encode a validation error into Response object by wrapping it in an errorMap.

get info of all running replications - serves back to consumers who call the REST end point, i.e.

get statistics for all running replications % returns a list of replication stats for the bucket.

pull GoMaxProc from environment.

update the replication settings and XDCR process setting.

update the per-replication settings only if justValidate is false Warnings should be given only if there are no errors.

constants for stats names.

constants used for parsing url path.

constants used for parsing url path.

desired latency is the parameter exposed to UI and CLI.

constants used for parsing replication settings.

constants for stats names.

constants used for parsing replication settings.

constants used for parsing replication settings.

constants used for parsing url path.

constants used for parsing url path.

constants for RegexpValidation request.

constants used for parsing bucket setting changes.

constants used for parsing url path.

bypass sounds better to external, translates into strip internally.

constants used for parsing replication settings.

constants for stats names.

constants used for parsing replication settings.

constants used for parsing replication settings.

constants for RegexpValidation request.

constants used for parsing replication settings.

constants used for parsing replication settings.

constants used for parsing replication settings.

constants used for parsing replication settings.

constants used for parsing replication settings.

constants used for parsing replication settings.

constants used for parsing replication settings.

constants used for parsing url path.

constants for stats names.

constants used for parsing url path.

constants used for parsing replication settings.

constants for RegexpValidation request.

constants for stats names.

constants for stats names.

constants for stats names.

constants for stats names.

constants for stats names.

constants for stats names.

Some url paths are not static and have variable contents, e.g., settings/replications/$replication_id The message keys for such paths are constructed by appending the dynamic suffix below to the static portion of the path.

Input.

constants used for parsing replication settings.

constants used for parsing replication settings.

constants used for parsing replication settings.

constants used for parsing replication settings.

constants used for parsing replication settings.

constants used for parsing replication settings.

constants used for parsing replication settings.

constants used for parsing replication settings.

constants used for parsing replication settings.

constants used for parsing replication settings.

constants used for parsing replication settings.

constants used for parsing replication settings.

constants used for parsing bucket setting changes.

constants used for parsing replication settings.

constants for RegexpValidation request.

Output.

constants used for parsing replication settings.

constants used for parsing url path.

constants used for parsing replication settings.

constants for stats names.

constants for stats names.

constants for stats names.

constants for stats names.

constants used for parsing replication settings.

constants used for parsing replication settings.

constants used for parsing replication settings.

constants used for parsing replication settings.

constants for stats names.

constants used for parsing url path.

constants used for parsing replication settings.

constants for parsing create/change/view replication response.

constants used for parsing replication settings.

constants used for parsing replication settings.

constants for parsing create/change/view replication response.

constants used for parsing replication settings.

constants used for parsing replication settings.

constants for RegexpValidation request.

constants used for parsing url path.

constants for stats names.

constants for RegexpValidation request.

constants used for parsing replication settings.

constants used for parsing url path.

constants used for parsing replication settings.

constants used for parsing replication settings.

constants for stats names.

constants used for parsing replication settings.

constants for stats names.

constants for stats names.

constants for stats names.

constants for parsing create/change/view replication response.

constants used for parsing url path.

constants used for parsing url path.

constants used for parsing url path.

For outside world via REST, they would prefer to see descriptive names of compression settings instead of 0 or 1.

errors.

xdcr prefix for internal settings keys.

Conversion to REST for user -> pauseRequested - Pretty much a NOT operation User wants to know if the replication is paused.

replication settings key in rest api -> internal replication settings key.

internal replication settings key -> replication settings key in rest api.

* * In cases where internally we store values differently from what the REST API requires, this * map performs the translation.

*********************************** /* struct Adminport *************************************/.

listener for GOXDCR Process level setting changes.

listener for GOXDCR internal setting changes.

generic listener for metadata stored in metakv.

listener for remote clusters.

listener for replication spec.

*********************************** /* ReplicationManager Interface ************************************ */.