46 lines
1.1 KiB
Go
46 lines
1.1 KiB
Go
|
package rabbithole
|
||
|
|
|
||
|
|
import "strconv"
|
||
|
|
|
||
|
|
// Extra arguments as a map (on queues, bindings, etc)
|
||
|
|
type Properties map[string]interface{}
|
||
|
|
|
||
|
|
// Port used by RabbitMQ or clients
|
||
|
|
type Port int
|
||
|
|
|
||
|
|
func (p *Port) UnmarshalJSON(b []byte) error {
|
||
|
|
stringValue := string(b)
|
||
|
|
var parsed int64
|
||
|
|
var err error
|
||
|
|
if stringValue[0] == '"' && stringValue[len(stringValue)-1] == '"' {
|
||
|
|
parsed, err = strconv.ParseInt(stringValue[1:len(stringValue)-1], 10, 32)
|
||
|
|
} else {
|
||
|
|
parsed, err = strconv.ParseInt(stringValue, 10, 32)
|
||
|
|
}
|
||
|
|
if err == nil {
|
||
|
|
*p = Port(int(parsed))
|
||
|
|
}
|
||
|
|
return err
|
||
|
|
}
|
||
|
|
|
||
|
|
// Rate of change of a numerical value
|
||
|
|
type RateDetails struct {
|
||
|
|
Rate float32 `json:"rate"`
|
||
|
|
}
|
||
|
|
|
||
|
|
// RabbitMQ context (Erlang app) running on
|
||
|
|
// a node
|
||
|
|
type BrokerContext struct {
|
||
|
|
Node string `json:"node"`
|
||
|
|
Description string `json:"description"`
|
||
|
|
Path string `json:"path"`
|
||
|
|
Port Port `json:"port"`
|
||
|
|
Ignore bool `json:"ignore_in_use"`
|
||
|
|
}
|
||
|
|
|
||
|
|
// Basic published messages statistics
|
||
|
|
type MessageStats struct {
|
||
|
|
Publish int `json:"publish"`
|
||
|
|
PublishDetails RateDetails `json:"publish_details"`
|
||
|
|
}
|