statspb

package
v0.6.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 1, 2018 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package statspb is a generated protocol buffer package.

It is generated from these files: 

statspb.proto

It has these top-level messages: 

ClusterStats
DatabaseStats
TableStats
TaskInfo
HotSpotStats
ScheduleCount
DiskStats
NetStats
MemStats
TpStats
SlowLog
SlowLogStats
DsInfo
ProcessStats
MacStats
RangeStats
ReplicaStatus
RaftStatus
SqlStats
SqlSlowlog
SqlSlow
SqlTp
RangeInfo

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthStatspb = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStatspb   = fmt.Errorf("proto: integer overflow")
)
View Source 
var TpArgs_name = map[int32]string{
	0:    "invalid",
	1000: "msec_index",
	1060: "sec_index",
	1061: "min_index",
}
View Source 
var TpArgs_value = map[string]int32{
	"invalid":    0,
	"msec_index": 1000,
	"sec_index":  1060,
	"min_index":  1061,
}

Functions

This section is empty.

Types

type ClusterStats 

type ClusterStats struct {
	CapacityTotal      uint64  `protobuf:"varint,1,opt,name=capacity_total,json=capacityTotal,proto3" json:"capacity_total,omitempty"`
	SizeUsed           uint64  `protobuf:"varint,2,opt,name=size_used,json=sizeUsed,proto3" json:"size_used,omitempty"`
	RangeNum           uint64  `protobuf:"varint,3,opt,name=range_num,json=rangeNum,proto3" json:"range_num,omitempty"`
	DbNum              uint64  `protobuf:"varint,4,opt,name=db_num,json=dbNum,proto3" json:"db_num,omitempty"`
	TableNum           uint64  `protobuf:"varint,5,opt,name=table_num,json=tableNum,proto3" json:"table_num,omitempty"`
	TaskNum            uint64  `protobuf:"varint,6,opt,name=task_num,json=taskNum,proto3" json:"task_num,omitempty"`
	NodeUpCount        uint64  `protobuf:"varint,7,opt,name=node_up_count,json=nodeUpCount,proto3" json:"node_up_count,omitempty"`
	NodeDownCount      uint64  `protobuf:"varint,8,opt,name=node_down_count,json=nodeDownCount,proto3" json:"node_down_count,omitempty"`
	NodeOfflineCount   uint64  `protobuf:"varint,9,opt,name=node_offline_count,json=nodeOfflineCount,proto3" json:"node_offline_count,omitempty"`
	NodeTombstoneCount uint64  `protobuf:"varint,10,opt,name=node_tombstone_count,json=nodeTombstoneCount,proto3" json:"node_tombstone_count,omitempty"`
	LeaderBalanceRatio float64 `protobuf:"fixed64,11,opt,name=leader_balance_ratio,json=leaderBalanceRatio,proto3" json:"leader_balance_ratio,omitempty"`
	RegionBalanceRatio float64 `protobuf:"fixed64,12,opt,name=region_balance_ratio,json=regionBalanceRatio,proto3" json:"region_balance_ratio,omitempty"`
}

func (*ClusterStats) Descriptor 

func (*ClusterStats) Descriptor() ([]byte, []int)

func (*ClusterStats) GetCapacityTotal 

func (m *ClusterStats) GetCapacityTotal() uint64

func (*ClusterStats) GetDbNum 

func (m *ClusterStats) GetDbNum() uint64

func (*ClusterStats) GetLeaderBalanceRatio 

func (m *ClusterStats) GetLeaderBalanceRatio() float64

func (*ClusterStats) GetNodeDownCount 

func (m *ClusterStats) GetNodeDownCount() uint64

func (*ClusterStats) GetNodeOfflineCount 

func (m *ClusterStats) GetNodeOfflineCount() uint64

func (*ClusterStats) GetNodeTombstoneCount 

func (m *ClusterStats) GetNodeTombstoneCount() uint64

func (*ClusterStats) GetNodeUpCount 

func (m *ClusterStats) GetNodeUpCount() uint64

func (*ClusterStats) GetRangeNum 

func (m *ClusterStats) GetRangeNum() uint64

func (*ClusterStats) GetRegionBalanceRatio 

func (m *ClusterStats) GetRegionBalanceRatio() float64

func (*ClusterStats) GetSizeUsed 

func (m *ClusterStats) GetSizeUsed() uint64

func (*ClusterStats) GetTableNum 

func (m *ClusterStats) GetTableNum() uint64

func (*ClusterStats) GetTaskNum 

func (m *ClusterStats) GetTaskNum() uint64

func (*ClusterStats) Marshal 

func (m *ClusterStats) Marshal() (dAtA []byte, err error)

func (*ClusterStats) MarshalTo 

func (m *ClusterStats) MarshalTo(dAtA []byte) (int, error)

func (*ClusterStats) ProtoMessage 

func (*ClusterStats) ProtoMessage()

func (*ClusterStats) Reset 

func (m *ClusterStats) Reset()

func (*ClusterStats) Size 

func (m *ClusterStats) Size() (n int)

func (*ClusterStats) String 

func (m *ClusterStats) String() string

func (*ClusterStats) Unmarshal 

func (m *ClusterStats) Unmarshal(dAtA []byte) error

type DatabaseStats 

type DatabaseStats struct {
	Name     string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	TableNum uint32 `protobuf:"varint,2,opt,name=table_num,json=tableNum,proto3" json:"table_num,omitempty"`
}

func (*DatabaseStats) Descriptor 

func (*DatabaseStats) Descriptor() ([]byte, []int)

func (*DatabaseStats) GetName 

func (m *DatabaseStats) GetName() string

func (*DatabaseStats) GetTableNum 

func (m *DatabaseStats) GetTableNum() uint32

func (*DatabaseStats) Marshal 

func (m *DatabaseStats) Marshal() (dAtA []byte, err error)

func (*DatabaseStats) MarshalTo 

func (m *DatabaseStats) MarshalTo(dAtA []byte) (int, error)

func (*DatabaseStats) ProtoMessage 

func (*DatabaseStats) ProtoMessage()

func (*DatabaseStats) Reset 

func (m *DatabaseStats) Reset()

func (*DatabaseStats) Size 

func (m *DatabaseStats) Size() (n int)

func (*DatabaseStats) String 

func (m *DatabaseStats) String() string

func (*DatabaseStats) Unmarshal 

func (m *DatabaseStats) Unmarshal(dAtA []byte) error

type DiskStats 

