代码拉取完成,页面将自动刷新
// Code generated by protoc-gen-gogo.
// source: cockroach/pkg/roachpb/app_stats.proto
// DO NOT EDIT!
package roachpb
import proto "github.com/gogo/protobuf/proto"
import fmt "fmt"
import math "math"
import io "io"
// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
type StatementStatistics struct {
// Count is the total number of times this statement was executed
// since the begin of the reporting period.
Count int64 `protobuf:"varint,1,opt,name=count" json:"count"`
// FirstAttemptCount collects the total number of times a first
// attempt was executed (either the one time in explicitly committed
// statements, or the first time in implicitly committed statements
// with implicit retries).
// The proportion of statements that could be executed without retry
// can be computed as FirstAttemptCount / Count.
// The cumulative number of retries can be computed with
// Count - FirstAttemptCount.
FirstAttemptCount int64 `protobuf:"varint,2,opt,name=first_attempt_count,json=firstAttemptCount" json:"first_attempt_count"`
// MaxRetries collects the maximum observed number of automatic
// retries in the reporting period.
MaxRetries int64 `protobuf:"varint,3,opt,name=max_retries,json=maxRetries" json:"max_retries"`
// LastErr collects the last error encountered.
LastErr string `protobuf:"bytes,4,opt,name=last_err,json=lastErr" json:"last_err"`
// NumRows collects the number of rows returned or observed.
NumRows NumericStat `protobuf:"bytes,5,opt,name=num_rows,json=numRows" json:"num_rows"`
// ParseLat is the time to transform the SQL string into an AST.
ParseLat NumericStat `protobuf:"bytes,6,opt,name=parse_lat,json=parseLat" json:"parse_lat"`
// PlanLat is the time to transform the AST into a logical query plan.
PlanLat NumericStat `protobuf:"bytes,7,opt,name=plan_lat,json=planLat" json:"plan_lat"`
// RunLat is the time to run the query and fetch/compute the result rows.
RunLat NumericStat `protobuf:"bytes,8,opt,name=run_lat,json=runLat" json:"run_lat"`
// ServiceLat is the time to service the query, from start of parse to end of execute.
ServiceLat NumericStat `protobuf:"bytes,9,opt,name=service_lat,json=serviceLat" json:"service_lat"`
// OverheadLat is the difference between ServiceLat and the sum of parse+plan+run latencies.
// We store it separately (as opposed to computing it post-hoc) because the combined
// variance for the overhead cannot be derived from the variance of the separate latencies.
OverheadLat NumericStat `protobuf:"bytes,10,opt,name=overhead_lat,json=overheadLat" json:"overhead_lat"`
}
func (m *StatementStatistics) Reset() { *m = StatementStatistics{} }
func (m *StatementStatistics) String() string { return proto.CompactTextString(m) }
func (*StatementStatistics) ProtoMessage() {}
func (*StatementStatistics) Descriptor() ([]byte, []int) { return fileDescriptorAppStats, []int{0} }
type NumericStat struct {
// NumericStat keeps track of two running values --- the running mean and
// the running sum of squared differences from the mean. Using this along
// with the total count of values, we can compute variance using Welford's
// method. This is more reliable than keeping track of the sum of
// squared values, which is liable to overflow. See
// https://en.wikipedia.org/wiki/Algorithms_for_calculating_variance#Online_algorithm
Mean float64 `protobuf:"fixed64,1,opt,name=mean" json:"mean"`
SquaredDiffs float64 `protobuf:"fixed64,2,opt,name=squared_diffs,json=squaredDiffs" json:"squared_diffs"`
}
func (m *NumericStat) Reset() { *m = NumericStat{} }
func (m *NumericStat) String() string { return proto.CompactTextString(m) }
func (*NumericStat) ProtoMessage() {}
func (*NumericStat) Descriptor() ([]byte, []int) { return fileDescriptorAppStats, []int{1} }
type StatementStatisticsKey struct {
Query string `protobuf:"bytes,1,opt,name=query" json:"query"`
App string `protobuf:"bytes,2,opt,name=app" json:"app"`
DistSQL bool `protobuf:"varint,3,opt,name=distSQL" json:"distSQL"`
Failed bool `protobuf:"varint,4,opt,name=failed" json:"failed"`
}
func (m *StatementStatisticsKey) Reset() { *m = StatementStatisticsKey{} }
func (m *StatementStatisticsKey) String() string { return proto.CompactTextString(m) }
func (*StatementStatisticsKey) ProtoMessage() {}
func (*StatementStatisticsKey) Descriptor() ([]byte, []int) { return fileDescriptorAppStats, []int{2} }
// CollectedStats wraps collected timings and metadata for some query's execution.
type CollectedStatementStatistics struct {
Key StatementStatisticsKey `protobuf:"bytes,1,opt,name=key" json:"key"`
Stats StatementStatistics `protobuf:"bytes,2,opt,name=stats" json:"stats"`
}
func (m *CollectedStatementStatistics) Reset() { *m = CollectedStatementStatistics{} }
func (m *CollectedStatementStatistics) String() string { return proto.CompactTextString(m) }
func (*CollectedStatementStatistics) ProtoMessage() {}
func (*CollectedStatementStatistics) Descriptor() ([]byte, []int) {
return fileDescriptorAppStats, []int{3}
}
func init() {
proto.RegisterType((*StatementStatistics)(nil), "cockroach.sql.StatementStatistics")
proto.RegisterType((*NumericStat)(nil), "cockroach.sql.NumericStat")
proto.RegisterType((*StatementStatisticsKey)(nil), "cockroach.sql.StatementStatisticsKey")
proto.RegisterType((*CollectedStatementStatistics)(nil), "cockroach.sql.CollectedStatementStatistics")
}
func (m *StatementStatistics) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *StatementStatistics) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0x8
i++
i = encodeVarintAppStats(dAtA, i, uint64(m.Count))
dAtA[i] = 0x10
i++
i = encodeVarintAppStats(dAtA, i, uint64(m.FirstAttemptCount))
dAtA[i] = 0x18
i++
i = encodeVarintAppStats(dAtA, i, uint64(m.MaxRetries))
dAtA[i] = 0x22
i++
i = encodeVarintAppStats(dAtA, i, uint64(len(m.LastErr)))
i += copy(dAtA[i:], m.LastErr)
dAtA[i] = 0x2a
i++
i = encodeVarintAppStats(dAtA, i, uint64(m.NumRows.Size()))
n1, err := m.NumRows.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n1
dAtA[i] = 0x32
i++
i = encodeVarintAppStats(dAtA, i, uint64(m.ParseLat.Size()))
n2, err := m.ParseLat.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n2
dAtA[i] = 0x3a
i++
i = encodeVarintAppStats(dAtA, i, uint64(m.PlanLat.Size()))
n3, err := m.PlanLat.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n3
dAtA[i] = 0x42
i++
i = encodeVarintAppStats(dAtA, i, uint64(m.RunLat.Size()))
n4, err := m.RunLat.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n4
dAtA[i] = 0x4a
i++
i = encodeVarintAppStats(dAtA, i, uint64(m.ServiceLat.Size()))
n5, err := m.ServiceLat.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n5
dAtA[i] = 0x52
i++
i = encodeVarintAppStats(dAtA, i, uint64(m.OverheadLat.Size()))
n6, err := m.OverheadLat.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n6
return i, nil
}
func (m *NumericStat) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *NumericStat) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0x9
i++
i = encodeFixed64AppStats(dAtA, i, uint64(math.Float64bits(float64(m.Mean))))
dAtA[i] = 0x11
i++
i = encodeFixed64AppStats(dAtA, i, uint64(math.Float64bits(float64(m.SquaredDiffs))))
return i, nil
}
func (m *StatementStatisticsKey) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *StatementStatisticsKey) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintAppStats(dAtA, i, uint64(len(m.Query)))
i += copy(dAtA[i:], m.Query)
dAtA[i] = 0x12
i++
i = encodeVarintAppStats(dAtA, i, uint64(len(m.App)))
i += copy(dAtA[i:], m.App)
dAtA[i] = 0x18
i++
if m.DistSQL {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i++
dAtA[i] = 0x20
i++
if m.Failed {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i++
return i, nil
}
func (m *CollectedStatementStatistics) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *CollectedStatementStatistics) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintAppStats(dAtA, i, uint64(m.Key.Size()))
n7, err := m.Key.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n7
dAtA[i] = 0x12
i++
i = encodeVarintAppStats(dAtA, i, uint64(m.Stats.Size()))
n8, err := m.Stats.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n8
return i, nil
}
func encodeFixed64AppStats(dAtA []byte, offset int, v uint64) int {
dAtA[offset] = uint8(v)
dAtA[offset+1] = uint8(v >> 8)
dAtA[offset+2] = uint8(v >> 16)
dAtA[offset+3] = uint8(v >> 24)
dAtA[offset+4] = uint8(v >> 32)
dAtA[offset+5] = uint8(v >> 40)
dAtA[offset+6] = uint8(v >> 48)
dAtA[offset+7] = uint8(v >> 56)
return offset + 8
}
func encodeFixed32AppStats(dAtA []byte, offset int, v uint32) int {
dAtA[offset] = uint8(v)
dAtA[offset+1] = uint8(v >> 8)
dAtA[offset+2] = uint8(v >> 16)
dAtA[offset+3] = uint8(v >> 24)
return offset + 4
}
func encodeVarintAppStats(dAtA []byte, offset int, v uint64) int {
for v >= 1<<7 {
dAtA[offset] = uint8(v&0x7f | 0x80)
v >>= 7
offset++
}
dAtA[offset] = uint8(v)
return offset + 1
}
func (m *StatementStatistics) Size() (n int) {
var l int
_ = l
n += 1 + sovAppStats(uint64(m.Count))
n += 1 + sovAppStats(uint64(m.FirstAttemptCount))
n += 1 + sovAppStats(uint64(m.MaxRetries))
l = len(m.LastErr)
n += 1 + l + sovAppStats(uint64(l))
l = m.NumRows.Size()
n += 1 + l + sovAppStats(uint64(l))
l = m.ParseLat.Size()
n += 1 + l + sovAppStats(uint64(l))
l = m.PlanLat.Size()
n += 1 + l + sovAppStats(uint64(l))
l = m.RunLat.Size()
n += 1 + l + sovAppStats(uint64(l))
l = m.ServiceLat.Size()
n += 1 + l + sovAppStats(uint64(l))
l = m.OverheadLat.Size()
n += 1 + l + sovAppStats(uint64(l))
return n
}
func (m *NumericStat) Size() (n int) {
var l int
_ = l
n += 9
n += 9
return n
}
func (m *StatementStatisticsKey) Size() (n int) {
var l int
_ = l
l = len(m.Query)
n += 1 + l + sovAppStats(uint64(l))
l = len(m.App)
n += 1 + l + sovAppStats(uint64(l))
n += 2
n += 2
return n
}
func (m *CollectedStatementStatistics) Size() (n int) {
var l int
_ = l
l = m.Key.Size()
n += 1 + l + sovAppStats(uint64(l))
l = m.Stats.Size()
n += 1 + l + sovAppStats(uint64(l))
return n
}
func sovAppStats(x uint64) (n int) {
for {
n++
x >>= 7
if x == 0 {
break
}
}
return n
}
func sozAppStats(x uint64) (n int) {
return sovAppStats(uint64((x << 1) ^ uint64((int64(x) >> 63))))
}
func (m *StatementStatistics) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowAppStats
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: StatementStatistics: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: StatementStatistics: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Count", wireType)
}
m.Count = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowAppStats
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Count |= (int64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
case 2:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field FirstAttemptCount", wireType)
}
m.FirstAttemptCount = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowAppStats
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.FirstAttemptCount |= (int64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
case 3:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field MaxRetries", wireType)
}
m.MaxRetries = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowAppStats
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.MaxRetries |= (int64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
case 4:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field LastErr", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowAppStats
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthAppStats
}
postIndex := iNdEx + intStringLen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.LastErr = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 5:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field NumRows", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowAppStats
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthAppStats
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.NumRows.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 6:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ParseLat", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowAppStats
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthAppStats
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.ParseLat.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 7:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field PlanLat", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowAppStats
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthAppStats
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.PlanLat.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 8:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field RunLat", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowAppStats
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthAppStats
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.RunLat.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 9:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ServiceLat", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowAppStats
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthAppStats
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.ServiceLat.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 10:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field OverheadLat", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowAppStats
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthAppStats
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.OverheadLat.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipAppStats(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthAppStats
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *NumericStat) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowAppStats
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: NumericStat: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: NumericStat: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 1 {
return fmt.Errorf("proto: wrong wireType = %d for field Mean", wireType)
}
var v uint64
if (iNdEx + 8) > l {
return io.ErrUnexpectedEOF
}
iNdEx += 8
v = uint64(dAtA[iNdEx-8])
v |= uint64(dAtA[iNdEx-7]) << 8
v |= uint64(dAtA[iNdEx-6]) << 16
v |= uint64(dAtA[iNdEx-5]) << 24
v |= uint64(dAtA[iNdEx-4]) << 32
v |= uint64(dAtA[iNdEx-3]) << 40
v |= uint64(dAtA[iNdEx-2]) << 48
v |= uint64(dAtA[iNdEx-1]) << 56
m.Mean = float64(math.Float64frombits(v))
case 2:
if wireType != 1 {
return fmt.Errorf("proto: wrong wireType = %d for field SquaredDiffs", wireType)
}
var v uint64
if (iNdEx + 8) > l {
return io.ErrUnexpectedEOF
}
iNdEx += 8
v = uint64(dAtA[iNdEx-8])
v |= uint64(dAtA[iNdEx-7]) << 8
v |= uint64(dAtA[iNdEx-6]) << 16
v |= uint64(dAtA[iNdEx-5]) << 24
v |= uint64(dAtA[iNdEx-4]) << 32
v |= uint64(dAtA[iNdEx-3]) << 40
v |= uint64(dAtA[iNdEx-2]) << 48
v |= uint64(dAtA[iNdEx-1]) << 56
m.SquaredDiffs = float64(math.Float64frombits(v))
default:
iNdEx = preIndex
skippy, err := skipAppStats(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthAppStats
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *StatementStatisticsKey) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowAppStats
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: StatementStatisticsKey: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: StatementStatisticsKey: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Query", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowAppStats
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthAppStats
}
postIndex := iNdEx + intStringLen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Query = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field App", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowAppStats
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthAppStats
}
postIndex := iNdEx + intStringLen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.App = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 3:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field DistSQL", wireType)
}
var v int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowAppStats
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
v |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
m.DistSQL = bool(v != 0)
case 4:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Failed", wireType)
}
var v int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowAppStats
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
v |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
m.Failed = bool(v != 0)
default:
iNdEx = preIndex
skippy, err := skipAppStats(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthAppStats
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *CollectedStatementStatistics) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowAppStats
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: CollectedStatementStatistics: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: CollectedStatementStatistics: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Key", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowAppStats
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthAppStats
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Key.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Stats", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowAppStats
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthAppStats
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Stats.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipAppStats(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthAppStats
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func skipAppStats(dAtA []byte) (n int, err error) {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowAppStats
}
if iNdEx >= l {
return 0, io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
wireType := int(wire & 0x7)
switch wireType {
case 0:
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowAppStats
}
if iNdEx >= l {
return 0, io.ErrUnexpectedEOF
}
iNdEx++
if dAtA[iNdEx-1] < 0x80 {
break
}
}
return iNdEx, nil
case 1:
iNdEx += 8
return iNdEx, nil
case 2:
var length int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowAppStats
}
if iNdEx >= l {
return 0, io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
length |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
iNdEx += length
if length < 0 {
return 0, ErrInvalidLengthAppStats
}
return iNdEx, nil
case 3:
for {
var innerWire uint64
var start int = iNdEx
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowAppStats
}
if iNdEx >= l {
return 0, io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
innerWire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
innerWireType := int(innerWire & 0x7)
if innerWireType == 4 {
break
}
next, err := skipAppStats(dAtA[start:])
if err != nil {
return 0, err
}
iNdEx = start + next
}
return iNdEx, nil
case 4:
return iNdEx, nil
case 5:
iNdEx += 4
return iNdEx, nil
default:
return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
}
}
panic("unreachable")
}
var (
ErrInvalidLengthAppStats = fmt.Errorf("proto: negative length found during unmarshaling")
ErrIntOverflowAppStats = fmt.Errorf("proto: integer overflow")
)
func init() { proto.RegisterFile("cockroach/pkg/roachpb/app_stats.proto", fileDescriptorAppStats) }
var fileDescriptorAppStats = []byte{
// 518 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x94, 0xcf, 0x6e, 0xd3, 0x40,
0x10, 0xc6, 0xb3, 0xe4, 0xff, 0xb8, 0x3d, 0xb0, 0x45, 0x95, 0x15, 0x55, 0x6e, 0x88, 0x14, 0x29,
0x5c, 0x12, 0x29, 0xe2, 0x82, 0x50, 0x91, 0xda, 0xc0, 0x89, 0x08, 0x89, 0xf4, 0xc6, 0xc5, 0x5a,
0xec, 0x49, 0x6a, 0xc5, 0xf6, 0x6e, 0x76, 0xd7, 0x6d, 0xf3, 0x0a, 0x9c, 0x78, 0x01, 0x9e, 0x80,
0x17, 0xc9, 0x91, 0x23, 0x27, 0x04, 0xe1, 0x45, 0xd0, 0xae, 0x6d, 0x14, 0x50, 0xa4, 0xe6, 0xb6,
0xfa, 0xe6, 0xfb, 0xcd, 0xce, 0x24, 0xdf, 0x1a, 0xfa, 0x01, 0x0f, 0x96, 0x92, 0xb3, 0xe0, 0x66,
0x24, 0x96, 0x8b, 0x91, 0x3d, 0x89, 0x8f, 0x23, 0x26, 0x84, 0xaf, 0x34, 0xd3, 0x6a, 0x28, 0x24,
0xd7, 0x9c, 0x1e, 0xff, 0xb5, 0x0d, 0xd5, 0x2a, 0xee, 0x3c, 0x59, 0xf0, 0x05, 0xb7, 0x95, 0x91,
0x39, 0xe5, 0xa6, 0xde, 0xd7, 0x1a, 0x9c, 0x5c, 0x6b, 0xa6, 0x31, 0xc1, 0x54, 0x9b, 0x43, 0xa4,
0x74, 0x14, 0x28, 0xda, 0x81, 0x7a, 0xc0, 0xb3, 0x54, 0xbb, 0xa4, 0x4b, 0x06, 0xd5, 0xab, 0xda,
0xe6, 0xc7, 0x79, 0x65, 0x96, 0x4b, 0xf4, 0x39, 0x9c, 0xcc, 0x23, 0xa9, 0xb4, 0xcf, 0xb4, 0xc6,
0x44, 0x68, 0x3f, 0x77, 0x3e, 0xda, 0x71, 0x3e, 0xb6, 0x86, 0xcb, 0xbc, 0x3e, 0xb1, 0x54, 0x1f,
0x9c, 0x84, 0xdd, 0xfb, 0x12, 0xb5, 0x8c, 0x50, 0xb9, 0xd5, 0x1d, 0x37, 0x24, 0xec, 0x7e, 0x96,
0xeb, 0xf4, 0x1c, 0x5a, 0x31, 0x53, 0xda, 0x47, 0x29, 0xdd, 0x5a, 0x97, 0x0c, 0xda, 0x85, 0xa7,
0x69, 0xd4, 0x37, 0x52, 0xd2, 0x97, 0xd0, 0x4a, 0xb3, 0xc4, 0x97, 0xfc, 0x4e, 0xb9, 0xf5, 0x2e,
0x19, 0x38, 0xe3, 0xce, 0xf0, 0x9f, 0x4d, 0x87, 0xef, 0xb2, 0x04, 0x65, 0x14, 0x98, 0x6d, 0x4a,
0x38, 0xcd, 0x92, 0x19, 0xbf, 0x53, 0xf4, 0x02, 0xda, 0x82, 0x49, 0x85, 0x7e, 0xcc, 0xb4, 0xdb,
0x38, 0x90, 0x6e, 0x59, 0x64, 0xca, 0xb4, 0xb9, 0x5b, 0xc4, 0x2c, 0xb5, 0x74, 0xf3, 0xd0, 0xbb,
0x0d, 0x61, 0xe0, 0x17, 0xd0, 0x94, 0x59, 0xce, 0xb6, 0x0e, 0x64, 0x1b, 0x32, 0xb3, 0xe8, 0x25,
0x38, 0x0a, 0xe5, 0x6d, 0x14, 0xe4, 0x83, 0xb7, 0x0f, 0xc4, 0xa1, 0x80, 0x4c, 0x8b, 0x09, 0x1c,
0xf1, 0x5b, 0x94, 0x37, 0xc8, 0x42, 0xdb, 0x03, 0x0e, 0xec, 0xe1, 0x94, 0xd4, 0x94, 0xe9, 0xde,
0x0c, 0x9c, 0x1d, 0x07, 0x75, 0xa1, 0x96, 0x20, 0x4b, 0x6d, 0x46, 0x48, 0xe1, 0xb7, 0x0a, 0x7d,
0x06, 0xc7, 0x6a, 0x95, 0x31, 0x89, 0xa1, 0x1f, 0x46, 0xf3, 0xb9, 0xb2, 0xe1, 0x28, 0x2d, 0x47,
0x45, 0xe9, 0xb5, 0xa9, 0xf4, 0x3e, 0x11, 0x38, 0xdd, 0x93, 0xc0, 0xb7, 0xb8, 0x36, 0x21, 0x5c,
0x65, 0x28, 0xd7, 0xf6, 0x82, 0x32, 0x08, 0xb9, 0x44, 0x4f, 0xa1, 0xca, 0x84, 0xb0, 0x7d, 0xcb,
0x8a, 0x11, 0xa8, 0x07, 0xcd, 0x30, 0x52, 0xfa, 0xfa, 0xfd, 0xd4, 0x46, 0xac, 0x55, 0xfe, 0x0b,
0x85, 0x48, 0xcf, 0xa0, 0x31, 0x67, 0x51, 0x8c, 0xa1, 0x4d, 0x57, 0x59, 0x2e, 0xb4, 0xde, 0x17,
0x02, 0x67, 0x13, 0x1e, 0xc7, 0x18, 0x68, 0x0c, 0xf7, 0xbd, 0x8b, 0x0b, 0xa8, 0x2e, 0x31, 0x1f,
0xc8, 0x19, 0xf7, 0xff, 0xfb, 0xf5, 0xf6, 0xaf, 0x51, 0x4e, 0xb7, 0xc4, 0x35, 0x7d, 0x05, 0x75,
0xfb, 0x44, 0xed, 0xdc, 0xce, 0xb8, 0xf7, 0x70, 0x83, 0x72, 0x6b, 0x8b, 0x5d, 0x3d, 0xdd, 0xfc,
0xf2, 0x2a, 0x9b, 0xad, 0x47, 0xbe, 0x6d, 0x3d, 0xf2, 0x7d, 0xeb, 0x91, 0x9f, 0x5b, 0x8f, 0x7c,
0xfe, 0xed, 0x55, 0x3e, 0x34, 0x8b, 0xcf, 0xc0, 0x9f, 0x00, 0x00, 0x00, 0xff, 0xff, 0xf8, 0x18,
0x0f, 0xe9, 0x1e, 0x04, 0x00, 0x00,
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。