Versions in this module Expand all Collapse all v1 v1.0.0 May 30, 2020 Changes in this version + const DefaultMaxRetries + const RetryInterval + func DelKeyWithPrefix(rm kv.RetrieverMutator, prefix kv.Key) error + func GetStack() []byte + func RandomBuf(size int) []byte + func RowKeyPrefixFilter(rowKeyPrefix kv.Key) kv.FnKeyCmp + func RunWithRetry(retryCnt int, backoff uint64, f func() (bool, error)) (err error) + func ScanMetaWithPrefix(retriever kv.Retriever, prefix kv.Key, filter func(kv.Key, []byte) bool) error + func WithRecovery(exec func(), recoverFn func(r interface{})) + type OscProcessInfo struct + Command string + ConnID uint64 + ID uint64 + Info string + IsGhost bool + Killed bool + Pause bool + Percent int + RemainTime string + Schema string + Sqlsha1 string + Table string + type ProcessInfo struct + Command string + DB string + DestHost string + DestPort int + DestUser string + Host string + ID uint64 + Info string + Mem int64 + OperState string + Percent float64 + State uint16 + Time time.Time + User string + type SessionManager interface + AddOscProcess func(p *OscProcessInfo) + Kill func(connectionID uint64, query bool) + ShowOscProcessList func() map[string]*OscProcessInfo + ShowProcessList func() map[uint64]ProcessInfo