Compare commits
2 Commits
b7d7dba4e7
...
cb7dd59b73
| Author | SHA1 | Date | |
|---|---|---|---|
| cb7dd59b73 | |||
| 8947ef0d6b |
@ -4,29 +4,39 @@
|
|||||||
//
|
//
|
||||||
// Author : go_developer@163.com<白茶清欢>
|
// Author : go_developer@163.com<白茶清欢>
|
||||||
//
|
//
|
||||||
// Date : 2021-11-26 5:07 下午
|
// Date : 2021-11-26 21:07 下午
|
||||||
package redis
|
package redis
|
||||||
|
|
||||||
// FullServerInfo 获取服务器信息
|
// FullServerInfo 获取服务器信息
|
||||||
//
|
//
|
||||||
// Author : go_developer@163.com<白茶清欢>
|
// Author : go_developer@163.com<白茶清欢>
|
||||||
//
|
//
|
||||||
// Date : 5:07 下午 2021/11/26
|
// Date : 21:07 下午 2021/11/26
|
||||||
type FullServerInfo struct {
|
type FullServerInfo struct {
|
||||||
ServerInfo *ServerInfo `json:"server_info"`
|
ServerInfo *ServerInfo `json:"server_info"`
|
||||||
ClientInfo *ClientInfo `json:"client_info"`
|
ClientInfo *ClientInfo `json:"client_info"`
|
||||||
|
MemoryInfo *MemoryInfo `json:"memory_info"`
|
||||||
|
Persistence *Persistence `json:"persistence"`
|
||||||
|
Stats *Stats `json:"stats"`
|
||||||
|
Replication *Replication `json:"replication"`
|
||||||
|
CPU *CPU `json:"cpu"`
|
||||||
|
CommandStats []CmdStat `json:"command_stats"`
|
||||||
|
Keyspace []DB `json:"keyspace"`
|
||||||
|
Cluster *Cluster `json:"cluster"`
|
||||||
|
ErrorStats []Error `json:"error_stats"`
|
||||||
|
Modules interface{} `json:"modules"`
|
||||||
}
|
}
|
||||||
|
|
||||||
// ServerInfo 服务器信息
|
// ServerInfo 服务器信息
|
||||||
//
|
//
|
||||||
// Author : go_developer@163.com<白茶清欢>
|
// Author : go_developer@163.com<白茶清欢>
|
||||||
//
|
//
|
||||||
// Date : 5:09 下午 2021/11/26
|
// Date : 21:09 下午 2021/11/26
|
||||||
type ServerInfo struct {
|
type ServerInfo struct {
|
||||||
RedisVersion string `json:"redis_version" yaml:"redis_version"` // Redis 服务器版本
|
RedisVersion string `json:"redis_version" yaml:"redis_version"` // Redis 服务器版本
|
||||||
RedisGitSha1 string `json:"redis_git_sha1" yaml:"redis_git_sha1"` // Git SHA1
|
RedisGitSha1 string `json:"redis_git_sha1" yaml:"redis_git_sha1"` // Git SHA1
|
||||||
RedisGitDirty string `json:"redis_git_dirty" json:"redis_git_dirty"` // Git dirty flag
|
RedisGitDirty string `json:"redis_git_dirty" yaml:"redis_git_dirty"` // Git dirty flag
|
||||||
RedisBuildID string `json:"redis_build_id" json:"redis_build_id"` // 构建ID
|
RedisBuildID string `json:"redis_build_id" yaml:"redis_build_id"` // 构建ID
|
||||||
RedisMode string `json:"redis_mode" yaml:"redis_mode"` // 运行模式(“独立”，“哨兵”或“集群”)
|
RedisMode string `json:"redis_mode" yaml:"redis_mode"` // 运行模式(“独立”，“哨兵”或“集群”)
|
||||||
OS string `json:"os" yaml:"os"` // Redis 服务器的宿主操作系统
|
OS string `json:"os" yaml:"os"` // Redis 服务器的宿主操作系统
|
||||||
ArchBits string `json:"arch_bits" yaml:"arch_bits"` // 架构（32 或 64 位）
|
ArchBits string `json:"arch_bits" yaml:"arch_bits"` // 架构（32 或 64 位）
|
||||||
@ -52,7 +62,7 @@ type ServerInfo struct {
|
|||||||
//
|
//
|
||||||
// Author : go_developer@163.com<白茶清欢>
|
// Author : go_developer@163.com<白茶清欢>
|
||||||
//
|
//
|
||||||
// Date : 5:29 下午 2021/11/26
|
// Date : 21:29 下午 2021/11/26
|
||||||
type ClientInfo struct {
|
type ClientInfo struct {
|
||||||
ConnectedClients int `json:"connected_clients" yaml:"connected_clients"` // 客户端连接数
|
ConnectedClients int `json:"connected_clients" yaml:"connected_clients"` // 客户端连接数
|
||||||
ClusterConnections int `json:"cluster_connections" yaml:"cluster_connections"` // 集群连接数
|
ClusterConnections int `json:"cluster_connections" yaml:"cluster_connections"` // 集群连接数
|
||||||
@ -68,7 +78,7 @@ type ClientInfo struct {
|
|||||||
//
|
//
|
||||||
// Author : go_developer@163.com<白茶清欢>
|
// Author : go_developer@163.com<白茶清欢>
|
||||||
//
|
//
|
||||||
// Date : 6:08 下午 2021/11/26
|
// Date : 22:08 下午 2021/11/26
|
||||||
type MemoryInfo struct {
|
type MemoryInfo struct {
|
||||||
UsedMemory int64 `json:"used_memory" yaml:"used_memory"` // 由 Redis 分配器分配的内存总量，以字节（byte）为单位
|
UsedMemory int64 `json:"used_memory" yaml:"used_memory"` // 由 Redis 分配器分配的内存总量，以字节（byte）为单位
|
||||||
UsedMemoryHuman string `json:"used_memory_human" yaml:"used_memory_human"` // UsedMemory 可读化表示
|
UsedMemoryHuman string `json:"used_memory_human" yaml:"used_memory_human"` // UsedMemory 可读化表示
|
||||||
@ -112,3 +122,180 @@ type MemoryInfo struct {
|
|||||||
LazyfreePendingObjects int64 `json:"lazyfree_pending_objects" yaml:"lazyfree_pending_objects"` // 延迟释放的挂起对象， 0表示不存在
|
LazyfreePendingObjects int64 `json:"lazyfree_pending_objects" yaml:"lazyfree_pending_objects"` // 延迟释放的挂起对象， 0表示不存在
|
||||||
LazyfreedObjects int64 `json:"lazyfreed_objects" yaml:"lazyfreed_objects"` // 延迟释放的对象数量
|
LazyfreedObjects int64 `json:"lazyfreed_objects" yaml:"lazyfreed_objects"` // 延迟释放的对象数量
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Persistence 持久化信息
|
||||||
|
//
|
||||||
|
// Author : go_developer@163.com<白茶清欢>
|
||||||
|
//
|
||||||
|
// Date : 22:15 下午 2021/11/26
|
||||||
|
type Persistence struct {
|
||||||
|
Loading int `json:"loading" yaml:"loading"` // 服务器是否正在进行持久化 0 - 否 1 -是
|
||||||
|
CurrentCowSize int `json:"current_cow_size" yaml:"current_cow_size"` // current_cow_size
|
||||||
|
CurrentCowSizeAge int `json:"current_cow_size_age" yaml:"current_cow_size_age"` // current_cow_size_age
|
||||||
|
CurrentForkPerc float64 `json:"current_fork_perc" yaml:"current_fork_perc"` // current_fork_perc
|
||||||
|
CurrentSaveKeysProcessed int `json:"current_save_keys_processed" yaml:"current_save_keys_processed"` // current_save_keys_processed
|
||||||
|
CurrentSaveKeysTotal int64 `json:"current_save_keys_total" yaml:"current_save_keys_total"` // current_save_keys_total
|
||||||
|
RdbChangesSinceLastSave int64 `json:"rdb_changes_since_last_save" yaml:"rdb_changes_since_last_save"` // 离最近一次成功生成rdb文件，写入命令的个数，即有多少个写入命令没有持久化
|
||||||
|
RdbBgsaveInProgress int `json:"rdb_bgsave_in_progress" yaml:"rdb_bgsave_in_progress"` // 服务器是否正在创建rdb文件 0 - 否 1 - 是
|
||||||
|
RdbLastSaveTime int64 `json:"rdb_last_save_time" yaml:"rdb_last_save_time"` // 最近一次创建rdb文件的时间戳,单位秒
|
||||||
|
RdbLastBgsaveStatus string `json:"rdb_last_bgsave_status" yaml:"rdb_last_bgsave_status"` // 最近一次rdb持久化是否成功 ok 成功
|
||||||
|
RdbLastBgsaveTimeSec int64 `json:"rdb_last_bgsave_time_sec" yaml:"rdb_last_bgsave_time_sec"` // 最近一次成功生成rdb文件耗时秒数
|
||||||
|
RdbCurrentBgsaveTimeSec int64 `json:"rdb_current_bgsave_time_sec" yaml:"rdb_current_bgsave_time_sec"` // 如果服务器正在创建rdb文件，那么这个域记录的就是当前的创建操作已经耗费的秒数
|
||||||
|
RdbLastCowSize int64 `json:"rdb_last_cow_size" yaml:"rdb_last_cow_size"` // RDB过程中父进程与子进程相比执行了多少修改(包括读缓冲区，写缓冲区，数据修改等)。
|
||||||
|
AofEnabled int `json:"aof_enabled" yaml:"aof_enabled"` // 是否开启了AOF 0 - 否 1 - 是
|
||||||
|
AofRewriteInProgress int `json:"aof_rewrite_in_progress" yaml:"aof_rewrite_in_progress"` // 标识aof的rewrite操作是否在进行中 0 - 否 1- 是
|
||||||
|
AofRewriteScheduled int `json:"aof_rewrite_scheduled" yaml:"aof_rewrite_scheduled"` // rewrite任务计划，当客户端发送bgrewriteaof指令，如果当前rewrite子进程正在执行，那么将客户端请求的bgrewriteaof变为计划任务，待aof子进程结束后执行rewrite
|
||||||
|
AofLastRewriteTimeSec int `json:"aof_last_rewrite_time_sec" yaml:"aof_last_rewrite_time_sec"` // 最近一次aof rewrite耗费的时长
|
||||||
|
AofCurrentRewriteTimeSec int `json:"aof_current_rewrite_time_sec" yaml:"aof_current_rewrite_time_sec"` // 如果rewrite操作正在进行，则记录所使用的时间，单位秒
|
||||||
|
AofLastBgrewriteStatus string `json:"aof_last_bgrewrite_status" yaml:"aof_last_bgrewrite_status"` // 上次bgrewriteaof操作的状态 ok 成功
|
||||||
|
AofLastWriteStatus string `json:"aof_last_write_status" yaml:"aof_last_write_status"` // 上次aof写入状态
|
||||||
|
AofLastCowSize int64 `json:"aof_last_cow_size" yaml:"aof_last_cow_size"` // AOF过程中父进程与子进程相比执行了多少修改(包括读缓冲区，写缓冲区，数据修改等)
|
||||||
|
IOThreadedReadsProcessed int `json:"io_threaded_reads_processed" yaml:"io_threaded_reads_processed"` // 读取线程数
|
||||||
|
IOThreadedWritesProcessed int `json:"io_threaded_writes_processed" yaml:"io_threaded_writes_processed"` // 写入线程数
|
||||||
|
}
|
||||||
|
|
||||||
|
// Stats ...
|
||||||
|
//
|
||||||
|
// Author : go_developer@163.com<白茶清欢>
|
||||||
|
//
|
||||||
|
// Date : 10:57 下午 2021/11/26
|
||||||
|
type Stats struct {
|
||||||
|
TotalConnectionsReceived int64 `json:"total_connections_received" yaml:"total_connections_received"` // 所有练结数, 累积值, 只增不减, 连接断开也不会减少
|
||||||
|
TotalCommandsProcessed int64 `json:"total_commands_processed" yaml:"total_commands_processed"` // 服务器执行的命令数 累积值, 只增不减
|
||||||
|
InstantaneousPpsPerSec int `json:"instantaneous_pps_per_sec" yaml:"instantaneous_pps_per_sec"` // 每秒执行的命令数
|
||||||
|
TotalNetInputBytes int64 `json:"total_net_input_bytes" yaml:"total_net_input_bytes"` // 网络流量-流入 以字节（byte）为单位
|
||||||
|
TotalNetOutputBytes int64 `json:"total_net_output_bytes" yaml:"total_net_output_bytes"` // 网络流量-流出 以字节（byte）为单位
|
||||||
|
InstantaneousInputKbps float64 `json:"instantaneous_input_kbps" yaml:"instantaneous_input_kbps"` // 网络流量-流入-KB/s
|
||||||
|
InstantaneousOutputKbps float64 `json:"instantaneous_output_kbps" yaml:"instantaneous_output_kbps"` // 网络流量-流出-KB/s
|
||||||
|
RejectedConnections int64 `json:"rejected_connections" yaml:"rejected_connections"` // 因达到做大连接数而被拒绝的连接数量
|
||||||
|
SyncFull int64 `json:"sync_full" yaml:"sync_full"` // 主从全量同步的次数
|
||||||
|
SyncPartialOk int64 `json:"sync_partial_ok" yaml:"sync_partial_ok"` // 主从部分同步成功的次数
|
||||||
|
SyncPartialErr int64 `json:"sync_partial_err" yaml:"sync_partial_err"` // 主从部分同步失败次数
|
||||||
|
ExpiredKeys int `json:"expired_keys" yaml:"expired_keys"` // 过期key的数量
|
||||||
|
ExpiredStalePerc float64 `json:"expired_stale_perc" yaml:"expired_stale_perc"` // 过期过时的百分比
|
||||||
|
ExpiredTimeCapReachedCount int64 `json:"expired_time_cap_reached_count" yaml:"expired_time_cap_reached_count"` // expired_time_cap_reached_count
|
||||||
|
ExpireCycleCpuMilliseconds int64 `json:"expire_cycle_cpu_milliseconds" yaml:"expire_cycle_cpu_milliseconds"` // expire_cycle_cpu_milliseconds
|
||||||
|
EvictedKeys int64 `json:"evicted_keys" yaml:"evicted_keys"` // 超过 maxmemory 之后, 剔除的 key 的数量
|
||||||
|
KeyspaceHits int64 `json:"keyspace_hits" yaml:"keyspace_hits"` // 访问命中次数
|
||||||
|
KeyspaceMisses int64 `json:"keyspace_misses" yaml:"keyspace_misses"` // 访问未命中次数
|
||||||
|
PubsubChannels int64 `json:"pubsub_channels" yaml:"pubsub_channels"` // 当前频道数量 发布 - 订阅 模式
|
||||||
|
PubsubPatterns int64 `json:"pubsub_patterns" yaml:"pubsub_patterns"` // 当前使用中的模式数量
|
||||||
|
LatestForkUsec int64 `json:"latest_fork_usec" yaml:"latest_fork_usec"` // 最近一次fork 操作消耗的时间, 单位微秒
|
||||||
|
TotalForks int64 `json:"total_forks" yaml:"total_forks"` // fork 的总次数
|
||||||
|
MigrateCachedSockets int64 `json:"migrate_cached_sockets" yaml:"migrate_cached_sockets"` // 记录当前 Redis 正在 migrate 操作的目标 Redis 个数, 例如 A 向 B 和 C 执行 migrate操作, 这个值为2
|
||||||
|
SlaveExpiresTrackedKeys int64 `json:"slave_expires_tracked_keys" yaml:"slave_expires_tracked_keys"` // 从实例到期的 key 的数量
|
||||||
|
ActiveDefragHits int64 `json:"active_defrag_hits" yaml:"active_defrag_hits"` // 主动碎片整理命中次数
|
||||||
|
ActiveDefragMisses int64 `json:"active_defrag_misses" yaml:"active_defrag_misses"` // 主动碎片整理未命中次数
|
||||||
|
ActiveDefragKeyHits int64 `json:"active_defrag_key_hits" yaml:"active_defrag_key_hits"` // 主动整理碎片, key命中次数
|
||||||
|
ActiveDefragKeyMisses int64 `json:"active_defrag_key_misses" yaml:"active_defrag_key_misses"` // 主动整理碎片, key未命中次数
|
||||||
|
TrackingTotalKeys int64 `json:"tracking_total_keys" yaml:"tracking_total_keys"` // tracking_total_keys
|
||||||
|
TrackingTotalItems int64 `json:"tracking_total_items" yaml:"tracking_total_items"` // tracking_total_items
|
||||||
|
TrackingTotalPrefixes int64 `json:"tracking_total_prefixes" yaml:"tracking_total_prefixes"` // tracking_total_prefixes
|
||||||
|
UnexpectedErrorReplies int64 `json:"unexpected_error_replies" yaml:"unexpected_error_replies"` // unexpected_error_replies
|
||||||
|
TotalErrorReplies int64 `json:"total_error_replies" yaml:"total_error_replies"` // total_error_replies
|
||||||
|
DumpPayloadSanitizations int64 `json:"dump_payload_sanitizations" yaml:"dump_payload_sanitizations"` // dump_payload_sanitizations
|
||||||
|
TotalReadsProcessed int64 `json:"total_reads_processed" yaml:"total_reads_processed"` // total_reads_processed
|
||||||
|
TotalWritesProcessed int64 `json:"total_writes_processed" yaml:"total_writes_processed"` // total_reads_processed
|
||||||
|
IOThreadedReadsProcessed int64 `json:"io_threaded_reads_processed" yaml:"io_threaded_reads_processed"` // io_threaded_reads_processed
|
||||||
|
IOThreadedWritesProcessed int64 `json:"io_threaded_writes_processed" yaml:"io_threaded_writes_processed"` // io_threaded_writes_processed
|
||||||
|
}
|
||||||
|
|
||||||
|
// Replication 复制相关
|
||||||
|
//
|
||||||
|
// Author : go_developer@163.com<白茶清欢>
|
||||||
|
//
|
||||||
|
// Date : 12:42 上午 2021/11/27
|
||||||
|
type Replication struct {
|
||||||
|
Role string `json:"role" yaml:"role"` // 节点的角色 master / slave
|
||||||
|
ConnectedSlaves int `json:"connected_slaves" yaml:"connected_slaves"` // 仅主节点属性 : 连接的从节点数量
|
||||||
|
MasterFailoverState string `json:"master_failover_state" yaml:"master_failover_state"` // 仅主节点 : 故障转移状态 no-failover 无故障转移
|
||||||
|
MasterReplid string `json:"master_replid" yaml:"master_replid"` // 仅主节点 : 实例启动的随机字符串
|
||||||
|
MasterReplid2 string `json:"master_replid2" yaml:"master_replid2"` // 仅主节点 : 实例启动的随机字符串2
|
||||||
|
MasterReplOffset int64 `json:"master_repl_offset" yaml:"master_repl_offset"` // 主从同步偏移量
|
||||||
|
SecondReplOffset int64 `json:"second_repl_offset" yaml:"second_repl_offset"` // 主从同步偏移量2
|
||||||
|
ReplBacklogActive int `json:"repl_backlog_active" yaml:"repl_backlog_active"` // 复制缓冲区是否开启 0 - 未开启 1 - 已开启
|
||||||
|
ReplBacklogSize int64 `json:"repl_backlog_size" yaml:"repl_backlog_size"` // 复制缓冲区大小（以字节为单位）
|
||||||
|
ReplBacklogFirstByteOffset int64 `json:"repl_backlog_first_byte_offset" yaml:"repl_backlog_first_byte_offset"` // 复制缓冲区里偏移量的大小
|
||||||
|
ReplBacklogHistlen int64 `json:"repl_backlog_histlen" yaml:"repl_backlog_histlen"` // 此值等于 master_repl_offset - repl_backlog_first_byte_offset,该值不会超过repl_backlog_size的大小
|
||||||
|
MasterHost string `json:"master_host" yaml:"master_host"` // 仅从节点 : 主节点host
|
||||||
|
MasterPort int `json:"master_port" yaml:"master_port"` // 仅从节点 : 主节点端口
|
||||||
|
MasterLinkStatus string `json:"master_link_status" yaml:"master_link_status"` // 仅从节点 : 与主节点连接状态 up - 正常连接 down - 断开
|
||||||
|
MasterLastIOSecondsAgo int `json:"master_last_io_seconds_ago" yaml:"master_last_io_seconds_ago"` // 仅从节点 : 主节点与从节点最后通信的时间间隔, 单位: s
|
||||||
|
MasterSyncInProgress int `json:"master_sync_in_progress" yaml:"master_sync_in_progress"` // 仅从节点 : 从节点是否正在全量同步主节点rdb文件 0 - 否 1 - 是
|
||||||
|
SlaveReplOffset int64 `json:"slave_repl_offset" yaml:"slave_repl_offset"` // 仅从节点 : 复制偏移量
|
||||||
|
SlavePriority int `json:"slave_priority" yaml:"slave_priority"` // 仅从节点 : 从节点优先级
|
||||||
|
SlaveReadOnly int `json:"slave_read_only" yaml:"slave_read_only"` // 仅从节点 : 从节点是否只读 0 - 否 1 - 是
|
||||||
|
SlaveList []SlaveNode `json:"slave_list" yaml:"slave_list"` // 从节点列表
|
||||||
|
}
|
||||||
|
|
||||||
|
// SlaveNode 从库数据结构,基于原始数据解析 eg : slave0:ip=x.x.x.x,port=6379,state=online,offset=123456,lag=1
|
||||||
|
//
|
||||||
|
// Author : go_developer@163.com<白茶清欢>
|
||||||
|
//
|
||||||
|
// Date : 1:51 上午 2021/11/27
|
||||||
|
type SlaveNode struct {
|
||||||
|
ID string `json:"id" yaml:"id"` // 从库ID
|
||||||
|
IP string `json:"ip" yaml:"ip"` // 从库IP
|
||||||
|
Port int `json:"port" yaml:"port"` // 从库端口
|
||||||
|
State string `json:"state" yaml:"state"` // 从库状态 online - 在线 offline - 离线
|
||||||
|
Offset int64 `json:"offset" yaml:"offset"` // 数据偏移量
|
||||||
|
Lag int64 `json:"lag" yaml:"lag"` // 数据延迟量大小
|
||||||
|
}
|
||||||
|
|
||||||
|
// CPU 信息
|
||||||
|
//
|
||||||
|
// Author : go_developer@163.com<白茶清欢>
|
||||||
|
//
|
||||||
|
// Date : 1:54 上午 2021/11/27
|
||||||
|
type CPU struct {
|
||||||
|
UsedCpuSys float64 `json:"used_cpu_sys" yaml:"used_cpu_sys"` // Redis主进程在内核态所占用CPU时钟总和
|
||||||
|
UsedCpuUser float64 `json:"used_cpu_user" yaml:"used_cpu_user"` // Redis主进程在用户态所占用CPU时钟总和
|
||||||
|
UsedCpuSysChildren float64 `json:"used_cpu_sys_children" yaml:"used_cpu_sys_children"` // Redis子进程在内核态所占用CPU时钟总和
|
||||||
|
UsedCpuUserChildren float64 `json:"used_cpu_user_children" yaml:"used_cpu_user_children"` // Redis子进程在用户态所占用CPU时钟总和
|
||||||
|
}
|
||||||
|
|
||||||
|
// CmdStat 指令状态 eg : cmdstat_get:calls=1,usec=42121,usec_per_call=42121.00,rejected_calls=0,failed_calls=0
|
||||||
|
//
|
||||||
|
// Author : go_developer@163.com<白茶清欢>
|
||||||
|
//
|
||||||
|
// Date : 2:02 上午 2021/11/27
|
||||||
|
type CmdStat struct {
|
||||||
|
Cmd string `json:"cmd" yaml:"cmd"` // 执行的指令
|
||||||
|
Calls int64 `json:"calls" yaml:"calls"` // 执行了多少次
|
||||||
|
TotalUsedTime float64 `json:"total_used_time" yaml:"total_used_time"` // 累计总耗时 微秒
|
||||||
|
AvgUsedTime float64 `json:"avg_used_time" yaml:"avg_used_time"` // 平均耗时 微秒
|
||||||
|
RejectedCalls int64 `json:"rejected_calls" yaml:"rejected_calls"` // 拒绝执行指令次数
|
||||||
|
FailedCalls int64 `json:"failed_calls" yaml:"failed_calls"` // 指令执行失败次数
|
||||||
|
SuccessCalls int64 `json:"success_calls" yaml:"success_calls"` // 指令执行成功次数 Calls - FailedCalls
|
||||||
|
}
|
||||||
|
|
||||||
|
// DB 数据库的数据结构, eg : db0:keys=3,expires=0,avg_ttl=0
|
||||||
|
//
|
||||||
|
// Author : go_developer@163.com<白茶清欢>
|
||||||
|
//
|
||||||
|
// Date : 2:09 上午 2021/11/27
|
||||||
|
type DB struct {
|
||||||
|
Name string `json:"name" yaml:"name"` // 数据库名称
|
||||||
|
Keys int64 `json:"keys" yaml:"keys"` // 数据库key的数量
|
||||||
|
Expires int64 `json:"expires" yaml:"expires"` // 数据库过期key的数量
|
||||||
|
AvgTTL int64 `json:"avg_ttl" yaml:"avg_ttl"` // 平均存活时间
|
||||||
|
}
|
||||||
|
|
||||||
|
// Cluster ...
|
||||||
|
//
|
||||||
|
// Author : go_developer@163.com<白茶清欢>
|
||||||
|
//
|
||||||
|
// Date : 2:13 上午 2021/11/27
|
||||||
|
type Cluster struct {
|
||||||
|
ClusterEnabled int `json:"cluster_enabled" yaml:"cluster_enabled"` // 是否启用 0 - 否 1 - 是
|
||||||
|
}
|
||||||
|
|
||||||
|
// Error 错误的状态 eg : errorstat_WRONGTYPE:count=4615
|
||||||
|
//
|
||||||
|
// Author : go_developer@163.com<白茶清欢>
|
||||||
|
//
|
||||||
|
// Date : 2:16 上午 2021/11/27
|
||||||
|
type Error struct {
|
||||||
|
Type string `json:"type" yaml:"type"` // 错误类型
|
||||||
|
Count int64 `json:"count" yaml:"count"` // 错误出现次数
|
||||||
|
}
|
||||||
|
|||||||
326
middleware/redis/monitor.go
Normal file
326
middleware/redis/monitor.go
Normal file
@ -0,0 +1,326 @@
|
|||||||
|
// Package redis ...
|
||||||
|
//
|
||||||
|
// Description : redis 系统信息监控
|
||||||
|
//
|
||||||
|
// Author : go_developer@163.com<白茶清欢>
|
||||||
|
//
|
||||||
|
// Date : 2021-11-27 12:22 下午
|
||||||
|
package redis
|
||||||
|
|
||||||
|
import (
|
||||||
|
"context"
|
||||||
|
"strings"
|
||||||
|
|
||||||
|
"git.zhangdeman.cn/zhangdeman/gopkg/convert"
|
||||||
|
|
||||||
|
yml "gopkg.in/yaml.v2"
|
||||||
|
|
||||||
|
"github.com/go-redis/redis/v8"
|
||||||
|
)
|
||||||
|
|
||||||
|
// GetRedisServerInfo 获取 redis server info
|
||||||
|
//
|
||||||
|
// Author : go_developer@163.com<白茶清欢>
|
||||||
|
//
|
||||||
|
// Date : 12:24 下午 2021/11/27
|
||||||
|
func GetRedisServerInfo(client *redis.Client) (*ServerInfo, error) {
|
||||||
|
var result ServerInfo
|
||||||
|
if err := infoToStruct(client, "server", &result); nil != err {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
return &result, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// GetMemoryInfo 获取内存信息
|
||||||
|
//
|
||||||
|
// Author : go_developer@163.com<白茶清欢>
|
||||||
|
//
|
||||||
|
// Date : 12:59 下午 2021/11/27
|
||||||
|
func GetMemoryInfo(client *redis.Client) (*MemoryInfo, error) {
|
||||||
|
var result MemoryInfo
|
||||||
|
if err := infoToStruct(client, "memory", &result); nil != err {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
return &result, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// GetClientInfo 获取客户端信息
|
||||||
|
//
|
||||||
|
// Author : go_developer@163.com<白茶清欢>
|
||||||
|
//
|
||||||
|
// Date : 1:10 下午 2021/11/27
|
||||||
|
func GetClientInfo(client *redis.Client) (*ClientInfo, error) {
|
||||||
|
var result ClientInfo
|
||||||
|
if err := infoToStruct(client, "clients", &result); nil != err {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
return &result, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// GetPersistence 获取持久化相关信息
|
||||||
|
//
|
||||||
|
// Author : go_developer@163.com<白茶清欢>
|
||||||
|
//
|
||||||
|
// Date : 1:11 下午 2021/11/27
|
||||||
|
func GetPersistence(client *redis.Client) (*Persistence, error) {
|
||||||
|
var result Persistence
|
||||||
|
if err := infoToStruct(client, "persistence", &result); nil != err {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
return &result, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// GetStats 获取状态
|
||||||
|
//
|
||||||
|
// Author : go_developer@163.com<白茶清欢>
|
||||||
|
//
|
||||||
|
// Date : 1:19 下午 2021/11/27
|
||||||
|
func GetStats(client *redis.Client) (*Stats, error) {
|
||||||
|
var result Stats
|
||||||
|
if err := infoToStruct(client, "stats", &result); nil != err {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
return &result, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// GetReplication 复制相关信息
|
||||||
|
//
|
||||||
|
// Author : go_developer@163.com<白茶清欢>
|
||||||
|
//
|
||||||
|
// Date : 1:23 下午 2021/11/27
|
||||||
|
func GetReplication(client *redis.Client) (*Replication, error) {
|
||||||
|
var result Replication
|
||||||
|
if err := infoToStruct(client, "replication", &result); nil != err {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
result.SlaveList = GetSlaveList(client)
|
||||||
|
return &result, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// GetSlaveList 获取从库信息
|
||||||
|
//
|
||||||
|
// Author : go_developer@163.com<白茶清欢>
|
||||||
|
//
|
||||||
|
// Date : 4:26 下午 2021/11/27
|
||||||
|
func GetSlaveList(client *redis.Client) []SlaveNode {
|
||||||
|
// 解析从库信息
|
||||||
|
slaveList := make([]SlaveNode, 0)
|
||||||
|
var data map[string]string
|
||||||
|
_ = infoToStruct(client, "replication", &data)
|
||||||
|
slaveKey := []string{"slave0", "slave1", "slave2", "slave3", "slave4", "slave5", "slave6", "slave7", "slave8", "slave9"}
|
||||||
|
for k, v := range data {
|
||||||
|
isSlave := false
|
||||||
|
for _, item := range slaveKey {
|
||||||
|
if strings.Contains(k, item) {
|
||||||
|
isSlave = true
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if !isSlave {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
|
||||||
|
vArr := strings.Split(v, ",")
|
||||||
|
if len(vArr) < 3 {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
slave := SlaveNode{
|
||||||
|
ID: k,
|
||||||
|
IP: "",
|
||||||
|
Port: 0,
|
||||||
|
State: "",
|
||||||
|
Offset: 0,
|
||||||
|
Lag: 0,
|
||||||
|
}
|
||||||
|
for _, prop := range vArr {
|
||||||
|
propArr := strings.Split(prop, "=")
|
||||||
|
if len(propArr) != 2 {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
switch strings.ToLower(propArr[0]) {
|
||||||
|
case "ip":
|
||||||
|
slave.IP = propArr[1]
|
||||||
|
case "port":
|
||||||
|
_ = convert.ConvertAssign(&slave.Port, propArr[1])
|
||||||
|
case "state":
|
||||||
|
slave.State = propArr[1]
|
||||||
|
case "offset":
|
||||||
|
_ = convert.ConvertAssign(&slave.Offset, propArr[1])
|
||||||
|
case "lag":
|
||||||
|
_ = convert.ConvertAssign(&slave.Lag, propArr[1])
|
||||||
|
}
|
||||||
|
}
|
||||||
|
slaveList = append(slaveList, slave)
|
||||||
|
}
|
||||||
|
return slaveList
|
||||||
|
}
|
||||||
|
|
||||||
|
// GetCPUInfo 获取cpu信息
|
||||||
|
//
|
||||||
|
// Author : go_developer@163.com<白茶清欢>
|
||||||
|
//
|
||||||
|
// Date : 1:24 下午 2021/11/27
|
||||||
|
func GetCPUInfo(client *redis.Client) (*CPU, error) {
|
||||||
|
var result CPU
|
||||||
|
if err := infoToStruct(client, "cpu", &result); nil != err {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
return &result, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// GetCommandStats 命令状态
|
||||||
|
//
|
||||||
|
// Author : go_developer@163.com<白茶清欢>
|
||||||
|
//
|
||||||
|
// Date : 1:27 下午 2021/11/27
|
||||||
|
func GetCommandStats(client *redis.Client) (*Stats, error) {
|
||||||
|
var result Stats
|
||||||
|
if err := infoToStruct(client, "stats", &result); nil != err {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
return &result, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// GetCommandInfo 获取命令信息
|
||||||
|
//
|
||||||
|
// Author : go_developer@163.com<白茶清欢>
|
||||||
|
//
|
||||||
|
// Date : 1:32 下午 2021/11/27
|
||||||
|
func GetCommandInfo(client *redis.Client) ([]CmdStat, error) {
|
||||||
|
var result map[string]string
|
||||||
|
if err := infoToStruct(client, "commandstats", &result); nil != err {
|
||||||
|
return make([]CmdStat, 0), err
|
||||||
|
}
|
||||||
|
cmdList := make([]CmdStat, 0)
|
||||||
|
// 解析数据
|
||||||
|
for cmd, detail := range result {
|
||||||
|
infoArr := strings.Split(detail, ",")
|
||||||
|
if len(infoArr) < 2 {
|
||||||
|
// 去掉开始的描述信息
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
info := CmdStat{
|
||||||
|
Cmd: strings.ReplaceAll(strings.ToLower(cmd), "cmdstat_", ""),
|
||||||
|
Calls: 0,
|
||||||
|
TotalUsedTime: 0,
|
||||||
|
AvgUsedTime: 0,
|
||||||
|
RejectedCalls: 0,
|
||||||
|
FailedCalls: 0,
|
||||||
|
SuccessCalls: 0,
|
||||||
|
}
|
||||||
|
for _, item := range infoArr {
|
||||||
|
itemArr := strings.Split(item, "=")
|
||||||
|
if len(itemArr) != 2 {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
switch strings.ToLower(itemArr[0]) {
|
||||||
|
case "calls":
|
||||||
|
_ = convert.ConvertAssign(&info.Calls, itemArr[1])
|
||||||
|
case "usec":
|
||||||
|
_ = convert.ConvertAssign(&info.TotalUsedTime, itemArr[1])
|
||||||
|
case "usec_per_call":
|
||||||
|
_ = convert.ConvertAssign(&info.AvgUsedTime, itemArr[1])
|
||||||
|
case "rejected_calls":
|
||||||
|
_ = convert.ConvertAssign(&info.RejectedCalls, itemArr[1])
|
||||||
|
case "failed_calls":
|
||||||
|
_ = convert.ConvertAssign(&info.FailedCalls, itemArr[1])
|
||||||
|
}
|
||||||
|
}
|
||||||
|
info.SuccessCalls = info.Calls - info.FailedCalls - info.RejectedCalls
|
||||||
|
cmdList = append(cmdList, info)
|
||||||
|
}
|
||||||
|
return cmdList, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// GetKeyspace 获取 keyspace 信息
|
||||||
|
//
|
||||||
|
// Author : go_developer@163.com<白茶清欢>
|
||||||
|
//
|
||||||
|
// Date : 2:44 下午 2021/11/27
|
||||||
|
func GetKeyspace(client *redis.Client) ([]DB, error) {
|
||||||
|
var result map[string]string
|
||||||
|
if err := infoToStruct(client, "keyspace", &result); nil != err {
|
||||||
|
return make([]DB, 0), err
|
||||||
|
}
|
||||||
|
dbList := make([]DB, 0)
|
||||||
|
for dbName, item := range result {
|
||||||
|
itemArr := strings.Split(item, ",")
|
||||||
|
if len(itemArr) < 3 {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
dbInfo := DB{
|
||||||
|
Name: dbName,
|
||||||
|
Keys: 0,
|
||||||
|
Expires: 0,
|
||||||
|
AvgTTL: 0,
|
||||||
|
}
|
||||||
|
for _, kv := range itemArr {
|
||||||
|
kvArr := strings.Split(kv, "=")
|
||||||
|
if len(kvArr) != 2 {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
switch strings.ToLower(kvArr[0]) {
|
||||||
|
case "keys":
|
||||||
|
_ = convert.ConvertAssign(&dbInfo.Keys, kvArr[1])
|
||||||
|
case "expires":
|
||||||
|
_ = convert.ConvertAssign(&dbInfo.Expires, kvArr[1])
|
||||||
|
case "avg_ttl":
|
||||||
|
_ = convert.ConvertAssign(&dbInfo.AvgTTL, kvArr[1])
|
||||||
|
}
|
||||||
|
}
|
||||||
|
dbList = append(dbList, dbInfo)
|
||||||
|
}
|
||||||
|
return dbList, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// GetCluster 获取 cluster 信息
|
||||||
|
//
|
||||||
|
// Author : go_developer@163.com<白茶清欢>
|
||||||
|
//
|
||||||
|
// Date : 3:30 下午 2021/11/27
|
||||||
|
func GetCluster(client *redis.Client) (*Cluster, error) {
|
||||||
|
var result Cluster
|
||||||
|
if err := infoToStruct(client, "cluster", &result); nil != err {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
return &result, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// GetErrorStats 获取错误状态信息
|
||||||
|
//
|
||||||
|
// Author : go_developer@163.com<白茶清欢>
|
||||||
|
//
|
||||||
|
// Date : 3:35 下午 2021/11/27
|
||||||
|
func GetErrorStats(client *redis.Client) ([]Error, error) {
|
||||||
|
var result map[string]string
|
||||||
|
if err := infoToStruct(client, "errorstats", &result); nil != err {
|
||||||
|
return make([]Error, 0), err
|
||||||
|
}
|
||||||
|
|
||||||
|
errList := make([]Error, 0)
|
||||||
|
for errType, item := range result {
|
||||||
|
itemArr := strings.Split(item, "=")
|
||||||
|
if len(itemArr) != 2 {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
errInfo := Error{
|
||||||
|
Type: strings.ReplaceAll(errType, "errorstat_", ""),
|
||||||
|
Count: 0,
|
||||||
|
}
|
||||||
|
_ = convert.ConvertAssign(&errInfo.Count, itemArr[1])
|
||||||
|
errList = append(errList, errInfo)
|
||||||
|
}
|
||||||
|
return errList, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// infoToStruct 读取到的数据,解析到结构体
|
||||||
|
//
|
||||||
|
// Author : go_developer@163.com<白茶清欢>
|
||||||
|
//
|
||||||
|
// Date : 12:28 下午 2021/11/27
|
||||||
|
func infoToStruct(client *redis.Client, module string, receiver interface{}) error {
|
||||||
|
data := client.Info(context.Background(), module).String()
|
||||||
|
// yaml 文件规范要求, key: val , 注意 : 的后面有空格
|
||||||
|
data = strings.ReplaceAll(data, ":", ": ")
|
||||||
|
return yml.Unmarshal([]byte(data), receiver)
|
||||||
|
}
|
||||||
@ -42,6 +42,12 @@ func TestCommandProxy(t *testing.T) {
|
|||||||
panic(err.Error())
|
panic(err.Error())
|
||||||
}
|
}
|
||||||
r, cmdErr := instance.CommandProxy(nil, "test_redis", "set", "command_proxy", "hello world")
|
r, cmdErr := instance.CommandProxy(nil, "test_redis", "set", "command_proxy", "hello world")
|
||||||
|
c, _ := instance.GetRedisClient("test_redis")
|
||||||
|
fmt.Println(GetRedisServerInfo(c.Instance))
|
||||||
|
fmt.Println(GetCommandInfo(c.Instance))
|
||||||
|
fmt.Println(GetKeyspace(c.Instance))
|
||||||
|
fmt.Println(GetCluster(c.Instance))
|
||||||
|
fmt.Println(GetErrorStats(c.Instance))
|
||||||
assert.Nil(t, cmdErr, "命令执行成功")
|
assert.Nil(t, cmdErr, "命令执行成功")
|
||||||
assert.Equal(t, "OK", fmt.Sprintf("%v", r))
|
assert.Equal(t, "OK", fmt.Sprintf("%v", r))
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user