nsmcp::accessIngestionFinish

 nsmcp::accessIngestionFinish

Defined in

Partial Call Graph (max 5 caller/called nodes):

Testcases:

No testcase defined.

Source code:

    if {$token eq {}} {
        return
    }
    set key nsmcp:access-writer:[ns_info server]
    set state [nsv_get $key state]
    if {![dict get $state running] || [dict get $state token] ne $token} {
        return
    }
    set now [clock clicks -milliseconds]
    set times [dict get $state phaseMilliseconds]
    dict incr times [dict get $state phase] [expr {max(0,$now-[dict get $state phaseTicks])}]
    set last [dict create startedAt [dict get $state startedAt] finishedAt [clock seconds]  durationMs [expr {max(0,$now-[dict get $state startedTicks])}] parsedBytes [dict get $state parsedBytes]  outcome $outcome lastPhase [dict get $state phase] phaseMilliseconds $times]
    foreach field {records requestRecords malformedRecords oversizedRecords committedBatches lastBatch} {
        dict set last $field [dict get $state $field]
    }
    if {[dict get $state committedBatches]==0} {
        dict set last lastBatch {}
    }
    dict set last recordsPerSecond [expr {[dict get $last durationMs]>0 ? 1000.0*[dict get $state records]/[dict get $last durationMs] : {}}]
    if {[dict exists $result code]} {
        dict set last code [dict get $result code]
    }
    dict set state lastRun $last
    dict set state running false
    nsv_set $key state $state

XQL Not present:

Generic, PostgreSQL, Oracle