proxy

Documentation

Index

• type ApiClient
  • func NewApiClient(addr string) *ApiClient
  • func (c *ApiClient) FillPconfigs(pconfig []*models.Pconfig) error
  • func (c *ApiClient) FillSlots(slots ...*models.Slot) error
  • func (c *ApiClient) Model() (*models.Proxy, error)
  • func (c *ApiClient) ReadCrossCloud(flag string) error
  • func (c *ApiClient) SetXAuth(name, auth string, token string)
  • func (c *ApiClient) Shutdown() error
  • func (c *ApiClient) Start() error
  • func (c *ApiClient) StatsSimple() (*Stats, error)
  • func (c *ApiClient) XPing() error
• type CalOpStats
• type GlobalOpsCost
• type OpsCost
• type PoolStat
• type RuntimeStats
• type Stats
• type StatsFlags
• type Usage

Types

type ApiClient

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

func NewApiClient

func NewApiClient(addr string) *ApiClient

func (*ApiClient) FillPconfigs

func (c *ApiClient) FillPconfigs(pconfig []*models.Pconfig) error

func (*ApiClient) FillSlots

func (c *ApiClient) FillSlots(slots ...*models.Slot) error

func (*ApiClient) Model

func (c *ApiClient) Model() (*models.Proxy, error)

func (*ApiClient) ReadCrossCloud

func (c *ApiClient) ReadCrossCloud(flag string) error

func (*ApiClient) SetXAuth

func (c *ApiClient) SetXAuth(name, auth string, token string)

func (*ApiClient) Shutdown

func (c *ApiClient) Shutdown() error

func (*ApiClient) Start

func (c *ApiClient) Start() error

func (*ApiClient) StatsSimple

func (c *ApiClient) StatsSimple() (*Stats, error)

func (*ApiClient) XPing

func (c *ApiClient) XPing() error

type CalOpStats

type CalOpStats struct {
	OpStr        string `json:"opstr"`
	Calls        int64  `json:"calls"`
	Usecs        int64  `json:"usecs"`
	UsecsPercall int64  `json:"usecs_percall"`
	Fails        int64  `json:"fails"`
	PeriodFails  int64  `json:"periodfails"`
}

type GlobalOpsCost

type GlobalOpsCost struct {
	AvgCost   atomic.Int64 `json:"avg_cost"`
	KVCost    atomic.Int64 `json:"kv_cost"`
	ListCost  atomic.Int64 `json:"list_cost"`
	HashCost  atomic.Int64 `json:"hash_cost"`
	SetCost   atomic.Int64 `json:"set_cost"`
	ZsetCost  atomic.Int64 `json:"zset_cost"`
	WriteCost atomic.Int64 `json:"write_cost"`
	ReadCost  atomic.Int64 `json:"read_cost"`
}

type OpsCost

type OpsCost struct {
	AvgCost   int64 `json:"avg_cost"`
	KVCost    int64 `json:"kv_cost"`
	ListCost  int64 `json:"list_cost"`
	HashCost  int64 `json:"hash_cost"`
	SetCost   int64 `json:"set_cost"`
	ZsetCost  int64 `json:"zset_cost"`
	WriteCost int64 `json:"write_cost"`
	ReadCost  int64 `json:"read_cost"`
}

type PoolStat

type PoolStat struct {
	ActiveCount int `json:"active_count"`
	IdleCount   int `json:"idle_count"`
}

type RuntimeStats

type RuntimeStats struct {
	General struct {
		Alloc   uint64 `json:"alloc"`
		Sys     uint64 `json:"sys"`
		Lookups uint64 `json:"lookups"`
		Mallocs uint64 `json:"mallocs"`
		Frees   uint64 `json:"frees"`
	} `json:"general"`

	Heap struct {
		Alloc   uint64 `json:"alloc"`
		Sys     uint64 `json:"sys"`
		Idle    uint64 `json:"idle"`
		Inuse   uint64 `json:"inuse"`
		Objects uint64 `json:"objects"`
	} `json:"heap"`

	GC struct {
		Num          uint32  `json:"num"`
		CPUFraction  float64 `json:"cpu_fraction"`
		TotalPauseMs uint64  `json:"total_pausems"`
	} `json:"gc"`

	NumProcs      int   `json:"num_procs"`
	NumGoroutines int   `json:"num_goroutines"`
	NumCgoCall    int64 `json:"num_cgo_call"`
}

type Stats

type Stats struct {
	Online bool `json:"online"`
	Closed bool `json:"closed"`

	ReadCrossCloud bool `json:"read_cross_cloud"`
	PoolActive     int  `json:"pool_active"`

	CmdOps struct {
		Total       int64         `json:"total"`
		Fails       int64         `json:"fails"`
		PeriodFails int64         `json:"periodfails"`
		QPS         int64         `json:"qps"`
		Cmd         []*CalOpStats `json:"cmd,omitempty"`

		OpsCost
	} `json:"cdm_ops"`

	Pool PoolStat `json:"pool"`

	Sessions struct {
		Total int64 `json:"total"`
		Alive int64 `json:"alive"`
	} `json:"sessions"`

	Rusage struct {
		Now string  `json:"now"`
		CPU float64 `json:"cpu"`
		Mem int64   `json:"mem"`
		Raw *Usage  `json:"raw,omitempty"`
	} `json:"rusage"`

	Runtime *RuntimeStats `json:"runtime,omitempty"`
	// contains filtered or unexported fields
}

type StatsFlags

type StatsFlags uint32

type Usage

type Usage struct {
	Utime time.Duration `json:"utime"`
	Stime time.Duration `json:"stime"`

	MaxRss int64 `json:"max_rss"`
	Ixrss  int64 `json:"ix_rss"`
	Idrss  int64 `json:"id_rss"`
	Isrss  int64 `json:"is_rss"`
}