rabbithole

package module

Go to main page

Versions in this module

v1

v1.4.0

Sep 13, 2017

Changes in this version

type Client

+ func (c *Client) GetClusterName() (rec *ClusterName, err error)

+ func (c *Client) PutUserWithoutPassword(username string, info UserSettings) (res *http.Response, err error)

+ func (c *Client) SetClusterName(cn ClusterName) (res *http.Response, err error)

+ func (c *Client) SetTimeout(timeout time.Duration)

+ type ClusterName struct

+ Name string

v1.3.0

Mar 25, 2017

Changes in this version

type Client

+ func (c *Client) DeclareShovel(vhost, shovel string, info ShovelDefinition) (res *http.Response, err error)

+ func (c *Client) DeleteShovel(vhost, shovel string) (res *http.Response, err error)

+ func (c *Client) GetShovel(vhost, shovel string) (rec *ShovelInfo, err error)

+ func (c *Client) ListShovels() (rec []ShovelInfo, err error)

+ func (c *Client) ListShovelsIn(vhost string) (rec []ShovelInfo, err error)

+ type ErrorResponse struct

+ Message string

+ Reason string

+ StatusCode int

+ func (rme ErrorResponse) Error() string

type FederationDefinition

+ Exchange string

+ Queue string

+ type ShovelDefinition struct

+ AckMode string

+ AddForwardHeaders bool

+ DeleteAfter string

+ DestinationExchange string

+ DestinationExchangeKey string

+ DestinationQueue string

+ DestinationURI string

+ PrefetchCount int

+ ReconnectDelay int

+ SourceExchange string

+ SourceExchangeKey string

+ SourceQueue string

+ SourceURI string

+ type ShovelDefinitionDTO struct

+ Definition ShovelDefinition

+ type ShovelInfo struct

+ Component string

+ Definition ShovelDefinition

+ Name string

+ Vhost string

v1.2.0

Feb 1, 2017

Changes in this version

+ func PathEscape(s string) string

type Client

+ func (c *Client) GetQueueWithParameters(vhost, queue string, qs url.Values) (rec *DetailedQueueInfo, err error)

+ func (c *Client) ListQueuesWithParameters(params url.Values) (rec []QueueInfo, err error)

+ type RateDetailSample struct

+ Sample int64

+ Timestamp int64

type RateDetails

+ Samples []RateDetailSample

v1.1.0

Dec 1, 2016

Changes in this version

type Client

+ func (c *Client) PurgeQueue(vhost, queue string) (res *http.Response, err error)

type MessageStats

+ Deliver int

+ DeliverDetails RateDetails

+ DeliverGet int

+ DeliverGetDetails RateDetails

+ DeliverNoAck int

+ DeliverNoAckDetails RateDetails

+ Get int

+ GetDetails RateDetails

+ GetNoAck int

+ GetNoAckDetails RateDetails

+ Redeliver int

+ RedeliverDetails RateDetails

type QueueInfo

+ ConsumerUtilisation float64

+ MessagesBytes int64

+ MessagesBytesPersistent int64

+ MessagesBytesRAM int64

+ MessagesPersistent int

+ MessagesRAM int

v1.0.0

Dec 25, 2015

Changes in this version

+ type AuthMechanism NameDescriptionEnabled

+ type BackingQueueStatus struct

+ AverageAckEgressRate float32

+ AverageAckIngressRate float32

+ AverageEgressRate float64

+ AverageIngressRate float64

+ Length int64

+ PendingAcks int64

+ PersistentCount int64

+ Q1 int

+ Q2 int

+ Q3 int

+ Q4 int

+ RAMAckCount int64

+ RAMMessageCount int64

+ type BindingInfo struct

+ Arguments map[string]interface{}

+ Destination string

+ DestinationType string

+ PropertiesKey string

+ RoutingKey string

+ Source string

+ Vhost string

+ type BriefConnectionDetails struct

+ Name string

+ PeerHost string

