b589fbfbd9
* ci: switch to go1.12.12 on machine executors - This brings in recent ci changes from the release/1.2.x branch. * go mod vendor * ci: remove ent build tags * ci: fix gopath * go mod vendor * ci: ensure yarn install * ci: add debug commands * ci: debugging * ci: increment yarn cache; remove debugging * ci: remove redundant yarn install
90 lines
2.3 KiB
Go
90 lines
2.3 KiB
Go
package rabbithole
|
|
|
|
import (
|
|
"net/url"
|
|
)
|
|
|
|
// BriefConnectionDetails represents a brief (very incomplete) subset of connection information.
|
|
type BriefConnectionDetails struct {
|
|
// Connection name
|
|
Name string `json:"name"`
|
|
// Client port
|
|
PeerPort Port `json:"peer_port"`
|
|
// Client host
|
|
PeerHost string `json:"peer_host"`
|
|
}
|
|
|
|
// ChannelInfo represents an AMQP 0-9-1 channel.
|
|
type ChannelInfo struct {
|
|
// Channel number
|
|
Number int `json:"number"`
|
|
// Channel name
|
|
Name string `json:"name"`
|
|
|
|
// basic.qos (prefetch count) value used
|
|
PrefetchCount int `json:"prefetch_count"`
|
|
// How many consumers does this channel have
|
|
ConsumerCount int `json:"consumer_count"`
|
|
|
|
// Number of unacknowledged messages on this channel
|
|
UnacknowledgedMessageCount int `json:"messages_unacknowledged"`
|
|
// Number of messages on this channel unconfirmed to publishers
|
|
UnconfirmedMessageCount int `json:"messages_unconfirmed"`
|
|
// Number of messages on this channel uncommited to message store
|
|
UncommittedMessageCount int `json:"messages_uncommitted"`
|
|
// Number of acks on this channel uncommited to message store
|
|
UncommittedAckCount int `json:"acks_uncommitted"`
|
|
|
|
// TODO(mk): custom deserializer to date/time?
|
|
IdleSince string `json:"idle_since"`
|
|
|
|
// True if this channel uses publisher confirms
|
|
UsesPublisherConfirms bool `json:"confirm"`
|
|
// True if this channel uses transactions
|
|
Transactional bool `json:"transactional"`
|
|
// True if this channel is blocked via channel.flow
|
|
ClientFlowBlocked bool `json:"client_flow_blocked"`
|
|
|
|
User string `json:"user"`
|
|
Vhost string `json:"vhost"`
|
|
Node string `json:"node"`
|
|
|
|
ConnectionDetails BriefConnectionDetails `json:"connection_details"`
|
|
}
|
|
|
|
//
|
|
// GET /api/channels
|
|
//
|
|
|
|
// ListChannels returns information about all open channels.
|
|
func (c *Client) ListChannels() (rec []ChannelInfo, err error) {
|
|
req, err := newGETRequest(c, "channels")
|
|
if err != nil {
|
|
return []ChannelInfo{}, err
|
|
}
|
|
|
|
if err = executeAndParseRequest(c, req, &rec); err != nil {
|
|
return []ChannelInfo{}, err
|
|
}
|
|
|
|
return rec, nil
|
|
}
|
|
|
|
//
|
|
// GET /api/channels/{name}
|
|
//
|
|
|
|
// GetChannel returns channel information.
|
|
func (c *Client) GetChannel(name string) (rec *ChannelInfo, err error) {
|
|
req, err := newGETRequest(c, "channels/"+url.PathEscape(name))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
if err = executeAndParseRequest(c, req, &rec); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return rec, nil
|
|
}
|