funcs

Documentation

Index

• func CheckAlive() (ok bool)
• func GetChannelCost() (getChannelCost float64, err error)
• type Aliveness
  • func GetAlive() (aliveness *Aliveness, err error)
• type ExchangeInfo
  • func GetExchanges() (exchs []*ExchangeInfo, err error)
• type MemStats
• type MsgStat
• type NodeStats
  • func GetNode() (n *NodeStats, err error)
  • func (n *NodeStats) DiskAlarmStatus() int
  • func (n *NodeStats) MemAlarmStatus() int
• type ObjectTotal
• type OverView
  • func GetOverview() (result *OverView, err error)
• type QueueMap
  • func GetQueues() (qm []*QueueMap, err error)
• type QueueMsgStat
• type QueueRate
• type QueueTotal
• type Rate
• type VHostName

Functions

func CheckAlive

func CheckAlive() (ok bool)

CheckAlive ...

func GetChannelCost

func GetChannelCost() (getChannelCost float64, err error)

GetChannelCost time cost of getting channel

Types

type Aliveness

type Aliveness struct {
	Status string `json:"status"`
}

Aliveness ...

func GetAlive

func GetAlive() (aliveness *Aliveness, err error)

GetAlive ...

type ExchangeInfo

type ExchangeInfo struct {
	Name     string `json:"name"`
	VHost    string `json:"vhost"`
	MsgStats struct {
		Confirm    int64 `json:"confirm"`
		PublishIn  int64 `json:"publish_in"`
		PublishOut int64 `json:"publish_out"`

		ConfirmRate struct {
			Rate float64 `json:"rate"`
		} `json:"confirm_details"`

		PublishInRate struct {
			Rate float64 `json:"rate"`
		} `json:"publish_in_details"`

		PublishOutRate struct {
			Rate float64 `json:"rate"`
		} `json:"publish_out_details"`
	} `json:"message_stats"`
}

ExchangeInfo information for exchange

func GetExchanges

func GetExchanges() (exchs []*ExchangeInfo, err error)

GetExchanges get all exchanges

type MemStats

type MemStats struct {
	Total              int64 `json:"total"`
	ConnectionReaders  int64 `json:"connection_readers"`
	ConnectionWriters  int64 `json:"connection_writers"`
	ConnectionChannels int64 `json:"connection_channels"`
	ConnectionOther    int64 `json:"connection_other"`
	QueueProcs         int64 `json:"queue_procs"`
	QueueSlaveProcs    int64 `json:"queue_slave_procs"`
	Plugins            int64 `json:"plugins"`
	Mnesia             int64 `json:"mnesia"`
	MgmtDB             int64 `json:"mgmt_db"`
	MsgIndex           int64 `json:"msg_index"`
	Code               int64 `json:"code"`
	Atom               int64 `json:"atom"`
	Binary             int64 `json:"binary"`
}

MemStats ...

type MsgStat

type MsgStat struct {
	Publish           int64 `json:"publish"`
	Ack               int64 `json:"ack"`
	DeliverGet        int64 `json:"deliver_get"`
	Redeliver         int64 `json:"redeliver"`
	Confirm           int64 `json:"confirm"`
	Deliver           int64 `json:"deliver"`
	DeliverNoAck      int64 `json:"deliver_no_ack"`
	Get               int64 `json:"get"`
	GetNoAck          int64 `json:"get_no_ack"`
	PublishRates      Rate  `json:"publish_details"`
	DeliverGetRates   Rate  `json:"deliver_get_details"`
	AckRates          Rate  `json:"ack_details"`
	ConfirmRates      Rate  `json:"confirm_details"`
	RedeliverRates    Rate  `json:"redeliver_details"`
	DeliverRates      Rate  `json:"deliver_details"`
	DeliverNoAckRates Rate  `json:"deliver_no_ack_details"`
	GetNoAckRates     Rate  `json:"get_no_ack_details"`
	GetRates          Rate  `json:"get_details"`
}

MsgStat ...

type NodeStats

type NodeStats struct {
	MemStats     `json:"memory"`
	Partitions   []string `json:"partitions"`
	Rawait       float64  `json:"io_read_avg_time"`
	Wawait       float64  `json:"io_write_avg_time"`
	Syncawait    float64  `json:"io_sync_avg_time"`
	MemUsed      int64    `json:"mem_used"`
	MemLimit     int64    `json:"mem_limit"`
	SocketsUsed  int64    `json:"sockets_used"`
	SocketsTotal int64    `json:"sockets_total"`
	FdUsed       int64    `json:"fd_used"`
	FdTotal      int64    `json:"fd_total"`
	ErlProcUsed  int64    `json:"proc_used"`
	ErlProcTotal int64    `json:"proc_total"`
	RunQueues    int64    `json:"run_queue"`
	MemAlarm     bool     `json:"mem_alarm"`
	DiskAlarm    bool     `json:"disk_free_alarm"`
}

NodeStats ...

func GetNode

func GetNode() (n *NodeStats, err error)

GetNode ...

func (*NodeStats) DiskAlarmStatus

func (n *NodeStats) DiskAlarmStatus() int

DiskAlarmStatus disc alarm status

func (*NodeStats) MemAlarmStatus

func (n *NodeStats) MemAlarmStatus() int

MemAlarmStatus memory alarm status

type ObjectTotal

type ObjectTotal struct {
	Consumers   int64 `json:"consumers"`
	Queues      int64 `json:"queues"`
	Exchanges   int64 `json:"exchanges"`
	Connections int64 `json:"connections"`
	Channels    int64 `json:"channels"`
}

ObjectTotal ...

type OverView

type OverView struct {
	MsgStat          `json:"message_stats"`
	QueueTotal       `json:"queue_totals"`
	ObjectTotal      `json:"object_totals"`
	StatsDbEvents    int    `json:"statistics_db_event_queue"`
	StatisticsDbNode string `json:"statistics_db_node"`
}

OverView ...

func GetOverview

func GetOverview() (result *OverView, err error)

GetOverview ...

type QueueMap

type QueueMap struct {
	Memory          int64       `json:"memory"`
	Messages        int64       `json:"messages"`
	MessagesReady   int64       `json:"messages_ready"`
	MessagesUnacked int64       `json:"messages_unacknowledged"`
	ConsumerUtil    interface{} `json:"consumer_utilisation"`
	Consumers       int64       `json:"consumers"`
	Status          string      `json:"state"`
	Name            string      `json:"name"`
	Vhost           string      `json:"vhost"`
	AutoDelete      bool        `json:"auto_delete"`
	QueueMsgStat    `json:"message_stats"`
}

QueueMap ...

func GetQueues

func GetQueues() (qm []*QueueMap, err error)

GetQueues ...

type QueueMsgStat

type QueueMsgStat struct {
	Publish    QueueRate `json:"publish_details"`
	DeliverGet QueueRate `json:"deliver_get_details"`
	Ack        QueueRate `json:"ack_details"`
	Redeliver  QueueRate `json:"redeliver_details"`
}

QueueMsgStat ...

type QueueRate

type QueueRate struct {
	Rate float64 `json:"rate"`
}

QueueRate ...

type QueueTotal

type QueueTotal struct {
	MsgsTotal        int64 `json:"messages"`
	MsgsReadyTotal   int64 `json:"messages_ready"`
	MsgsUnackedTotal int64 `json:"messages_unacknowledged"`
}

QueueTotal ...

type Rate

type Rate struct {
	Rate float64 `json:"rate"`
}

Rate ...

type VHostName

type VHostName struct {
	Name string `json:"name"`
}

VHostName name of vHost