+ PeerPort Port

+ type BrokerContext struct

+ Description string

+ Ignore bool

+ Node string

+ Path string

+ Port Port

+ type ChannelInfo struct

+ ClientFlowBlocked bool

+ ConnectionDetails BriefConnectionDetails

+ ConsumerCount int

+ IdleSince string

+ Name string

+ Node string

+ Number int

+ PrefetchCount int

+ Transactional bool

+ UnacknowledgedMessageCount int

+ UncommittedAckCount int

+ UncommittedMessageCount int

+ UnconfirmedMessageCount int

+ User string

+ UsesPublisherConfirms bool

+ Vhost string

+ type Client struct

+ Endpoint string

+ Password string

+ Username string

+ func NewClient(uri string, username string, password string) (me *Client, err error)

+ func NewTLSClient(uri string, username string, password string, transport *http.Transport) (me *Client, err error)

+ func (c *Client) ClearPermissionsIn(vhost, username string) (res *http.Response, err error)

+ func (c *Client) CloseConnection(name string) (res *http.Response, err error)

+ func (c *Client) DeclareBinding(vhost string, info BindingInfo) (res *http.Response, err error)

+ func (c *Client) DeclareExchange(vhost, exchange string, info ExchangeSettings) (res *http.Response, err error)

+ func (c *Client) DeclareQueue(vhost, queue string, info QueueSettings) (res *http.Response, err error)

+ func (c *Client) DeleteBinding(vhost string, info BindingInfo) (res *http.Response, err error)

+ func (c *Client) DeleteExchange(vhost, exchange string) (res *http.Response, err error)

+ func (c *Client) DeleteFederationUpstream(vhost, upstreamName string) (res *http.Response, err error)

+ func (c *Client) DeletePolicy(vhost, name string) (res *http.Response, err error)

+ func (c *Client) DeleteQueue(vhost, queue string) (res *http.Response, err error)

+ func (c *Client) DeleteUser(username string) (res *http.Response, err error)

+ func (c *Client) DeleteVhost(vhostname string) (res *http.Response, err error)

+ func (c *Client) EnabledProtocols() (xs []string, err error)

+ func (c *Client) GetChannel(name string) (rec *ChannelInfo, err error)

+ func (c *Client) GetConnection(name string) (rec *ConnectionInfo, err error)

+ func (c *Client) GetExchange(vhost, exchange string) (rec *DetailedExchangeInfo, err error)

+ func (c *Client) GetNode(name string) (rec *NodeInfo, err error)

+ func (c *Client) GetPermissionsIn(vhost, username string) (rec PermissionInfo, err error)

+ func (c *Client) GetPolicy(vhost, name string) (rec *Policy, err error)

+ func (c *Client) GetQueue(vhost, queue string) (rec *DetailedQueueInfo, err error)

+ func (c *Client) GetUser(username string) (rec *UserInfo, err error)

+ func (c *Client) GetVhost(vhostname string) (rec *VhostInfo, err error)

+ func (c *Client) ListBindings() (rec []BindingInfo, err error)

+ func (c *Client) ListBindingsIn(vhost string) (rec []BindingInfo, err error)

+ func (c *Client) ListChannels() (rec []ChannelInfo, err error)

+ func (c *Client) ListConnections() (rec []ConnectionInfo, err error)

+ func (c *Client) ListExchanges() (rec []ExchangeInfo, err error)

+ func (c *Client) ListExchangesIn(vhost string) (rec []ExchangeInfo, err error)

+ func (c *Client) ListNodes() (rec []NodeInfo, err error)

+ func (c *Client) ListPermissions() (rec []PermissionInfo, err error)

+ func (c *Client) ListPermissionsOf(username string) (rec []PermissionInfo, err error)

+ func (c *Client) ListPolicies() (rec []Policy, err error)

+ func (c *Client) ListPoliciesIn(vhost string) (rec []Policy, err error)