type DiskStats struct {
	DiskPath             string  `protobuf:"bytes,1,opt,name=disk_path,json=diskPath,proto3" json:"disk_path,omitempty"`
	DiskTotal            uint64  `protobuf:"varint,2,opt,name=disk_total,json=diskTotal,proto3" json:"disk_total,omitempty"`
	DiskUsed             uint64  `protobuf:"varint,3,opt,name=disk_used,json=diskUsed,proto3" json:"disk_used,omitempty"`
	DiskFree             uint64  `protobuf:"varint,4,opt,name=disk_free,json=diskFree,proto3" json:"disk_free,omitempty"`
	DiskProcRate         float64 `protobuf:"fixed64,5,opt,name=disk_proc_rate,json=diskProcRate,proto3" json:"disk_proc_rate,omitempty"`
	DiskReadBytePerSec   uint64  `protobuf:"varint,6,opt,name=disk_read_byte_per_sec,json=diskReadBytePerSec,proto3" json:"disk_read_byte_per_sec,omitempty"`
	DiskWriteBytePerSec  uint64  `protobuf:"varint,7,opt,name=disk_write_byte_per_sec,json=diskWriteBytePerSec,proto3" json:"disk_write_byte_per_sec,omitempty"`
	DiskReadCountPerSec  uint64  `protobuf:"varint,8,opt,name=disk_read_count_per_sec,json=diskReadCountPerSec,proto3" json:"disk_read_count_per_sec,omitempty"`
	DiskWriteCountPerSec uint64  `` /* 128-byte string literal not displayed */
}

func (*DiskStats) Descriptor 

func (*DiskStats) Descriptor() ([]byte, []int)

func (*DiskStats) GetDiskFree 

func (m *DiskStats) GetDiskFree() uint64

func (*DiskStats) GetDiskPath 

func (m *DiskStats) GetDiskPath() string

func (*DiskStats) GetDiskProcRate 

func (m *DiskStats) GetDiskProcRate() float64

func (*DiskStats) GetDiskReadBytePerSec 

func (m *DiskStats) GetDiskReadBytePerSec() uint64

func (*DiskStats) GetDiskReadCountPerSec 

func (m *DiskStats) GetDiskReadCountPerSec() uint64

func (*DiskStats) GetDiskTotal 

func (m *DiskStats) GetDiskTotal() uint64

func (*DiskStats) GetDiskUsed 

func (m *DiskStats) GetDiskUsed() uint64

func (*DiskStats) GetDiskWriteBytePerSec 

func (m *DiskStats) GetDiskWriteBytePerSec() uint64

func (*DiskStats) GetDiskWriteCountPerSec 

func (m *DiskStats) GetDiskWriteCountPerSec() uint64

func (*DiskStats) Marshal 

func (m *DiskStats) Marshal() (dAtA []byte, err error)

func (*DiskStats) MarshalTo 

func (m *DiskStats) MarshalTo(dAtA []byte) (int, error)

func (*DiskStats) ProtoMessage 

func (*DiskStats) ProtoMessage()

func (*DiskStats) Reset 

func (m *DiskStats) Reset()

func (*DiskStats) Size 

func (m *DiskStats) Size() (n int)

func (*DiskStats) String 

func (m *DiskStats) String() string

func (*DiskStats) Unmarshal 

func (m *DiskStats) Unmarshal(dAtA []byte) error

type DsInfo 

type DsInfo struct {
	// Total range count in this store.
	RangeCount uint64 `protobuf:"varint,1,opt,name=range_count,json=rangeCount,proto3" json:"range_count,omitempty"`
	// Current range split count.
	RangeSplitCount uint32 `protobuf:"varint,2,opt,name=range_split_count,json=rangeSplitCount,proto3" json:"range_split_count,omitempty"`
	// Current sending snapshot count.
	SendingSnapCount uint32 `protobuf:"varint,3,opt,name=sending_snap_count,json=sendingSnapCount,proto3" json:"sending_snap_count,omitempty"`
	// Current receiving snapshot count.
	ReceivingSnapCount uint32 `protobuf:"varint,4,opt,name=receiving_snap_count,json=receivingSnapCount,proto3" json:"receiving_snap_count,omitempty"`
	// How many range is applying snapshot.
	ApplyingSnapCount uint32 `protobuf:"varint,5,opt,name=applying_snap_count,json=applyingSnapCount,proto3" json:"applying_snap_count,omitempty"`
	RangeLeaderCount  uint32 `protobuf:"varint,6,opt,name=range_leader_count,json=rangeLeaderCount,proto3" json:"range_leader_count,omitempty"`
	// ds version for update
	Version string `protobuf:"bytes,7,opt,name=version,proto3" json:"version,omitempty"`
}

func (*DsInfo) Descriptor 

func (*DsInfo) Descriptor() ([]byte, []int)

func (*DsInfo) GetApplyingSnapCount 

func (m *DsInfo) GetApplyingSnapCount() uint32

func (*DsInfo) GetRangeCount 

func (m *DsInfo) GetRangeCount() uint64

func (*DsInfo) GetRangeLeaderCount 

func (m *DsInfo) GetRangeLeaderCount() uint32

func (*DsInfo) GetRangeSplitCount 

func (m *DsInfo) GetRangeSplitCount() uint32

func (*DsInfo) GetReceivingSnapCount 

func (m *DsInfo) GetReceivingSnapCount() uint32

func (*DsInfo) GetSendingSnapCount 

func (m *DsInfo) GetSendingSnapCount() uint32

func (*DsInfo) GetVersion 

func (m *DsInfo) GetVersion() string

func (*DsInfo) Marshal 

func (m *DsInfo) Marshal() (dAtA []byte, err error)

func (*DsInfo) MarshalTo 

func (m *DsInfo) MarshalTo(dAtA []byte) (int, error)

func (*DsInfo) ProtoMessage 

func (*DsInfo) ProtoMessage()

func (*DsInfo) Reset 

func (m *DsInfo) Reset()

func (*DsInfo) Size 

func (m *DsInfo) Size() (n int)

func (*DsInfo) String 

func (m *DsInfo) String() string

func (*DsInfo) Unmarshal 

func (m *DsInfo) Unmarshal(dAtA []byte) error

type HotSpotStats 

