common

Documentation

Index

• type CQChannel
  • func (cc *CQChannel) String() string
• type CQStats
  • func (cs *CQStats) String() string
• type PubSubChannel
  • func (pc *PubSubChannel) String() string
• type PubSubStats
  • func (ps *PubSubStats) String() string
• type QueuesChannel
  • func (qc *QueuesChannel) String() string
• type QueuesStats
  • func (qs *QueuesStats) String() string

Types

type CQChannel

type CQChannel struct {
	Name         string  `json:"name"`
	Type         string  `json:"type"`
	LastActivity int     `json:"lastActivity"`
	IsActive     bool    `json:"isActive"`
	Incoming     CQStats `json:"incoming"`
	Outgoing     CQStats `json:"outgoing"`
}

func (*CQChannel) String

func (cc *CQChannel) String() string

type CQStats

type CQStats struct {
	Messages  int `json:"messages"`
	Volume    int `json:"volume"`
	Responses int `json:"responses"`
}

func (*CQStats) String

func (cs *CQStats) String() string

type PubSubChannel

type PubSubChannel struct {
	Name         string      `json:"name"`
	Type         string      `json:"type"`
	LastActivity int         `json:"lastActivity"`
	IsActive     bool        `json:"isActive"`
	Incoming     PubSubStats `json:"incoming"`
	Outgoing     PubSubStats `json:"outgoing"`
}

func (*PubSubChannel) String

func (pc *PubSubChannel) String() string

type PubSubStats

type PubSubStats struct {
	Messages int `json:"messages"`
	Volume   int `json:"volume"`
}

func (*PubSubStats) String

func (ps *PubSubStats) String() string

type QueuesChannel

type QueuesChannel struct {
	Name         string      `json:"name"`
	Type         string      `json:"type"`
	LastActivity int         `json:"lastActivity"`
	IsActive     bool        `json:"isActive"`
	Incoming     QueuesStats `json:"incoming"`
	Outgoing     QueuesStats `json:"outgoing"`
}

func (*QueuesChannel) String

func (qc *QueuesChannel) String() string

type QueuesStats

type QueuesStats struct {
	Messages int `json:"messages"`
	Volume   int `json:"volume"`
	Waiting  int `json:"waiting"`
	Expired  int `json:"expired"`
	Delayed  int `json:"delayed"`
}

func (*QueuesStats) String

func (qs *QueuesStats) String() string