Tap stats
Stat | Description |
---|---|
ep_tap_ack_grace_period | The amount of time to wait for a tap acks |
before disconnecting | |
ep_tap_ack_interval | The amount of messages a tap producer |
should send before requesting an ack | |
ep_tap_ack_window_size | The maximum amount of ack requests that |
can be sent before the consumer sends a | |
response ack. When the window is full the | |
tap stream is paused | |
ep_tap_queue_backfillremaining | Number of items needing to be backfilled |
ep_tap_total_backlog_size | Number of remaining items for replication |
ep_tap_total_queue | Sum of tap queue sizes on the current |
tap queues | |
ep_tap_total_fetched | Sum of all tap messages sent |
ep_tap_bg_max_pending | The maximum number of bg jobs a tap |
connection may have | |
ep_tap_bg_fetched | Number of tap disk fetches |
ep_tap_bg_fetch_requeued | Number of times a tap bg fetch task is |
requeued | |
ep_tap_fg_fetched | Number of tap memory fetches |
ep_tap_deletes | Number of tap deletion messages sent |
ep_tap_throttled | Number of tap messages refused due to |
throttling | |
ep_tap_count | Number of tap connections |
ep_tap_bg_num_samples | The number of tap bg fetch samples |
included in the avg | |
ep_tap_bg_min_wait | The shortest time (µs) for a tap item |
before it is serviced by the dispatcher | |
ep_tap_bg_max_wait | The longest time (µs) for a tap item |
before it is serviced by the dispatcher | |
ep_tap_bg_wait_avg | The average wait time (µs) for a tap item |
before it is serviced by the dispatcher | |
ep_tap_bg_min_load | The shortest time (µs) for a tap item to |
be loaded from the persistence layer | |
ep_tap_bg_max_load | The longest time (µs) for a tap item to |
be loaded from the persistence layer | |
ep_tap_bg_load_avg | The average time (µs) for a tap item to |
be loaded from the persistence layer | |
ep_tap_noop_interval | The number of secs between a noop is |
added to an idle connection | |
ep_tap_backoff_period | The number of seconds the tap connection |
should back off after receiving ETMPFAIL | |
ep_tap_queue_fill | Total enqueued items |
ep_tap_queue_drain | Total drained items |
ep_tap_queue_backoff | Total back-off items |
ep_tap_queue_backfill | Number of backfill remaining |
ep_tap_queue_itemondisk | Number of items remaining on disk |
ep_tap_throttle_threshold | Percentage of memory in use before we |
throttle tap streams | |
ep_tap_throttle_queue_cap | Disk write queue cap to throttle |
tap streams |
Per Tap client stats
Each stat begins with =ep_tapq:= followed by a unique /client_id/ and another colon. For example, if your client is named, =slave1=, the =qlen= stat would be =ep_tapq:slave1:qlen=.
Stat | Description | P/C |
---|---|---|
type | The kind of tap connection (producer or | PC |
consumer) | ||
created | Creation time for the tap connection | PC |
supports_ack | true if the connection use acks | PC |
connected | true if this client is connected | PC |
disconnects | Number of disconnects from this client | PC |
reserved | true if the tap stream is reserved | P |
suspended | true if the tap stream is suspended | P |
qlen | Queue size for the given client_id | P |
qlen_high_pri | High priority tap queue items | P |
qlen_low_pri | Low priority tap queue items | P |
vb_filters | Size of connection vbucket filter set | P |
vb_filter | The content of the vbucket filter | P |
rec_fetched | Tap messages sent to the client | P |
rec_skipped | Number of messages skipped due to | P |
tap reconnect with a different filter | P | |
idle | True if this connection is idle | P |
has_queued_item | True if there are any remaining items | P |
from hash table or disk | ||
bg_result_size | Number of ready background results | P |
bg_jobs_issued | Number of background jobs started | P |
bg_jobs_completed | Number of background jobs completed | P |
flags | Connection flags set by the client | P |
pending_disconnect | true if we’re hanging up on this client | P |
paused | true if this client is blocked | P |
pending_backfill | true if we’re still backfilling keys | P |
for this connection | P | |
pending_disk_backfill | true if we’re still backfilling keys | P |
from disk for this connection | P | |
backfill_completed | true if all items from backfill is | P |
successfully transmitted to the client | P | |
backfill_start_timestamp | Timestamp of backfill start | P |
reconnects | Number of reconnects from this client | P |
backfill_age | The age of the start of the backfill | P |
ack_seqno | The current tap ACK sequence number | P |
recv_ack_seqno | Last receive tap ACK sequence number | P |
ack_log_size | Tap ACK backlog size | P |
ack_window_full | true if our tap ACK window is full | P |
seqno_ack_requested | The seqno of the ack message that the | P |
producer is wants to get a response for | ||
expires | When this ACK backlog expires | P |
queue_memory | Memory used for tap queue | P |
queue_fill | Total queued items | P |
queue_drain | Total drained items | P |
queue_backoff | Total back-off items | P |
queue_backfillremaining | Number of backfill remaining | P |
queue_itemondisk | Number of items remaining on disk | P |
total_backlog_size | Num of remaining items for replication | P |
total_noops | Number of NOOP messages sent | P |
num_checkpoint_end | Number of chkpoint end operations | C |
num_checkpoint_end_failed | Number of chkpoint end operations failed | C |
num_checkpoint_start | Number of chkpoint end operations | C |
num_checkpoint_start_failed | Number of chkpoint end operations failed | C |
num_delete | Number of delete operations | C |
num_delete_failed | Number of failed delete operations | C |
num_flush | Number of flush operations | C |
num_flush_failed | Number of failed flush operations | C |
num_mutation | Number of mutation operations | C |
num_mutation_failed | Number of failed mutation operations | C |
num_opaque | Number of opaque operation | C |
num_opaque_failed | Number of failed opaque operations | C |
num_vbucket_set | Number of vbucket set operations | C |
num_vbucket_set_failed | Number of failed vbucket set operations | C |
num_unknown | Number of unknown operations | C |
Tap aggregated stats
Aggregated tap stats allow named tap connections to be logically grouped and aggregated together by prefixes.
For example, if all of your tap connections started with =rebalance= or =replication=, you could call =stats tapagg = to request stats grouped by everything before the first == character, giving you a set for =rebalance= and a set for =replication=.
Results
Stat | Description |
---|---|
[prefix]:count | Number of connections matching this prefix |
[prefix]:qlen | Total length of queues with this prefix |
[prefix]:backfill_remaining | Number of items needing to be backfilled |
[prefix]:backoff | Total number of backoff events |
[prefix]:drain | Total number of items drained |
[prefix]:fill | Total number of items filled |
[prefix]:itemondisk | Number of items remaining on disk |
[prefix]:total_backlog_size | Num of remaining items for replication |