type HotSpotStats struct {
	NodeId                    uint64  `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	NodeAddr                  string  `protobuf:"bytes,2,opt,name=node_addr,json=nodeAddr,proto3" json:"node_addr,omitempty"`
	TotalWrittenBytesAsPeer   float64 `` /* 138-byte string literal not displayed */
	HotWriteRegionAsPeer      uint64  `` /* 128-byte string literal not displayed */
	TotalWrittenBytesAsLeader float64 `` /* 144-byte string literal not displayed */
	HotWriteRegionAsLeader    uint64  `` /* 134-byte string literal not displayed */
}

func (*HotSpotStats) Descriptor 

func (*HotSpotStats) Descriptor() ([]byte, []int)

func (*HotSpotStats) GetHotWriteRegionAsLeader 

func (m *HotSpotStats) GetHotWriteRegionAsLeader() uint64

func (*HotSpotStats) GetHotWriteRegionAsPeer 

func (m *HotSpotStats) GetHotWriteRegionAsPeer() uint64

func (*HotSpotStats) GetNodeAddr 

func (m *HotSpotStats) GetNodeAddr() string

func (*HotSpotStats) GetNodeId 

func (m *HotSpotStats) GetNodeId() uint64

func (*HotSpotStats) GetTotalWrittenBytesAsLeader 

func (m *HotSpotStats) GetTotalWrittenBytesAsLeader() float64

func (*HotSpotStats) GetTotalWrittenBytesAsPeer 

func (m *HotSpotStats) GetTotalWrittenBytesAsPeer() float64

func (*HotSpotStats) Marshal 

func (m *HotSpotStats) Marshal() (dAtA []byte, err error)

func (*HotSpotStats) MarshalTo 

func (m *HotSpotStats) MarshalTo(dAtA []byte) (int, error)

func (*HotSpotStats) ProtoMessage 

func (*HotSpotStats) ProtoMessage()

func (*HotSpotStats) Reset 

func (m *HotSpotStats) Reset()

func (*HotSpotStats) Size 

func (m *HotSpotStats) Size() (n int)

func (*HotSpotStats) String 

func (m *HotSpotStats) String() string

func (*HotSpotStats) Unmarshal 

func (m *HotSpotStats) Unmarshal(dAtA []byte) error

type MacStats 

type MacStats struct {
	CpuProcRate float64   `protobuf:"fixed64,1,opt,name=cpu_proc_rate,json=cpuProcRate,proto3" json:"cpu_proc_rate,omitempty"`
	CpuCount    uint32    `protobuf:"varint,2,opt,name=cpu_count,json=cpuCount,proto3" json:"cpu_count,omitempty"`
	Load1       float64   `protobuf:"fixed64,3,opt,name=load1,proto3" json:"load1,omitempty"`
	Load5       float64   `protobuf:"fixed64,4,opt,name=load5,proto3" json:"load5,omitempty"`
	Load15      float64   `protobuf:"fixed64,5,opt,name=load15,proto3" json:"load15,omitempty"`
	MemStats    *MemStats `protobuf:"bytes,6,opt,name=mem_stats,json=memStats" json:"mem_stats,omitempty"`
	NetStats    *NetStats `protobuf:"bytes,7,opt,name=net_stats,json=netStats" json:"net_stats,omitempty"`
	// 多个磁盘的统计情况
	DiskStats []*DiskStats `protobuf:"bytes,8,rep,name=disk_stats,json=diskStats" json:"disk_stats,omitempty"`
	// 进程数
	ProcessNum uint32 `protobuf:"varint,9,opt,name=process_num,json=processNum,proto3" json:"process_num,omitempty"`
	// 线程数
	ThreadNum uint32 `protobuf:"varint,10,opt,name=thread_num,json=threadNum,proto3" json:"thread_num,omitempty"`
	// 句柄数
	HandleNum uint32 `protobuf:"varint,11,opt,name=handle_num,json=handleNum,proto3" json:"handle_num,omitempty"`
}

func (*MacStats) Descriptor 

func (*MacStats) Descriptor() ([]byte, []int)

func (*MacStats) GetCpuCount 

func (m *MacStats) GetCpuCount() uint32

func (*MacStats) GetCpuProcRate 

func (m *MacStats) GetCpuProcRate() float64

func (*MacStats) GetDiskStats 

func (m *MacStats) GetDiskStats() []*DiskStats

func (*MacStats) GetHandleNum 

func (m *MacStats) GetHandleNum() uint32

func (*MacStats) GetLoad1 

func (m *MacStats) GetLoad1() float64

func (*MacStats) GetLoad15 

func (m *MacStats) GetLoad15() float64

func (*MacStats) GetLoad5 

func (m *MacStats) GetLoad5() float64

func (*MacStats) GetMemStats 

func (m *MacStats) GetMemStats() *MemStats

func (*MacStats) GetNetStats 

func (m *MacStats) GetNetStats() *NetStats

func (*MacStats) GetProcessNum 

func (m *MacStats) GetProcessNum() uint32

func (*MacStats) GetThreadNum 

func (m *MacStats) GetThreadNum() uint32

func (*MacStats) Marshal 

func (m *MacStats) Marshal() (dAtA []byte, err error)

func (*MacStats) MarshalTo 

func (m *MacStats) MarshalTo(dAtA []byte) (int, error)

func (*MacStats) ProtoMessage 

func (*MacStats) ProtoMessage()

func (*MacStats) Reset 

func (m *MacStats) Reset()

func (*MacStats) Size 

func (m *MacStats) Size() (n int)

func (*MacStats) String 

func (m *MacStats) String() string

func (*MacStats) Unmarshal 

func (m *MacStats) Unmarshal(dAtA []byte) error

type MemStats 

type MemStats struct {
	MemoryTotal           uint64  `protobuf:"varint,1,opt,name=memory_total,json=memoryTotal,proto3" json:"memory_total,omitempty"`
	MemoryUsedRss         uint64  `protobuf:"varint,2,opt,name=memory_used_rss,json=memoryUsedRss,proto3" json:"memory_used_rss,omitempty"`
	MemoryUsed            uint64  `protobuf:"varint,3,opt,name=memory_used,json=memoryUsed,proto3" json:"memory_used,omitempty"`
	MemoryFree            uint64  `protobuf:"varint,4,opt,name=memory_free,json=memoryFree,proto3" json:"memory_free,omitempty"`
	MemoryUsedPercent     float64 `protobuf:"fixed64,5,opt,name=memory_used_percent,json=memoryUsedPercent,proto3" json:"memory_used_percent,omitempty"`
	SwapMemoryTotal       uint64  `protobuf:"varint,6,opt,name=swap_memory_total,json=swapMemoryTotal,proto3" json:"swap_memory_total,omitempty"`
	SwapMemoryUsed        uint64  `protobuf:"varint,7,opt,name=swap_memory_used,json=swapMemoryUsed,proto3" json:"swap_memory_used,omitempty"`
	SwapMemoryFree        uint64  `protobuf:"varint,8,opt,name=swap_memory_free,json=swapMemoryFree,proto3" json:"swap_memory_free,omitempty"`
	SwapMemoryUsedPercent float64 `` /* 130-byte string literal not displayed */
}

func (*MemStats) Descriptor 

func (*MemStats) Descriptor() ([]byte, []int)

func (*MemStats) GetMemoryFree 

func (m *MemStats) GetMemoryFree() uint64

func (*MemStats) GetMemoryTotal 

func (m *MemStats) GetMemoryTotal() uint64

func (*MemStats) GetMemoryUsed 

func (m *MemStats) GetMemoryUsed() uint64

func (*MemStats) GetMemoryUsedPercent 

func (m *MemStats) GetMemoryUsedPercent() float64

func (*MemStats) GetMemoryUsedRss 

func (m *MemStats) GetMemoryUsedRss() uint64

func (*MemStats) GetSwapMemoryFree 

func (m *MemStats) GetSwapMemoryFree() uint64

func (*MemStats) GetSwapMemoryTotal 

func (m *MemStats) GetSwapMemoryTotal() uint64

func (*MemStats) GetSwapMemoryUsed 

func (m *MemStats) GetSwapMemoryUsed() uint64

func (*MemStats) GetSwapMemoryUsedPercent 

func (m *MemStats) GetSwapMemoryUsedPercent() float64

func (*MemStats) Marshal 

func (m *MemStats) Marshal() (dAtA []byte, err error)

func (*MemStats) MarshalTo 

func (m *MemStats) MarshalTo(dAtA []byte) (int, error)

func (*MemStats) ProtoMessage 

func (*MemStats) ProtoMessage()

func (*MemStats) Reset 

func (m *MemStats) Reset()

func (*MemStats) Size 

func (m *MemStats) Size() (n int)

func (*MemStats) String 

func (m *MemStats) String() string

func (*MemStats) Unmarshal 

func (m *MemStats) Unmarshal(dAtA []byte) error

type NetStats 

type NetStats struct {
	NetIoInBytePerSec             uint64 `protobuf:"varint,1,opt,name=net_io_in_byte_per_sec,json=netIoInBytePerSec,proto3" json:"net_io_in_byte_per_sec,omitempty"`
	NetIoOutBytePerSec            uint64 `protobuf:"varint,2,opt,name=net_io_out_byte_per_sec,json=netIoOutBytePerSec,proto3" json:"net_io_out_byte_per_sec,omitempty"`
	NetIoInPackagePerSec          uint64 `` /* 130-byte string literal not displayed */
	NetIoOutPackagePerSec         uint64 `` /* 133-byte string literal not displayed */
	NetTcpConnections             uint32 `protobuf:"varint,5,opt,name=net_tcp_connections,json=netTcpConnections,proto3" json:"net_tcp_connections,omitempty"`
	NetTcpActiveOpensPerSec       uint64 `` /* 139-byte string literal not displayed */
	NetIpRecvPackagePerSec        uint64 `` /* 136-byte string literal not displayed */
	NetIpSendPackagePerSec        uint64 `` /* 136-byte string literal not displayed */
	NetIpDropPackagePerSec        uint64 `` /* 136-byte string literal not displayed */
	NetTcpRecvPackagePerSec       uint64 `` /* 140-byte string literal not displayed */
	NetTcpSendPackagePerSec       uint64 `` /* 140-byte string literal not displayed */
	NetTcpErrPackagePerSec        uint64 `` /* 137-byte string literal not displayed */
	NetTcpRetransferPackagePerSec uint64 `` /* 158-byte string literal not displayed */
}

func (*NetStats) Descriptor 

func (*NetStats) Descriptor() ([]byte, []int)

func (*NetStats) GetNetIoInBytePerSec 

func (m *NetStats) GetNetIoInBytePerSec() uint64

func (*NetStats) GetNetIoInPackagePerSec 

func (m *NetStats) GetNetIoInPackagePerSec() uint64

func (*NetStats) GetNetIoOutBytePerSec 

func (m *NetStats) GetNetIoOutBytePerSec() uint64

func (*NetStats) GetNetIoOutPackagePerSec 

func (m *NetStats) GetNetIoOutPackagePerSec() uint64

func (*NetStats) GetNetIpDropPackagePerSec 

func (m *NetStats) GetNetIpDropPackagePerSec() uint64

func (*NetStats) GetNetIpRecvPackagePerSec 

func (m *NetStats) GetNetIpRecvPackagePerSec() uint64

func (*NetStats) GetNetIpSendPackagePerSec 

func (m *NetStats) GetNetIpSendPackagePerSec() uint64

func (*NetStats) GetNetTcpActiveOpensPerSec 

func (m *NetStats) GetNetTcpActiveOpensPerSec() uint64

func (*NetStats) GetNetTcpConnections 

func (m *NetStats) GetNetTcpConnections() uint32

func (*NetStats) GetNetTcpErrPackagePerSec 

func (m *NetStats) GetNetTcpErrPackagePerSec() uint64

func (*NetStats) GetNetTcpRecvPackagePerSec 

func (m *NetStats) GetNetTcpRecvPackagePerSec() uint64

func (*NetStats) GetNetTcpRetransferPackagePerSec 

func (m *NetStats) GetNetTcpRetransferPackagePerSec() uint64

func (*NetStats) GetNetTcpSendPackagePerSec 

func (m *NetStats) GetNetTcpSendPackagePerSec() uint64

func (*NetStats) Marshal 

func (m *NetStats) Marshal() (dAtA []byte, err error)

func (*NetStats) MarshalTo 

func (m *NetStats) MarshalTo(dAtA []byte) (int, error)

func (*NetStats) ProtoMessage 

func (*NetStats) ProtoMessage()

func (*NetStats) Reset 

func (m *NetStats) Reset()

func (*NetStats) Size 

func (m *NetStats) Size() (n int)

func (*NetStats) String 

func (m *NetStats) String() string

func (*NetStats) Unmarshal 

func (m *NetStats) Unmarshal(dAtA []byte) error

type ProcessStats 

type ProcessStats struct {
	CpuProcRate float64 `protobuf:"fixed64,1,opt,name=cpu_proc_rate,json=cpuProcRate,proto3" json:"cpu_proc_rate,omitempty"`
	MemoryTotal uint64  `protobuf:"varint,2,opt,name=memory_total,json=memoryTotal,proto3" json:"memory_total,omitempty"`
	MemoryUsed  uint64  `protobuf:"varint,3,opt,name=memory_used,json=memoryUsed,proto3" json:"memory_used,omitempty"`
	// 客户端连接数
	ConnectCount uint64 `protobuf:"varint,4,opt,name=connect_count,json=connectCount,proto3" json:"connect_count,omitempty"`
	// 一般只有DS需要
	DiskStats *DiskStats `protobuf:"bytes,8,opt,name=disk_stats,json=diskStats" json:"disk_stats,omitempty"`
	TpStats   *TpStats   `protobuf:"bytes,9,opt,name=tp_stats,json=tpStats" json:"tp_stats,omitempty"`
	// 只有ds process需要统计这部分信息
	DsInfo *DsInfo `protobuf:"bytes,10,opt,name=ds_info,json=dsInfo" json:"ds_info,omitempty"`
	// 线程数 or 协程数
	ThreadNum uint32 `protobuf:"varint,11,opt,name=thread_num,json=threadNum,proto3" json:"thread_num,omitempty"`
	// 句柄数
	HandleNum uint32 `protobuf:"varint,12,opt,name=handle_num,json=handleNum,proto3" json:"handle_num,omitempty"`
	// When the data server is started (unix timestamp in seconds).
	StartTime int64 `protobuf:"varint,13,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
}