+ func (c *Client) ListQueueBindings(vhost, queue string) (rec []BindingInfo, err error)

+ func (c *Client) ListQueues() (rec []QueueInfo, err error)

+ func (c *Client) ListQueuesIn(vhost string) (rec []QueueInfo, err error)

+ func (c *Client) ListUsers() (rec []UserInfo, err error)

+ func (c *Client) ListVhosts() (rec []VhostInfo, err error)

+ func (c *Client) Overview() (rec *Overview, err error)

+ func (c *Client) ProtocolPorts() (res map[string]Port, err error)

+ func (c *Client) PutFederationUpstream(vhost string, upstreamName string, fDef FederationDefinition) (res *http.Response, err error)

+ func (c *Client) PutPolicy(vhost string, name string, policy Policy) (res *http.Response, err error)

+ func (c *Client) PutUser(username string, info UserSettings) (res *http.Response, err error)

+ func (c *Client) PutVhost(vhostname string, settings VhostSettings) (res *http.Response, err error)

+ func (c *Client) SetTransport(transport *http.Transport)

+ func (c *Client) UpdatePermissionsIn(vhost, username string, permissions Permissions) (res *http.Response, err error)

+ func (c *Client) Whoami() (rec *WhoamiInfo, err error)

+ type ConnectionInfo struct

+ Channels int

+ ClientProperties Properties

+ FrameMax int

+ Host string

+ LastBlockedAge string

+ LastBlockedBy string

+ Name string

+ Node string

+ PeerCertIssuer string

+ PeerCertSubject string

+ PeerCertValidity string

+ PeerHost string

+ PeerPort Port

+ Port Port

+ Protocol string

+ RecvCount uint64

+ RecvOct uint64

+ RecvOctDetails RateDetails

+ SSLCipher string

+ SSLHash string

+ SSLKeyExchange string

+ SSLProtocol string

+ SendCount uint64

+ SendOct uint64

+ SendOctDetails RateDetails

+ SendPending uint64

+ State string

+ Timeout int

+ Type string

+ User string

+ UsesTLS bool

+ Vhost string

+ type DetailedExchangeInfo struct

+ Arguments map[string]interface{}

+ AutoDelete bool

+ Durable bool

+ Incoming []ExchangeIngressDetails

+ Internal bool

+ Name string

+ Outgoing []ExchangeEgressDetails

+ Type string

+ Vhost string

+ type DetailedQueueInfo QueueInfo

+ type ErlangApp NameDescriptionVersion

+ type ExchangeEgressDetails struct

+ Queue NameAndVhost

+ Stats MessageStats

+ type ExchangeInfo struct

+ Arguments map[string]interface{}

+ AutoDelete bool

+ Durable bool

+ Internal bool

+ MessageStats IngressEgressStats

+ Name string

+ Type string

+ Vhost string

+ type ExchangeIngressDetails struct

+ ChannelDetails PublishingChannel

+ Stats MessageStats

+ type ExchangeSettings struct

+ Arguments map[string]interface{}

+ AutoDelete bool

+ Durable bool

+ Type string

+ type ExchangeType NameDescriptionEnabled

+ type FederationDefinition struct

+ AckMode string

+ Expires int

+ MaxHops int

+ MessageTTL int32

+ PrefetchCount int

+ ReconnectDelay int

+ TrustUserId bool

+ Uri string

+ type FederationUpstream struct

+ Definition FederationDefinition

+ type IngressEgressStats struct

+ PublishIn int

+ PublishInDetails RateDetails

+ PublishOut int

+ PublishOutDetails RateDetails

+ type Listener struct

+ IpAddress string

+ Node string

+ Port Port

+ Protocol string

+ type MessageStats struct

+ Publish int

+ PublishDetails RateDetails

+ type NameAndVhost struct

+ Name string

+ Vhost string

+ type NameDescriptionEnabled struct

+ Description string

+ Enabled bool

+ Name string

+ type NameDescriptionVersion struct

