Documentation
¶
Index ¶
- Constants
- Variables
- func AddCommit(ts time.Time, op int, t int, id uint64, backKey int, d1, d2, d time.Duration, ...)
- func AddRecovery(ts time.Time, op int, t int, id uint64, backKey int, d1, d2, d time.Duration, ...)
- func AddRequest(ts time.Time, op int, status, reqId, chunk string, d1, d2, d, dp time.Duration, ...)
- func Collect(session *lifetime.Session)
- func Save()
- func SaveWithOption(snapshot bool)
- func Send(entry DataEntry)
- type DataEntry
- type PersistEntry
- type RequestEntry
Constants ¶
View Source
const ( COLLECT_REQUEST = 0x0001 COLLECT_PERSIST = 0x0002 )
Variables ¶
Functions ¶
func AddRecovery ¶
func AddRequest ¶
func SaveWithOption ¶
func SaveWithOption(snapshot bool)
Types ¶
type PersistEntry ¶
type PersistEntry struct {
Time time.Time
Op int
Type int
Id uint64
BackupId int
DLineage time.Duration // Duration for lambda to handle request.
DObjects time.Duration // Duration for lambda to transmit response.
Duration time.Duration // Duration for lambda side latency.
BytesLineage int
BytesObjects int
Objects int
Session string
}
For requests
func (*PersistEntry) WriteTo ¶
func (e *PersistEntry) WriteTo(buf *bytes.Buffer)
type RequestEntry ¶
type RequestEntry struct {
Time time.Time
Op int
Status string
ReqId string
ChunkId string
DHandling time.Duration // Duration for lambda to handle request.
DResponse time.Duration // Duration for lambda to transmit response.
Duration time.Duration // Duration for lambda side latency.
DPost time.Duration // Duration for post handling
Session string
}
For requests
func (*RequestEntry) WriteTo ¶
func (e *RequestEntry) WriteTo(buf *bytes.Buffer)
Click to show internal directories.
Click to hide internal directories.