func (*ProcessStats) Descriptor 

func (*ProcessStats) Descriptor() ([]byte, []int)

func (*ProcessStats) GetConnectCount 

func (m *ProcessStats) GetConnectCount() uint64

func (*ProcessStats) GetCpuProcRate 

func (m *ProcessStats) GetCpuProcRate() float64

func (*ProcessStats) GetDiskStats 

func (m *ProcessStats) GetDiskStats() *DiskStats

func (*ProcessStats) GetDsInfo 

func (m *ProcessStats) GetDsInfo() *DsInfo

func (*ProcessStats) GetHandleNum 

func (m *ProcessStats) GetHandleNum() uint32

func (*ProcessStats) GetMemoryTotal 

func (m *ProcessStats) GetMemoryTotal() uint64

func (*ProcessStats) GetMemoryUsed 

func (m *ProcessStats) GetMemoryUsed() uint64

func (*ProcessStats) GetStartTime 

func (m *ProcessStats) GetStartTime() int64

func (*ProcessStats) GetThreadNum 

func (m *ProcessStats) GetThreadNum() uint32

func (*ProcessStats) GetTpStats 

func (m *ProcessStats) GetTpStats() *TpStats

func (*ProcessStats) Marshal 

func (m *ProcessStats) Marshal() (dAtA []byte, err error)

func (*ProcessStats) MarshalTo 

func (m *ProcessStats) MarshalTo(dAtA []byte) (int, error)