+ Description string

+ Name string

+ Version string

+ type NodeInfo struct

+ AuthMechanisms []AuthMechanism

+ Contexts []BrokerContext

+ DiskFree int

+ DiskFreeAlarm bool

+ DiskFreeLimit int

+ ErlangApps []ErlangApp

+ ExchangeTypes []ExchangeType

+ FdTotal int

+ FdUsed int

+ IsRunning bool

+ MemAlarm bool

+ MemLimit int

+ MemUsed int

+ Name string

+ NodeType string

+ OsPid OsPid

+ Processors uint32

+ RunQueueLength uint32

+ SocketsTotal int

+ SocketsUsed int

+ Uptime uint64

+ type NodeNames []string

+ type ObjectTotals struct

+ Channels int

+ Connections int

+ Consumers int

+ Exchanges int

+ Queues int

+ type OsPid string

+ type Overview struct

+ Contexts []BrokerContext

+ ErlangVersion string

+ ExchangeTypes []ExchangeType

+ FullErlangVersion string

+ Listeners []Listener

+ ManagementVersion string

+ MessageStats MessageStats

+ Node string

+ ObjectTotals ObjectTotals

+ QueueTotals QueueTotals

+ RabbitMQVersion string

+ StatisticsDBNode string

+ StatisticsLevel string

+ type OwnerPidDetails struct

+ Name string

+ PeerHost string

+ PeerPort Port

+ type PermissionInfo struct

+ Configure string

+ Read string

+ User string

+ Vhost string

+ Write string

+ type Permissions struct

+ Configure string

+ Read string

+ Write string

+ type Policy struct

+ ApplyTo string

+ Definition PolicyDefinition

+ Name string

+ Pattern string

+ Priority int

+ Vhost string

+ type PolicyDefinition map[string]interface

+ type Port int

+ func (p *Port) UnmarshalJSON(b []byte) error

+ type Properties map[string]interface

+ type PublishingChannel struct

+ ConnectionName string

+ Name string

+ Number int

+ PeerHost string

+ PeerPort Port

+ type QueueInfo struct

+ Arguments map[string]interface{}

+ AutoDelete bool

+ BackingQueueStatus BackingQueueStatus

+ Consumers int

+ Durable bool

+ ExclusiveConsumerTag string

+ Memory int64

+ MessageStats MessageStats

+ Messages int

+ MessagesDetails RateDetails

+ MessagesReady int

+ MessagesReadyDetails RateDetails

+ MessagesUnacknowledged int

+ MessagesUnacknowledgedDetails RateDetails

+ Name string

+ Node string

+ OwnerPidDetails OwnerPidDetails

+ Policy string

+ Status string

+ Vhost string

+ type QueueSettings struct

+ Arguments map[string]interface{}

+ AutoDelete bool

+ Durable bool

+ type QueueTotals struct

+ Messages int

+ MessagesDetails RateDetails

+ MessagesReady int

+ MessagesReadyDetails RateDetails

+ MessagesUnacknowledged int

+ MessagesUnacknowledgedDetails RateDetails

+ type RateDetails struct

+ Rate float32

+ type UserInfo struct

+ Name string

+ PasswordHash string

+ Tags string

+ type UserSettings struct

+ Name string

+ Password string

+ Tags string

+ type VhostInfo struct

+ Messages int

+ MessagesDetails RateDetails

+ MessagesReady int

+ MessagesReadyDetails RateDetails

+ MessagesUnacknowledged int

+ MessagesUnacknowledgedDetails RateDetails

+ Name string

+ RecvCount uint64

+ RecvOct uint64

+ RecvOctDetails RateDetails

+ SendCount uint64

+ SendOct uint64

+ SendOctDetails RateDetails

+ SendPending uint64

+ Tracing bool

+ type VhostSettings struct

+ Tracing bool

+ type WhoamiInfo struct

+ AuthBackend string

+ Name string

+ Tags string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL