mypika

Documentation

Index

• func ParsePikaInfoClients(result map[string]string, info *PikaInfoAll)
• func ParsePikaInfoData(result map[string]string, info *PikaInfoAll)
• func ParsePikaInfoKeyspace(result map[string]string, info *PikaInfoAll)
• func ParsePikaInfoRepl(result map[string]string, info *PikaInfoAll)
• func ParsePikaInfoSever(result map[string]string, info *PikaInfoAll)
• func ParsePikaInfoStats(result map[string]string, info *PikaInfoAll)
• type PikaConfVar
  • func GetPikaConfVars(client myredis.ClusterAndRedisClient, ifBreakOnErr bool) (PikaConfVar, error)
• type PikaInfoAll
  • func GetPikaInfoAll(client myredis.ClusterAndRedisClient) (PikaInfoAll, error)

Functions

func ParsePikaInfoClients

func ParsePikaInfoClients(result map[string]string, info *PikaInfoAll)

func ParsePikaInfoData

func ParsePikaInfoData(result map[string]string, info *PikaInfoAll)

func ParsePikaInfoKeyspace

func ParsePikaInfoKeyspace(result map[string]string, info *PikaInfoAll)

# Keyspace（key数量展示，按照数据类型分类展示，默认不更新，仅在执行info keyspace 1的时候刷新该信息） # Time:2016-04-22 17:08:33 ------------------------------ 上一次统计的时间 kv keys:43 hash keys:503 list keys:0 zset keys:0 set keys:0

# Keyspace # Time:1970-01-01 08:00:00 kv keys:0 hash keys:0 list keys:0 zset keys:0 set keys:0

func ParsePikaInfoRepl

func ParsePikaInfoRepl(result map[string]string, info *PikaInfoAll)

# Replication(MASTER) role:master --------------------------------------------- 本实例角色 connected_slaves:1 -------------------------------------- 当前从库数量 slave0: host_port=192.168.1.1:57765 state=online -------- 当前从库连接信息，如果有多个从库则依次展示

#从库（区别仅在于同步信息的展示）： # Replication(SLAVE) role:slave ---------------------------------------------- 本实例角色 master_host:192.168.1.2 --------------------------------- 主库IP master_port:9001 ---------------------------------------- 主库端口 master_link_status:up ----------------------------------- 当前同步状态 slave_read_only:1 --------------------------------------- 从库是否readonly

func ParsePikaInfoSever

func ParsePikaInfoSever(result map[string]string, info *PikaInfoAll)

func ParsePikaInfoStats

func ParsePikaInfoStats(result map[string]string, info *PikaInfoAll)

Types

type PikaConfVar

type PikaConfVar struct {
	Maxmemory          uint64
	TargetFileSizeBase uint64
}

func GetPikaConfVars

func GetPikaConfVars(client myredis.ClusterAndRedisClient, ifBreakOnErr bool) (PikaConfVar, error)

type PikaInfoAll

type PikaInfoAll struct {
	Process_id                 int32
	Config_file                string
	Server_id                  uint64
	Db_size                    uint64
	Used_memory                uint64
	Db_memtable_usage          uint64
	Db_tablereader_usage       uint64
	Connected_clients          uint64
	Total_connections_received uint64
	Instantaneous_ops_per_sec  float64
	Accumulative_query_nums    uint64 //pika 2.3.0
	Total_commands_processed   uint64 // pika 2.2.5
	Is_bgsaving                int8
	Is_scaning_keyspace        int8
	Is_compact                 int8
	Role                       string
	Master_host                string
	Master_port                uint64
	IsSlave                    int8
	Master_link_status         int8 //1; up, 0: down
	Slave_read_only            int8 // 1:readonly, 0: read and write
	KeysCnt                    uint64
	KeysCntHash                uint64
	KeysCntList                uint64
	KeysCntZset                uint64
	KeysCntSet                 uint64
}

func GetPikaInfoAll

func GetPikaInfoAll(client myredis.ClusterAndRedisClient) (PikaInfoAll, error)