func (*ProcessStats) ProtoMessage 

func (*ProcessStats) ProtoMessage()

func (*ProcessStats) Reset 

func (m *ProcessStats) Reset()

func (*ProcessStats) Size 

func (m *ProcessStats) Size() (n int)

func (*ProcessStats) String 

func (m *ProcessStats) String() string

func (*ProcessStats) Unmarshal 

func (m *ProcessStats) Unmarshal(dAtA []byte) error

type RaftStatus 

type RaftStatus struct {
	ID                uint64           `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	NodeID            uint64           `protobuf:"varint,2,opt,name=NodeID,proto3" json:"NodeID,omitempty"`
	Leader            uint64           `protobuf:"varint,3,opt,name=Leader,proto3" json:"Leader,omitempty"`
	Term              uint64           `protobuf:"varint,4,opt,name=Term,proto3" json:"Term,omitempty"`
	Index             uint64           `protobuf:"varint,5,opt,name=Index,proto3" json:"Index,omitempty"`
	Commit            uint64           `protobuf:"varint,6,opt,name=Commit,proto3" json:"Commit,omitempty"`
	Applied           uint64           `protobuf:"varint,7,opt,name=Applied,proto3" json:"Applied,omitempty"`
	Vote              uint64           `protobuf:"varint,8,opt,name=Vote,proto3" json:"Vote,omitempty"`
	PendQueue         int32            `protobuf:"varint,9,opt,name=PendQueue,proto3" json:"PendQueue,omitempty"`
	RecvQueue         int32            `protobuf:"varint,10,opt,name=RecvQueue,proto3" json:"RecvQueue,omitempty"`
	AppQueue          int32            `protobuf:"varint,11,opt,name=AppQueue,proto3" json:"AppQueue,omitempty"`
	Stopped           bool             `protobuf:"varint,12,opt,name=Stopped,proto3" json:"Stopped,omitempty"`
	RestoringSnapshot bool             `protobuf:"varint,13,opt,name=RestoringSnapshot,proto3" json:"RestoringSnapshot,omitempty"`
	State             string           `protobuf:"bytes,14,opt,name=State,proto3" json:"State,omitempty"`
	Replicas          []*ReplicaStatus `protobuf:"bytes,15,rep,name=Replicas" json:"Replicas,omitempty"`
}

func (*RaftStatus) Descriptor 

func (*RaftStatus) Descriptor() ([]byte, []int)

func (*RaftStatus) GetAppQueue 

func (m *RaftStatus) GetAppQueue() int32

func (*RaftStatus) GetApplied 

func (m *RaftStatus) GetApplied() uint64

func (*RaftStatus) GetCommit 

func (m *RaftStatus) GetCommit() uint64

func (*RaftStatus) GetID 

func (m *RaftStatus) GetID() uint64

func (*RaftStatus) GetIndex 

func (m *RaftStatus) GetIndex() uint64

func (*RaftStatus) GetLeader 

func (m *RaftStatus) GetLeader() uint64

func (*RaftStatus) GetNodeID 

func (m *RaftStatus) GetNodeID() uint64

func (*RaftStatus) GetPendQueue 

func (m *RaftStatus) GetPendQueue() int32

func (*RaftStatus) GetRecvQueue 

func (m *RaftStatus) GetRecvQueue() int32

func (*RaftStatus) GetReplicas 

func (m *RaftStatus) GetReplicas() []*ReplicaStatus

func (*RaftStatus) GetRestoringSnapshot 

func (m *RaftStatus) GetRestoringSnapshot() bool

func (*RaftStatus) GetState 

func (m *RaftStatus) GetState() string

func (*RaftStatus) GetStopped 

func (m *RaftStatus) GetStopped() bool

func (*RaftStatus) GetTerm 

func (m *RaftStatus) GetTerm() uint64

func (*RaftStatus) GetVote 

func (m *RaftStatus) GetVote() uint64

func (*RaftStatus) Marshal 

func (m *RaftStatus) Marshal() (dAtA []byte, err error)

func (*RaftStatus) MarshalTo 

func (m *RaftStatus) MarshalTo(dAtA []byte) (int, error)

func (*RaftStatus) ProtoMessage 

func (*RaftStatus) ProtoMessage()

func (*RaftStatus) Reset 

func (m *RaftStatus) Reset()

func (*RaftStatus) Size 

func (m *RaftStatus) Size() (n int)

func (*RaftStatus) String 

func (m *RaftStatus) String() string

func (*RaftStatus) Unmarshal 

func (m *RaftStatus) Unmarshal(dAtA []byte) error

type RangeInfo 

type RangeInfo struct {
	RangeId   uint64           `protobuf:"varint,1,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"`
	LeaderId  uint64           `protobuf:"varint,2,opt,name=leader_id,json=leaderId,proto3" json:"leader_id,omitempty"`
	NodeAdder string           `protobuf:"bytes,3,opt,name=node_adder,json=nodeAdder,proto3" json:"node_adder,omitempty"`
	Stats     *mspb.RangeStats `protobuf:"bytes,4,opt,name=stats" json:"stats,omitempty"`
}

func (*RangeInfo) Descriptor 

func (*RangeInfo) Descriptor() ([]byte, []int)

func (*RangeInfo) GetLeaderId 

func (m *RangeInfo) GetLeaderId() uint64

func (*RangeInfo) GetNodeAdder 

func (m *RangeInfo) GetNodeAdder() string

func (*RangeInfo) GetRangeId 

func (m *RangeInfo) GetRangeId() uint64

func (*RangeInfo) GetStats 

func (m *RangeInfo) GetStats() *mspb.RangeStats

func (*RangeInfo) Marshal 

func (m *RangeInfo) Marshal() (dAtA []byte, err error)

func (*RangeInfo) MarshalTo 

func (m *RangeInfo) MarshalTo(dAtA []byte) (int, error)

func (*RangeInfo) ProtoMessage 

func (*RangeInfo) ProtoMessage()

func (*RangeInfo) Reset 

func (m *RangeInfo) Reset()

func (*RangeInfo) Size 

func (m *RangeInfo) Size() (n int)

func (*RangeInfo) String 

func (m *RangeInfo) String() string

func (*RangeInfo) Unmarshal 

func (m *RangeInfo) Unmarshal(dAtA []byte) error

type RangeStats 

type RangeStats struct {
	Size_                  uint64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	Ops                    uint64 `protobuf:"varint,2,opt,name=ops,proto3" json:"ops,omitempty"`
	BytesInPerSec          uint64 `protobuf:"varint,3,opt,name=bytes_in_per_sec,json=bytesInPerSec,proto3" json:"bytes_in_per_sec,omitempty"`
	BytesOutPerSec         uint64 `protobuf:"varint,4,opt,name=bytes_out_per_sec,json=bytesOutPerSec,proto3" json:"bytes_out_per_sec,omitempty"`
	TotalCommandsProcessed uint64 `` /* 130-byte string literal not displayed */
	KeyspaceMisses         uint64 `protobuf:"varint,6,opt,name=keyspace_misses,json=keyspaceMisses,proto3" json:"keyspace_misses,omitempty"`
}

func (*RangeStats) Descriptor 

func (*RangeStats) Descriptor() ([]byte, []int)

func (*RangeStats) GetBytesInPerSec 

func (m *RangeStats) GetBytesInPerSec() uint64

func (*RangeStats) GetBytesOutPerSec 

func (m *RangeStats) GetBytesOutPerSec() uint64

func (*RangeStats) GetKeyspaceMisses 

func (m *RangeStats) GetKeyspaceMisses() uint64

func (*RangeStats) GetOps 

func (m *RangeStats) GetOps() uint64

func (*RangeStats) GetSize_ 

func (m *RangeStats) GetSize_() uint64

func (*RangeStats) GetTotalCommandsProcessed 

func (m *RangeStats) GetTotalCommandsProcessed() uint64

func (*RangeStats) Marshal 

func (m *RangeStats) Marshal() (dAtA []byte, err error)

func (*RangeStats) MarshalTo 

func (m *RangeStats) MarshalTo(dAtA []byte) (int, error)

func (*RangeStats) ProtoMessage 

func (*RangeStats) ProtoMessage()

func (*RangeStats) Reset 

func (m *RangeStats) Reset()

func (*RangeStats) Size 

func (m *RangeStats) Size() (n int)

func (*RangeStats) String 

func (m *RangeStats) String() string

func (*RangeStats) Unmarshal 

func (m *RangeStats) Unmarshal(dAtA []byte) error

type ReplicaStatus 

type ReplicaStatus struct {
	Match       uint64 `protobuf:"varint,1,opt,name=Match,proto3" json:"Match,omitempty"`
	Commit      uint64 `protobuf:"varint,2,opt,name=Commit,proto3" json:"Commit,omitempty"`
	Next        uint64 `protobuf:"varint,3,opt,name=Next,proto3" json:"Next,omitempty"`
	State       string `protobuf:"bytes,4,opt,name=State,proto3" json:"State,omitempty"`
	Snapshoting bool   `protobuf:"varint,5,opt,name=Snapshoting,proto3" json:"Snapshoting,omitempty"`
	Paused      bool   `protobuf:"varint,6,opt,name=Paused,proto3" json:"Paused,omitempty"`
	Active      bool   `protobuf:"varint,7,opt,name=Active,proto3" json:"Active,omitempty"`
	LastActive  int64  `protobuf:"varint,8,opt,name=LastActive,proto3" json:"LastActive,omitempty"`
	Inflight    int32  `protobuf:"varint,9,opt,name=Inflight,proto3" json:"Inflight,omitempty"`
	ID          uint64 `protobuf:"varint,10,opt,name=ID,proto3" json:"ID,omitempty"`
}

func (*ReplicaStatus) Descriptor 

func (*ReplicaStatus) Descriptor() ([]byte, []int)

func (*ReplicaStatus) GetActive 

func (m *ReplicaStatus) GetActive() bool

func (*ReplicaStatus) GetCommit 

func (m *ReplicaStatus) GetCommit() uint64

func (*ReplicaStatus) GetID 

func (m *ReplicaStatus) GetID() uint64

func (*ReplicaStatus) GetInflight 

func (m *ReplicaStatus) GetInflight() int32

func (*ReplicaStatus) GetLastActive 

func (m *ReplicaStatus) GetLastActive() int64

func (*ReplicaStatus) GetMatch 

func (m *ReplicaStatus) GetMatch() uint64

func (*ReplicaStatus) GetNext 

func (m *ReplicaStatus) GetNext() uint64

func (*ReplicaStatus) GetPaused 

func (m *ReplicaStatus) GetPaused() bool

func (*ReplicaStatus) GetSnapshoting 

func (m *ReplicaStatus) GetSnapshoting() bool

func (*ReplicaStatus) GetState 

func (m *ReplicaStatus) GetState() string

func (*ReplicaStatus) Marshal 

func (m *ReplicaStatus) Marshal() (dAtA []byte, err error)

func (*ReplicaStatus) MarshalTo 

func (m *ReplicaStatus) MarshalTo(dAtA []byte) (int, error)

func (*ReplicaStatus) ProtoMessage 

func (*ReplicaStatus) ProtoMessage()

func (*ReplicaStatus) Reset 

func (m *ReplicaStatus) Reset()

func (*ReplicaStatus) Size 

func (m *ReplicaStatus) Size() (n int)

func (*ReplicaStatus) String 

func (m *ReplicaStatus) String() string

func (*ReplicaStatus) Unmarshal 

func (m *ReplicaStatus) Unmarshal(dAtA []byte) error

type ScheduleCount 

type ScheduleCount struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Label string `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	Count uint64 `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
}

func (*ScheduleCount) Descriptor 

func (*ScheduleCount) Descriptor() ([]byte, []int)

func (*ScheduleCount) GetCount 

func (m *ScheduleCount) GetCount() uint64

func (*ScheduleCount) GetLabel 

func (m *ScheduleCount) GetLabel() string

func (*ScheduleCount) GetName 

func (m *ScheduleCount) GetName() string

func (*ScheduleCount) Marshal 

func (m *ScheduleCount) Marshal() (dAtA []byte, err error)

func (*ScheduleCount) MarshalTo 

func (m *ScheduleCount) MarshalTo(dAtA []byte) (int, error)

func (*ScheduleCount) ProtoMessage 

func (*ScheduleCount) ProtoMessage()

func (*ScheduleCount) Reset 

func (m *ScheduleCount) Reset()

func (*ScheduleCount) Size 

func (m *ScheduleCount) Size() (n int)

func (*ScheduleCount) String 

func (m *ScheduleCount) String() string

func (*ScheduleCount) Unmarshal 

func (m *ScheduleCount) Unmarshal(dAtA []byte) error

type SlowLog 

type SlowLog struct {
	SlowLog string `protobuf:"bytes,1,opt,name=slow_log,json=slowLog,proto3" json:"slow_log,omitempty"`
	Lats    int64  `protobuf:"varint,2,opt,name=lats,proto3" json:"lats,omitempty"`
}

func (*SlowLog) Descriptor 

func (*SlowLog) Descriptor() ([]byte, []int)

func (*SlowLog) GetLats 

func (m *SlowLog) GetLats() int64

func (*SlowLog) GetSlowLog 

func (m *SlowLog) GetSlowLog() string

func (*SlowLog) Marshal 

func (m *SlowLog) Marshal() (dAtA []byte, err error)

func (*SlowLog) MarshalTo 

func (m *SlowLog) MarshalTo(dAtA []byte) (int, error)

func (*SlowLog) ProtoMessage 

func (*SlowLog) ProtoMessage()

func (*SlowLog) Reset 

func (m *SlowLog) Reset()

func (*SlowLog) Size 

func (m *SlowLog) Size() (n int)

func (*SlowLog) String 

func (m *SlowLog) String() string

func (*SlowLog) Unmarshal 

func (m *SlowLog) Unmarshal(dAtA []byte) error

type SlowLogStats 

type SlowLogStats struct {
	SlowLogs []*SlowLog `protobuf:"bytes,1,rep,name=slow_logs,json=slowLogs" json:"slow_logs,omitempty"`
}

func (*SlowLogStats) Descriptor 

func (*SlowLogStats) Descriptor() ([]byte, []int)

func (*SlowLogStats) GetSlowLogs 

func (m *SlowLogStats) GetSlowLogs() []*SlowLog

func (*SlowLogStats) Marshal 

func (m *SlowLogStats) Marshal() (dAtA []byte, err error)

func (*SlowLogStats) MarshalTo 

func (m *SlowLogStats) MarshalTo(dAtA []byte) (int, error)

func (*SlowLogStats) ProtoMessage 

func (*SlowLogStats) ProtoMessage()

func (*SlowLogStats) Reset 

func (m *SlowLogStats) Reset()

func (*SlowLogStats) Size 

func (m *SlowLogStats) Size() (n int)

func (*SlowLogStats) String 

func (m *SlowLogStats) String() string

func (*SlowLogStats) Unmarshal 

func (m *SlowLogStats) Unmarshal(dAtA []byte) error

type SqlSlow 

type SqlSlow struct {
	TimeSec   int64  `protobuf:"varint,1,opt,name=time_sec,json=timeSec,proto3" json:"time_sec,omitempty"`
	Sql       string `protobuf:"bytes,2,opt,name=sql,proto3" json:"sql,omitempty"`
	TotalUsec int64  `protobuf:"varint,3,opt,name=total_usec,json=totalUsec,proto3" json:"total_usec,omitempty"`
	CallUsec  int64  `protobuf:"varint,4,opt,name=call_usec,json=callUsec,proto3" json:"call_usec,omitempty"`
}

func (*SqlSlow) Descriptor 

func (*SqlSlow) Descriptor() ([]byte, []int)

func (*SqlSlow) GetCallUsec 

func (m *SqlSlow) GetCallUsec() int64

func (*SqlSlow) GetSql 

func (m *SqlSlow) GetSql() string

func (*SqlSlow) GetTimeSec 

func (m *SqlSlow) GetTimeSec() int64

func (*SqlSlow) GetTotalUsec 

func (m *SqlSlow) GetTotalUsec() int64

func (*SqlSlow) Marshal 

func (m *SqlSlow) Marshal() (dAtA []byte, err error)

func (*SqlSlow) MarshalTo 

func (m *SqlSlow) MarshalTo(dAtA []byte) (int, error)

func (*SqlSlow) ProtoMessage 

func (*SqlSlow) ProtoMessage()

func (*SqlSlow) Reset 

func (m *SqlSlow) Reset()

func (*SqlSlow) Size 

func (m *SqlSlow) Size() (n int)

func (*SqlSlow) String 

func (m *SqlSlow) String() string

func (*SqlSlow) Unmarshal 

func (m *SqlSlow) Unmarshal(dAtA []byte) error

type SqlSlowlog 

type SqlSlowlog struct {
	Len  uint32     `protobuf:"varint,1,opt,name=len,proto3" json:"len,omitempty"`
	Than int32      `protobuf:"varint,2,opt,name=than,proto3" json:"than,omitempty"`
	Idx  uint32     `protobuf:"varint,3,opt,name=idx,proto3" json:"idx,omitempty"`
	Log  []*SqlSlow `protobuf:"bytes,4,rep,name=log" json:"log,omitempty"`
}

func (*SqlSlowlog) Descriptor 

func (*SqlSlowlog) Descriptor() ([]byte, []int)

func (*SqlSlowlog) GetIdx 

func (m *SqlSlowlog) GetIdx() uint32

func (*SqlSlowlog) GetLen 

func (m *SqlSlowlog) GetLen() uint32

func (*SqlSlowlog) GetLog 

func (m *SqlSlowlog) GetLog() []*SqlSlow

func (*SqlSlowlog) GetThan 

func (m *SqlSlowlog) GetThan() int32

func (*SqlSlowlog) Marshal 

func (m *SqlSlowlog) Marshal() (dAtA []byte, err error)

func (*SqlSlowlog) MarshalTo 

func (m *SqlSlowlog) MarshalTo(dAtA []byte) (int, error)

func (*SqlSlowlog) ProtoMessage 

func (*SqlSlowlog) ProtoMessage()

func (*SqlSlowlog) Reset 

func (m *SqlSlowlog) Reset()

func (*SqlSlowlog) Size 

func (m *SqlSlowlog) Size() (n int)

func (*SqlSlowlog) String 

func (m *SqlSlowlog) String() string

func (*SqlSlowlog) Unmarshal 

func (m *SqlSlowlog) Unmarshal(dAtA []byte) error

type SqlStats 

type SqlStats struct {
	Ops      int64  `protobuf:"varint,1,opt,name=ops,proto3" json:"ops,omitempty"`
	DelayAvg int64  `protobuf:"varint,2,opt,name=delay_avg,json=delayAvg,proto3" json:"delay_avg,omitempty"`
	Tp       []byte `protobuf:"bytes,3,opt,name=tp,proto3" json:"tp,omitempty"`
}

func (*SqlStats) Descriptor 

func (*SqlStats) Descriptor() ([]byte, []int)

func (*SqlStats) GetDelayAvg 

func (m *SqlStats) GetDelayAvg() int64

func (*SqlStats) GetOps 

func (m *SqlStats) GetOps() int64

func (*SqlStats) GetTp 

func (m *SqlStats) GetTp() []byte

func (*SqlStats) Marshal 

func (m *SqlStats) Marshal() (dAtA []byte, err error)

func (*SqlStats) MarshalTo 

func (m *SqlStats) MarshalTo(dAtA []byte) (int, error)

func (*SqlStats) ProtoMessage 

func (*SqlStats) ProtoMessage()

func (*SqlStats) Reset 

func (m *SqlStats) Reset()

func (*SqlStats) Size 

func (m *SqlStats) Size() (n int)

func (*SqlStats) String 

func (m *SqlStats) String() string

func (*SqlStats) Unmarshal 

func (m *SqlStats) Unmarshal(dAtA []byte) error

type SqlTp 

type SqlTp struct {
	Calls    int64   `protobuf:"varint,1,opt,name=calls,proto3" json:"calls,omitempty"`
	Tp       []int64 `protobuf:"varint,2,rep,packed,name=tp" json:"tp,omitempty"`
	DelayMax int64   `protobuf:"varint,3,opt,name=delay_max,json=delayMax,proto3" json:"delay_max,omitempty"`
}

func (*SqlTp) Descriptor 

func (*SqlTp) Descriptor() ([]byte, []int)

func (*SqlTp) GetCalls 

func (m *SqlTp) GetCalls() int64

func (*SqlTp) GetDelayMax 

func (m *SqlTp) GetDelayMax() int64

func (*SqlTp) GetTp 

func (m *SqlTp) GetTp() []int64

func (*SqlTp) Marshal 

func (m *SqlTp) Marshal() (dAtA []byte, err error)

func (*SqlTp) MarshalTo 

func (m *SqlTp) MarshalTo(dAtA []byte) (int, error)

func (*SqlTp) ProtoMessage 

func (*SqlTp) ProtoMessage()

func (*SqlTp) Reset 

func (m *SqlTp) Reset()

func (*SqlTp) Size 

func (m *SqlTp) Size() (n int)

func (*SqlTp) String 

func (m *SqlTp) String() string

func (*SqlTp) Unmarshal 

func (m *SqlTp) Unmarshal(dAtA []byte) error

type TableStats 

type TableStats struct {
	DbName    string `protobuf:"bytes,1,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	TableName string `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	RangeNum  uint64 `protobuf:"varint,3,opt,name=range_num,json=rangeNum,proto3" json:"range_num,omitempty"`
	Size_     uint64 `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
}

func (*TableStats) Descriptor 

func (*TableStats) Descriptor() ([]byte, []int)

func (*TableStats) GetDbName 

func (m *TableStats) GetDbName() string

func (*TableStats) GetRangeNum 

func (m *TableStats) GetRangeNum() uint64

func (*TableStats) GetSize_ 

func (m *TableStats) GetSize_() uint64

func (*TableStats) GetTableName 

func (m *TableStats) GetTableName() string

func (*TableStats) Marshal 

func (m *TableStats) Marshal() (dAtA []byte, err error)

func (*TableStats) MarshalTo 

func (m *TableStats) MarshalTo(dAtA []byte) (int, error)

func (*TableStats) ProtoMessage 

func (*TableStats) ProtoMessage()

func (*TableStats) Reset 

func (m *TableStats) Reset()

func (*TableStats) Size 

func (m *TableStats) Size() (n int)

func (*TableStats) String 

func (m *TableStats) String() string

func (*TableStats) Unmarshal 

func (m *TableStats) Unmarshal(dAtA []byte) error

type TaskInfo 

type TaskInfo struct {
	TaskId  uint64 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	RangeId uint64 `protobuf:"varint,2,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"`
	Kind    string `protobuf:"bytes,3,opt,name=kind,proto3" json:"kind,omitempty"`
	Name    string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// 任务状态
	State string `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"`
	Start int64  `protobuf:"varint,6,opt,name=start,proto3" json:"start,omitempty"`
	End   int64  `protobuf:"varint,7,opt,name=end,proto3" json:"end,omitempty"`
	// 单位s
	UsedTime float64 `protobuf:"fixed64,8,opt,name=used_time,json=usedTime,proto3" json:"used_time,omitempty"`
	Describe string  `protobuf:"bytes,9,opt,name=describe,proto3" json:"describe,omitempty"`
}

func (*TaskInfo) Descriptor 

func (*TaskInfo) Descriptor() ([]byte, []int)

func (*TaskInfo) GetDescribe 

func (m *TaskInfo) GetDescribe() string

func (*TaskInfo) GetEnd 

func (m *TaskInfo) GetEnd() int64

func (*TaskInfo) GetKind 

func (m *TaskInfo) GetKind() string

func (*TaskInfo) GetName 

func (m *TaskInfo) GetName() string

func (*TaskInfo) GetRangeId 

func (m *TaskInfo) GetRangeId() uint64

func (*TaskInfo) GetStart 

func (m *TaskInfo) GetStart() int64

func (*TaskInfo) GetState 

func (m *TaskInfo) GetState() string

func (*TaskInfo) GetTaskId 

func (m *TaskInfo) GetTaskId() uint64

func (*TaskInfo) GetUsedTime 

func (m *TaskInfo) GetUsedTime() float64

func (*TaskInfo) Marshal 

func (m *TaskInfo) Marshal() (dAtA []byte, err error)

func (*TaskInfo) MarshalTo 

func (m *TaskInfo) MarshalTo(dAtA []byte) (int, error)

func (*TaskInfo) ProtoMessage 

func (*TaskInfo) ProtoMessage()

func (*TaskInfo) Reset 

