monitor

Documentation

Index

• func BulkTable(bulk string) (map[string]string, error)
• type CPU
  • func NewCPU(sys, user float64) *CPU
  • func (c *CPU) Tick(sys, user float64) (float64, float64)
• type Line
• type MemoryStats
  • func (m *MemoryStats) Table() [][]string
• type RedisServer
  • func Redis(address, password string) (*RedisServer, error)
  • func (r *RedisServer) Info() (map[string]string, error)
  • func (r *RedisServer) Memory() (*MemoryStats, error)
  • func (r *RedisServer) Monitor(ctx context.Context, evt func(bool)) (chan Line, chan error)

Functions

func BulkTable

func BulkTable(bulk string) (map[string]string, error)

Types

type CPU

type CPU struct {
	// contains filtered or unexported fields
}

func NewCPU

func NewCPU(sys, user float64) *CPU

func (*CPU) Tick

func (c *CPU) Tick(sys, user float64) (float64, float64)

type Line

type Line struct {
	IP string

	Command string
	// contains filtered or unexported fields
}

type MemoryStats

type MemoryStats struct {
	PeakAllocated      int64
	DatasetBytes       int64
	KeysCount          int64
	Fragmentation      float64
	ReplicationBacklog int64
}

func (*MemoryStats) Table

func (m *MemoryStats) Table() [][]string

type RedisServer

type RedisServer struct {
	// contains filtered or unexported fields
}

func Redis

func Redis(address, password string) (*RedisServer, error)

func (*RedisServer) Info

func (r *RedisServer) Info() (map[string]string, error)

func (*RedisServer) Memory

func (r *RedisServer) Memory() (*MemoryStats, error)

func (*RedisServer) Monitor

func (r *RedisServer) Monitor(ctx context.Context, evt func(bool)) (chan Line, chan error)