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

# Packages

No description provided by the author
simple utility functions with minimum dependencies on other goxdcr packages.

# Functions

No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
check if two vb server maps are the same.
evenly distribute load across workers assumes that num_of_worker <= num_of_load returns load_distribution [][]int, where load_distribution[i][0] is the start index, inclusive, of load for ith worker load_distribution[i][1] is the end index, exclusive, of load for ith worker note that load is zero indexed, i.e., indexed as 0, 1, .
No description provided by the author
No description provided by the author
No description provided by the author
Map should be protected for read.
Given a destination, insert the "ins" at pos This insert should not generate garbage unless a contiguous block of memory cannot be found.
During debug mode, a bunch of HTTP requests will have user identifiable information.
No description provided by the author
No description provided by the author
No description provided by the author
"sort" needs to be true if list_1 and list_2 are not sorted 136.
No description provided by the author
No description provided by the author
return the singleton ConnPoolMgr.
construct vb->server map for the vbs in vbList using server->vbList map.
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
No description provided by the author
encode version into an integer.
check whether source byte array contains the same string as target string this impl avoids converting byte array to string.
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
NOTE - takes in user entered META().id as key.
Xattr counterpart of the key above.
No description provided by the author
This will find the custom CR XATTR from the req body.
flatten an array of byte array into a byte array.
Efficiently concatenate and flatten errmap into a presentable single error string Note map coming in should be read-protected.
flatten a string array into a string.
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
A pointer function to lookup Auto with the actual compression type - right now it's Snappy.
translate conflict resolution type bucket metadata into ConflictResolutionMode.
get the subset of vbs in vbList that point to different servers in the two vb server maps.
Internally, XDCR eventIDs are kept as int64 Externally, since JSON doesn't play nice with int64, we will use reg int32 The Getter function here should ensure that if it exceeds MaxInt32, it starts over from the beginning.
return host address in the form of hostName:port hostName could be 1.
extract host name from hostAddr, which is in the form of hostName:port.
No description provided by the author
No description provided by the author
No description provided by the author
get number of vbuckets in a cluster based on kv vb map.
No description provided by the author
Given two maps, find the total number of elements in an union should these maps be combined.
No description provided by the author
No description provided by the author
check if a specified data type contains xattr.
This routine expect prefix 0x since this is included in KV macro expansion.
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
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
check if a cluster (with specified clusterCompatibility) is compatible with version.
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
check if memcached response status indicates ignorable error, which requires no corrective action at all If caslock is true, resp.Status will be KEY_EEXISTS/KEY_ENOENT if cas does not match.
No description provided by the author
No description provided by the author
check if memcached response status indicates mutation locked error, which requires resending the corresponding request.
No description provided by the author
Returns true iff the specific MCRequest is of a compression type that is being checked (Note: None is also a type).
No description provided by the author
No description provided by the author
check if memcached response status indicates error of temporary nature, which requires retrying corresponding requests.
check if memcached response status indicates topology change, in which case we defer pipeline restart to topology change detector.
No description provided by the author
Return true if re-encode has the same length as passed in value with space trimmed.
Note, this is not meant to be a direct replacement of pcre.
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
Merge two maps into one - not go-routine/thread safe.
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
The specificStr should follow the format of: "<scope>.<collection>".
plainAuth is set to false only when 1.
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
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
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
Used to encode a uint64 into a unsigned LEB128 32-bit int encoding This is needed for converting collection/scope UID to setmeta/getmeta requests.
No description provided by the author
No description provided by the author
parse stats value from stats map.
No description provided by the author
randomized ordering of elements in passed in list.
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
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
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
Linearly combine two lists into one and also deduplicates duplicated entries, returns the result.
Given two lists, return a slice that contains elements from list1 that are not found in list2.
No description provided by the author
Redaction User Data tag - cbcollect will hash these values externally Makes a copy of the data coming in Expensive to call, so ONLY call on DEBUG or calls that do not happen regularly.
Modifies data coming in.
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
No description provided by the author
No description provided by the author
validate host address [provided by user at remote cluster reference creation time].
No description provided by the author
wait till the specified time or till finish_ch is closed.
Given a correctly allocatedBytes slice that can contain the whole rawJSON message, write the given information without the use of any data structures on the heap Input: allocatedBytes - finalized byte slice that will contain the specific marshalled JSON bytesToWrite - This can be either key or value in []byte form mode - mode above pos - current position to continue the write size - In cases where bytesToWrite originated from dataPool, the length may not reflect the actual length of the data (i.e.

# Constants

No description provided by the author
No description provided by the author
No description provided by the author
supervisor related 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
No description provided by the author
No description provided by the author
const used by block profile.
No description provided by the author
UI+ns_server returned document content, keyed by special keys.
UI+ns_server returned document content, keyed by special keys.
UI+ns_server returned document content, keyed by special keys.
Custom CR related constants.
metadata change listener related constants.
constants for replication docs.
No description provided by the author
No description provided by the author
The value for the cv field when setting back to source.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
keys used in pipeline.settings.
names of async component event listeners.
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
No description provided by the author
No description provided by the author
No description provided by the author
From KV design doc: A user’s collection can only contain characters A-Z, a-z, 0-9 and the following symbols _ - % The prefix character of a user’s collection name however is restricted.
No description provided by the author
XDCR only.
No description provided by the author
XDCR only.
No description provided by the author
None means try to establish memcached with snappy HELO.
No description provided by the author
Snappy is for internal use only.
Start and End markers are considered invalid values.
No description provided by the author
No description provided by the author
constants for parsing conflict resolution type setting in bucket metadata.
constants for parsing conflict resolution type setting in bucket metadata.
constants for parsing conflict resolution type setting in bucket metadata.
constants for parsing conflict resolution type setting in bucket metadata.
constants used for remote cluster references.
http request related constants.
http request related 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
names of async component event listeners.
names of async component event listeners.
names of async component event listeners.
names of async component event listeners.
names of async component event listeners.
names of async component event listeners.
names of async component event listeners.
names of async component event listeners.
names of async component event listeners.
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
http request related constants.
Custom CR related constants.
Custom CR related 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
No description provided by the author
No description provided by the author
Need to escape the () to result in "META().xattrs" literal.
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
No description provided by the author
No description provided by the author
No description provided by the author
Note the default is KeyOnly because from a version that did not have this key, that is the expected version so we can do proper handling.
No description provided by the author
constants used for create replication request.
Custom CR related constants.
No description provided by the author
No description provided by the author
names of async component event listeners.
metadata change listener related 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
seconds, 3 days.
No description provided by the author
https authentication.
plain http authentication.
scram sha authentication.
No description provided by the author
metadata change listener related constants.
constants for ipv6 addresses.
constants used for remote cluster references.
http request related constants.
DataType fields of MCRequest kv_engine/include/mcbp/protocol/datatype.h.
In subdoc lookup for vxattr $document, KV returns an array of the following strings instead.
No description provided by the author
constant used by more than one rest apis.
constant used by more than one rest apis.
No description provided by the author
No description provided by the author
No description provided by the author
Limit imposed by memcached.
No description provided by the author
No description provided by the author
When callbacks are to be called concurrently, certain callbacks may have higher priority to be called than another when certain metadata is being created or deleted.
When callbacks are to be called concurrently, certain callbacks may have higher priority to be called than another when certain metadata is being created or deleted.
When callbacks are to be called concurrently, certain callbacks may have higher priority to be called than another when certain metadata is being created or deleted.
http request method types.
http request method types.
http request method types.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
constant for replication tasklist status.
constant for replication tasklist status.
permissions for RBAC.
permissions for RBAC.
permissions for RBAC.
permissions for RBAC.
permissions for RBAC.
permissions for RBAC.
permissions for RBAC.
permissions for RBAC.
permissions for RBAC.
permissions for RBAC.
permissions for RBAC.
permissions for RBAC.
permissions for RBAC.
No description provided by the author
No description provided by the author
supervisor related constants.
No description provided by the author
supervisor related constants.
http request related constants.
constants used for remote cluster references.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
priority shown on UI and rest api.
priority shown on UI and rest api.
priority shown on UI and rest api.
No description provided by the author
No description provided by the author
No description provided by the author
keys used in pipeline.settings.
keys used in pipeline.settings.
http request related constants.
constants used for remote cluster references.
No description provided by the author
constants used for remote cluster references.
metadata change listener related constants.
constants used for remote cluster references.
constants used for remote cluster references.
constants used for remote cluster references.
To be deprecated.
To be deprecated.
constants used for remote cluster references.
constants used for remote cluster references.
constants used for remote cluster references.
constants used for remote cluster references.
New parameter that should be used in the place of RemoteClusterDemandEncryption and RemoteClusterEncryptionType starting at 5.5.
constants for replication docs.
constants used for remote cluster references.
constants used for remote cluster references.
constants used for remote cluster references.
constants used for remote cluster references.
constants used for remote cluster references.
constant for replication tasklist status.
constants for replication docs.
constants for replication docs.
constants for replication docs.
constants for replication docs.
constants for replication docs.
constants for replication docs.
constants for replication docs.
constants for replication docs.
constants for replication docs.
supervisor related constants.
metadata change listener related 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
seconds, 1 hour.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
secure type for remote cluster reference.
secure type for remote cluster reference.
secure type for remote cluster reference.
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
DataType fields of MCRequest kv_engine/include/mcbp/protocol/datatype.h.
DataType fields of MCRequest kv_engine/include/mcbp/protocol/datatype.h.
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
Flags for SUBDOC commands.
Path level flag.
Flags for SUBDOC commands.
No description provided by the author
names of async component event listeners.
No description provided by the author
constants used for create replication request.
constants used for create replication request.
No description provided by the author
No description provided by the author
No description provided by the author
constants used for create replication request.
* * Log Redaction section * Spectrum 1 - User Data redaction (ud) tags * Spectrum 2 - Metadata redaction tags (TBD) * Spectrum 3 - System Data redaction tags (TBD) */.
* * Log Redaction section * Spectrum 1 - User Data redaction (ud) tags * Spectrum 2 - Metadata redaction tags (TBD) * Spectrum 3 - System Data redaction tags (TBD) */.
Collection consts.
URL related constants.
http request related constants.
basic user auth using passed in username and password - so far this applies to user in remote clusters only.
use implicit local user auth.
no user auth.
No description provided by the author
vb error caused by source topology change.
vb error caused by target topology change.
keys used in pipeline.settings.
No description provided by the author
Bucket sequence number statistics.
No description provided by the author
Custom CR related constants.
Custom CR related constants.
Custom CR related constants.
Custom CR related 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
The Cas field in _xdcr.
Custom CR related constants.
The cluster ID field in _xdcr.
Custom CR related constants.
the MV field in _xdcr.
Custom CR related constants.
The Pcas field in _xdcr.
Custom CR related constants.
The XDCR XATTR.
DataType fields of MCRequest kv_engine/include/mcbp/protocol/datatype.h.
DataType fields of MCRequest kv_engine/include/mcbp/protocol/datatype.h.
This constant is used when communicating with KV to retrieve a list of all the available xattr keys.
No description provided by the author

# Variables

No description provided by the author
No description provided by the author
No description provided by the author
used as default value for tests.
read timeout for golib's http server.
constants for adminport.
write timeout for golib's http server.
No description provided by the author
read time out for audit service (seconds).
No description provided by the author
write time out for audit service (seconds).
Amount of time between each backfill metakv persist operation Be careful when changing the unit - need corresponding base.InitConstants to change.
No description provided by the author
*********************************** /* struct XmemClient *************************************/.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
The following will result in a max of 3 seconds of retry time before declaring failure.
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
when set to true, bypass san in certificate check in ssl connections.
No description provided by the author
Cached variables.
No description provided by the author
No description provided by the author
timeout for batch processing in capi 1.
capi nozzle data chan size is defined as batchCount*CapiDataChanSizeMultiplier.
max retry for capi batchUpdateDocs operation.
No description provided by the author
timeout for tcp read operation in capi.
interval between retries on batchUpdateDocs.
No description provided by the author
timeout for tcp write operation in capi.
once changes_left becomes smaller than this threshold, replication will be classified as ongoing replication.
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
No description provided by the author
No description provided by the author
Implicit, no mirror, no migration, OSO.
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
Last element is invalid and is there to keep consistency with the EndMarker.
id of conflict resolution mode in extended metadata.
No description provided by the author
keys in the map which /nodes/self returns.
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
interval for cpu stats collection.
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
No description provided by the author
No description provided by the author
default time out for outgoing http requests if it is not explicitly specified (seconds).
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
Stopwatch timers.
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
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
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
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
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
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
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
No description provided by the author
No description provided by the author
Various error messages.
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
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
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
NRU eviction policy for ephemeral bucket.
version of extended metadata to look for.
No description provided by the author
extra quota given to replications when cpu is not yet maximized.
No description provided by the author
No description provided by the author
No description provided by the author
0x2.
0x4.
0x1.
Various non-error internal msgs.
flag for memcached to enable lww to lww bucket replication.
No description provided by the author
No description provided by the author
No description provided by the author
Used to calculate the number of bytes to allocate for sending the HELO messages.
Collections Feature.
value representing snappy compression.
value representing tcp no delay feature in helo request/response.
value representing xattr feature in helo request/response.
value representing XERROR.
read/write timeout for helo command to memcached.
No description provided by the author
No description provided by the author
When contacting the remote cluster's NS server for getting HTTPS ports, it should not take long.
No description provided by the author
Internal key to wrap around incoming key for advanced filtering.
Internal key to wrap around incoming document's xattributes for advanced filtering Customers may change it if a specific key conflicts with this.
interval for throttler calibration, i.e., for stopping reassigning tokens to low priority replications, as number of time slots.
No description provided by the author
No description provided by the author
https://github.com/couchbase/kv_engine/blob/master/engines/ep/docs/protocol/del_with_meta.md.
No description provided by the author
Custom conflict resolution related constants.
Keep alive period for tcp connections.
delimiter for multiple parts in a key.
No description provided by the author
No description provided by the author
length of random id.
No description provided by the author
No description provided by the author
How often in seconds to pull manifests from ns_server.
No description provided by the author
No description provided by the author
the maximum number of checkpoint records to keep in the checkpoint doc.
the maximum number of checkpoint records to read from the checkpoint doc.
No description provided by the author
when the number of consecutive terms where there have been backlog reaches the threshold, set DCP priorities.
max count of consecutive terms where cpu has not been maxed out an extra quota period will be started when the max count is reached.
when the number of consecutive terms where there have been no backlog reaches the threshold, reset DCP priorities to normal.
DCP inactive stream monitor will sleep every "dcp_inactive_stream_check_interval" (30sec) Once this max is hit, it'll retry streamReq with DCP.
max count of consecutive terms where throughput dropped from previous high if we are in extra quota period, the period will be ended when the max count is reached.
No description provided by the author
maximum number of snapshot markers to store for each vb once the maximum is reached, the oldest snapshot marker is dropped to make room for the new one.
max number of async listeners [for an event type].
max number of retries for metakv ops.
max number of retries for setDerivedObj op.
Number of retries for RemoteClusterService to do any metaKV operations.
For utilities to try to get a working remote connection.
number of retries for CAPI calls, e.g., pre_replicate and commit_for_checkpoint.
max retry for live updating of pipelines.
max retry for random id generation.
max retry for target stats retrieval.
the maximum number of topology change checks to wait before pipeline is restarted to elaborate: 1.
the maximum number of consecutive stable topology seen before pipeline is restarted to elaborate: 1.
constant used in replication info to ensure compatibility with erlang xdcr.
the max number of concurrent workers for checkpointing.
interval for mem stats logging (seconds).
Exponential backoff factor.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
keys used in parsing cluster info.
No description provided by the author
No description provided by the author
the full error as of now is : "x509: cannot validate certificate for xxx because it doesn't contain any IP SANs" use a much shorter version for matching to reduce the chance of false negatives - the error message may be changed by golang in the future.
number of time slots [in one second] to track for bandwidth throttling computation.
number of time slots [per measurement interval] for throughput throttling.
No description provided by the author
constants for integer parsing.
No description provided by the author
When doing bandwith throttling in xmem, set minNumberOfBytes = TotalNumberOfBytes * PercentageOfBytesToSendAsMin / 100.
Retry for serializer - should be relatively quick.
No description provided by the author
No description provided by the author
Key used for general validation errors that are not related to any specific http request parameters.
URL Paths for retrieving cluster info.
No description provided by the author
new XATTR bit in data type field in dcp mutations.
interval for refreshing remote cluster references.
For Requesting Remote Bucket monitoring - max of 8 seconds.
No description provided by the author
No description provided by the author
Number of times for a remote cluster to consistently change from using internal interface to external interface, and vice versa.
No description provided by the author
No description provided by the author
Number of times to verify bucket is missing before removing an invalid replicationSpec.
No description provided by the author
No description provided by the author
interval for replication spec validity check (seconds).
No description provided by the author
No description provided by the author
flag for requesting datatype in GetMeta request.
From end user's perspective, they will see the reserved word they entered However, internally, XDCR will insert more obscure internal keys to prevent collision with actual user's data.
The regexp here returns true if the specified values are not escaped (enclosed by backticks).
Used to make sure the pcre's are initialized only once, when needed.
interval for resource management actions.
all the ratio related constants are defined as multiples of 1/ResourceManagementRatioBase so that we can do integer arithmetic.
upper bound for ratio of throughput of high priority replications to throughput of all replications this is to ensure that low priority replications will not be completely starved.
interval for logging resource management stats.
No description provided by the author
interval between metakv retries.
retry interval for setDerivedObj op.
base wait time between retries for target stats retrieval (milliseconds).
No description provided by the author
constants for CAPI nozzle.
No description provided by the author
No description provided by the author
No description provided by the author
when we need to make a rest call when processing a XDCR rest request, the time out of the second rest call needs to be shorter than that of the first one, which is currently 30 seconds.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
interval for printing replication runtime stats to log file.
No description provided by the author
No description provided by the author
actual size of data chan is logged when it exceeds ThresholdForEventChanSizeLogging.
if through seqno computation takes longer than the threshold, it will be logged.
when actual process cpu usage exceeds maxProcessCpu * ThresholdRatioForProcessCpu/100, process cpu is considered to have maxed out.
when actual total cpu usage exceeds totalCpu * ThresholdRatioForTotalCpu/100, total cpu is considered to have maxed out.
alpha for exponential decay sampling.
number of throughput samples to keep.
interval for clearing tokens in throughput throttler.
interval for printing throughput throttler stats to log file.
Time to wait between metakv get ops.
timeout for checkpointing attempt before pipeline is stopped - to put an upper bound on the delay of pipeline stop/restart.
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
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
No description provided by the author
No description provided by the author
No description provided by the author
ui log related constants.
No description provided by the author
No description provided by the author
so far all xdcr logs are of info level, thus we can hardcode it here.
dcp flow control buffer size (number of bytes).
length of data channel between dcp nozzle and gomemcached.
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
No description provided by the author
minimum versions where various features are supported.
No description provided by the author
No description provided by the author
wait time between retries for live updating of pipelines (milliseconds).
No description provided by the author
No description provided by the author
initial backoff time between retries for new xmem connection (milliseconds).
wait time between writes is backoff_factor*XmemBackoffWaitTime.
default resp timeout, which is used as the interval for checkAndRepairBufferMonitor.
max backoff factor.
max batch size that can be sent in one writeToClient() op.
//the maximum amount of data (in bytes) xmem data channel can hold.
initial max idle count; it is dynamically adjusted at runtime by factor = actual response wait time / previous response wait time if xmem idle count exceeds this max, it will be declared to be stuck.
lower bound for xmem max idle count.
upper bound for xmem max idle count.
network connection will be repaired if its down time (the time that it receives continuous network error responses from read or write) exceeds max down time (seconds).
max retry for xmem operations like batch send, resend, etc.
max interval between retries when resending docs (seconds).
max interval between retries when resending docs on mutation locked errors (seconds) the upper limit on lock period is as of now 30 seconds.
max retry for xmem resend operation on mutation locked error.
max retry for new xmem connection.
xmem read time out when reading from network connection (seconds).
interval for xmem self monitoring (seconds).
xmem write time out for writing to network connection (seconds).

# Structs

atomic boolean type which uses a uint32 integer to store boolean value.
No description provided by the author
These should be RO once they are created because they are potentially used as constant keys for CollectionNamespaceMapping.
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
No description provided by the author
No description provided by the author
No description provided by the author
Fake data pool used to simulate returning a byte slice filled with garbage.
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
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
resp is a response to subdoc_multi_lookup based on the path specs.
No description provided by the author
No description provided by the author
timestamp for a specific vb.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author

# Interfaces

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
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
bucket info map.
No description provided by the author
No description provided by the author
Compression Section.
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
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
So on pool details and bucket details "status": "healthy" currently means node recently sent heartbeat.
http authentication mode.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
Callback function for the handling of metadata changed event.
Certain callbacks are done in parallel and so may need a waitGroup to ensure synchronization is done.
No description provided by the author
Callback function, which typically is a method in metadata service, which translates metakv call back parameters into metadata objects The function may do something addtional that is specific to the metadata service, e.g., caching the new metadata.
No description provided by the author
No description provided by the author
Pprof goroutines dump types.
No description provided by the author
No description provided by the author
No description provided by the author
stack implementation.
No description provided by the author
No description provided by the author
No description provided by the author
StringPair holds a pair of strings.
StringPairList is used mainly to facilitate sorting StringPairList can be sorted by first string through sort.Sort(list).
type to facilitate the sorting of uint16 lists.
No description provided by the author
type to facilitate the sorting of uint64 lists.
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
outgoing nozzle type.