func (m *TaskInfo) Reset()

func (*TaskInfo) Size 

func (m *TaskInfo) Size() (n int)

func (*TaskInfo) String 

func (m *TaskInfo) String() string

func (*TaskInfo) Unmarshal 

func (m *TaskInfo) Unmarshal(dAtA []byte) error

type TpArgs 

type TpArgs int32
const (
	TpArgs_invalid    TpArgs = 0
	TpArgs_msec_index TpArgs = 1000
	TpArgs_sec_index  TpArgs = 1060
	TpArgs_min_index  TpArgs = 1061
)

func (TpArgs) EnumDescriptor 

func (TpArgs) EnumDescriptor() ([]byte, []int)

func (TpArgs) String 

func (x TpArgs) String() string

type TpStats 

type TpStats struct {
	Tps uint64 `protobuf:"varint,1,opt,name=tps,proto3" json:"tps,omitempty"`
	// min　latency ms
	Min float64 `protobuf:"fixed64,2,opt,name=min,proto3" json:"min,omitempty"`
	// max　latency ms
	Max float64 `protobuf:"fixed64,3,opt,name=max,proto3" json:"max,omitempty"`
	// avg　latency ms
	Avg         float64 `protobuf:"fixed64,4,opt,name=avg,proto3" json:"avg,omitempty"`
	Tp_50       float64 `protobuf:"fixed64,5,opt,name=tp_50,json=tp50,proto3" json:"tp_50,omitempty"`
	Tp_90       float64 `protobuf:"fixed64,6,opt,name=tp_90,json=tp90,proto3" json:"tp_90,omitempty"`
	Tp_99       float64 `protobuf:"fixed64,7,opt,name=tp_99,json=tp99,proto3" json:"tp_99,omitempty"`
	Tp_999      float64 `protobuf:"fixed64,8,opt,name=tp_999,json=tp999,proto3" json:"tp_999,omitempty"`
	TotalNumber uint64  `protobuf:"varint,9,opt,name=total_number,json=totalNumber,proto3" json:"total_number,omitempty"`
	ErrNumber   uint64  `protobuf:"varint,10,opt,name=err_number,json=errNumber,proto3" json:"err_number,omitempty"`
}

func (*TpStats) Descriptor 

func (*TpStats) Descriptor() ([]byte, []int)

func (*TpStats) GetAvg 

func (m *TpStats) GetAvg() float64

func (*TpStats) GetErrNumber 

func (m *TpStats) GetErrNumber() uint64

func (*TpStats) GetMax 

func (m *TpStats) GetMax() float64

func (*TpStats) GetMin 

func (m *TpStats) GetMin() float64

func (*TpStats) GetTotalNumber 

func (m *TpStats) GetTotalNumber() uint64

func (*TpStats) GetTp_50 

func (m *TpStats) GetTp_50() float64

func (*TpStats) GetTp_90 

func (m *TpStats) GetTp_90() float64

func (*TpStats) GetTp_99 

func (m *TpStats) GetTp_99() float64

func (*TpStats) GetTp_999 

func (m *TpStats) GetTp_999() float64

func (*TpStats) GetTps 

func (m *TpStats) GetTps() uint64

func (*TpStats) Marshal 

func (m *TpStats) Marshal() (dAtA []byte, err error)

func (*TpStats) MarshalTo 

func (m *TpStats) MarshalTo(dAtA []byte) (int, error)

func (*TpStats) ProtoMessage 

func (*TpStats) ProtoMessage()

func (*TpStats) Reset 

func (m *TpStats) Reset()

func (*TpStats) Size 

func (m *TpStats) Size() (n int)

func (*TpStats) String 

func (m *TpStats) String() string

func (*TpStats) Unmarshal 

func (m *TpStats) Unmarshal(dAtA []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.