rabbithole

package module

Go to main page

Versions in this module

v2

v2.16.0

Dec 13, 2023

Changes in this version

type ChannelDetails

+ func (c *ChannelDetails) UnmarshalJSON(data []byte) error

type Client

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

+ func (c *Client) ListConnectionsOfUser(username string) (rec []UserConnectionInfo, err error)

+ func (c *Client) UploadVhostDefinitions(p *ExportedDefinitions, vhost string) (res *http.Response, err error)

+ type UserConnectionInfo struct

+ Name string

+ Node string

+ User string

+ Vhost string

v2.15.0

May 18, 2023

Changes in this version

type ShovelDefinition

+ DestinationMessageAnnotations map[string]interface{}

+ DestinationQueueArgs map[string]interface{}

+ SourceConsumerArgs map[string]interface{}

+ SourceQueueArgs map[string]interface{}

v2.14.0

May 4, 2023

Changes in this version

type VhostInfo

+ DefaultQueueType string

type VhostSettings

+ DefaultQueueType string

v2.13.0

Feb 23, 2023

Changes in this version

+ type FederationLinkMap = []map[string]interface

v2.12.0

Dec 12, 2021

Changes in this version

type Client

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

+ func (c *Client) GetAllUserLimits() (rec []UserLimitsInfo, err error)

+ func (c *Client) GetAllVhostLimits() (rec []VhostLimitsInfo, err error)

+ func (c *Client) GetUserLimits(username string) (rec []UserLimitsInfo, err error)

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

+ func (c *Client) ListVhostConnections(vhostname string) (rec []ConnectionInfo, err error)

+ func (c *Client) PagedListQueuesWithParametersIn(vhost string, params url.Values) (rec PagedQueueInfo, err error)

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

+ func (c *Client) UploadDefinitions(p *ExportedDefinitions) (res *http.Response, err error)

+ type UserLimits []string

+ type UserLimitsInfo struct

+ User string

+ Value UserLimitsValues

+ type UserLimitsValues map[string]int

v2.11.0

Sep 16, 2021

Changes in this version

+ type AutoDelete bool

+ func (d *AutoDelete) UnmarshalJSON(b []byte) error

+ type ChannelDetails struct

+ ConnectionName string

+ Name string

+ Node string

+ Number uint

+ PeerHost string

+ PeerPort uint

+ User string

type Client

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

+ func (c *Client) GetVhostLimits(vhostname string) (rec []VhostLimitsInfo, err error)

+ func (c *Client) ListVhostDefinitions(vhost string) (p *ExportedDefinitions, err error)

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

+ type ClusterLink struct

+ Name string

+ PeerAddr string

+ PeerPort uint

+ RecvBytes uint64

+ SendBytes uint64

+ SockAddr string

+ SockPort uint

+ Stats ClusterLinkStats

+ type ClusterLinkStats struct

+ RecvBytes uint64

+ RecvBytesDetails RateDetails

+ SendBytes uint64

+ SendBytesDetails RateDetails

+ type ConsumerDetail struct

+ AckRequired bool

+ Active bool

+ ActiveStatus string

+ Arguments map[string]interface{}

+ ChannelDetails ChannelDetails

+ ConsumerTag string

+ Exclusive bool

+ PrefetchCount uint

+ Queue QueueDetail

+ type GarbageCollectionDetails struct

+ FullSweepAfter int

+ MaxHeapSize int

+ MinBinVheapSize int

+ MinHeapSize int

+ MinorGCs int

+ type MetricsGCQueueLength struct

+ ChannelClosed int

+ ChannelConsumerDeleted int

+ ConnectionClosed int

+ ConsumerDeleted int

+ ExchangeDeleted int

+ NodeNodeDeleted int

+ QueueDeleted int

+ VhostDeleted int

type NodeInfo

+ ChannelClosed uint64

+ ChannelClosedDetails RateDetails

+ ChannelCreated uint64

+ ChannelCreatedDetails RateDetails

+ ClusterLinks []ClusterLink

+ ConnectionClosed uint64

+ ConnectionClosedDetails RateDetails

+ ConnectionCreated uint64

+ ConnectionCreatedDetails RateDetails

+ ContextSwitches uint64

+ ContextSwitchesDetails RateDetails

+ DiskFreeDetails RateDetails

+ FdUsedDetails RateDetails

+ GCBytesReclaimed uint64

+ GCBytesReclaimedDetails RateDetails

+ GCNum uint64

+ GCNumDetails RateDetails

+ IOFileHandleOpenAttemptCount uint64

+ IOFileHandleOpenAttemptCountDetails RateDetails

+ IOReadAvgTime float64

+ IOReadAvgTimeDetails RateDetails

+ IOReadBytes uint64

+ IOReadBytesDetails RateDetails

+ IOReadCount uint64

+ IOReadCountDetails RateDetails

+ IOReopenCount uint64

+ IOReopenCountDetails RateDetails

+ IOSeekAvgTime float64

+ IOSeekAvgTimeDetails RateDetails

+ IOSeekCount uint64

+ IOSeekCountDetails RateDetails

+ IOSyncAvgTime float64

+ IOSyncAvgTimeDetails RateDetails

+ IOSyncCount uint64

+ IOSyncCountDetails RateDetails

+ IOWriteAvgTime float64

+ IOWriteAvgTimeDetails RateDetails

+ IOWriteBytes uint64

+ IOWriteBytesDetails RateDetails

+ IOWriteCount uint64

+ IOWriteCountDetails RateDetails

+ MemUsedDetails RateDetails

+ MetricsGCQueueLength MetricsGCQueueLength

+ MnesiaDiskTxCount uint64

+ MnesiaDiskTxCountDetails RateDetails

+ MnesiaRAMTxCount uint64

+ MnesiaRAMTxCountDetails RateDetails

+ MsgStoreReadCount uint64

+ MsgStoreReadCountDetails RateDetails

+ MsgStoreWriteCount uint64

+ MsgStoreWriteCountDetails RateDetails

+ ProcUsedDetails RateDetails

+ QueueCreated uint64

+ QueueCreatedDetails RateDetails

+ QueueDeclared uint64

+ QueueDeclaredDetails RateDetails

+ QueueDeleted uint64

+ QueueDeletedDetails RateDetails

+ QueueIndexJournalWriteCount uint64

+ QueueIndexJournalWriteCountDetails RateDetails

+ QueueIndexReadCount uint64

+ QueueIndexReadCountDetails RateDetails

+ QueueIndexWriteCount uint64

+ QueueIndexWriteCountDetails RateDetails

+ SocketsUsedDetails RateDetails

+ type QueueDetail struct

+ Name string

+ Vhost string

type QueueInfo

+ ConsumerDetails *[]ConsumerDetail

+ Exclusive bool

+ GarbageCollection *GarbageCollectionDetails

+ Leader string

+ Members []string

+ MessagesBytesReady int64

+ MessagesBytesUnacknowledged int64

+ Online []string

+ Type string

+ type VhostLimits []string

+ type VhostLimitsInfo struct

+ Value VhostLimitsValues

+ Vhost string

+ type VhostLimitsValues map[string]int

v2.10.0

Jun 3, 2021

v2.9.0

Jun 2, 2021

Changes in this version

type Client

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

+ func (c *Client) GetOperatorPolicy(vhost, name string) (rec *OperatorPolicy, err error)

+ func (c *Client) ListOperatorPolicies() (rec []OperatorPolicy, err error)

+ func (c *Client) ListOperatorPoliciesIn(vhost string) (rec []OperatorPolicy, err error)

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

+ type OperatorPolicy struct

+ ApplyTo string

+ Definition PolicyDefinition

+ Name string

+ Pattern string

+ Priority int

+ Vhost string

+ type URISet []string

+ func (s *URISet) UnmarshalJSON(b []byte) error

type VhostInfo

+ Description string

+ Tags VhostTags

type VhostSettings

+ Description string

+ Tags VhostTags

+ type VhostTags []string

+ func (d *VhostTags) UnmarshalJSON(b []byte) error

+ func (d VhostTags) MarshalJSON() ([]byte, error)

v2.8.0

Apr 14, 2021

Changes in this version

type Client

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

+ func (c *Client) GetGlobalParameter(name string) (p *GlobalRuntimeParameter, err error)

+ func (c *Client) ListGlobalParameters() (params []GlobalRuntimeParameter, err error)

+ func (c *Client) PutGlobalParameter(name string, value interface{}) (res *http.Response, err error)

v2.7.0

Mar 30, 2021

Changes in this version

+ type AlarmInEffect struct

+ Node string

+ Resource string

type Client

+ func (c *Client) HealthCheckAlarms() (rec ResourceAlarmCheckStatus, err error)

+ func (c *Client) HealthCheckCertificateExpiration(within uint, unit TimeUnit) (rec HealthCheckStatus, err error)

+ func (c *Client) HealthCheckLocalAlarms() (rec ResourceAlarmCheckStatus, err error)

+ func (c *Client) HealthCheckNodeIsMirrorSyncCritical() (rec HealthCheckStatus, err error)

+ func (c *Client) HealthCheckNodeIsQuorumCritical() (rec HealthCheckStatus, err error)

+ func (c *Client) HealthCheckPortListener(port uint) (rec PortListenerCheckStatus, err error)

+ func (c *Client) HealthCheckProtocolListener(protocol Protocol) (rec ProtocolListenerCheckStatus, err error)

+ func (c *Client) HealthCheckVirtualHosts() (rec HealthCheckStatus, err error)

+ func (c *Client) ListDefinitions() (p *ExportedDefinitions, err error)

+ func (c *Client) ListShovelStatus(vhost string) (rec []ShovelStatus, err error)

+ type ExportedDefinitions struct

+ Bindings []BindingInfo

+ Exchanges []ExchangeInfo

+ GlobalParameters []GlobalRuntimeParameter

+ Parameters []RuntimeParameter

+ Permissions []Permissions

+ Policies []PolicyDefinition

+ ProductName string

+ ProductVersion string

+ Queues []QueueInfo

+ RabbitMQVersion string

+ RabbitVersion string

+ TopicPermissions []TopicPermissionInfo

+ Users []UserInfo

+ Vhosts []VhostInfo

+ type GlobalRuntimeParameter struct

+ Name string

+ Value interface{}

+ type HealthCheck interface

+ Ok func() bool

+ type HealthCheckStatus struct

+ Reason string

+ Status string

+ func (h *HealthCheckStatus) Ok() bool

+ type PortListenerCheckStatus struct

+ Missing uint

+ Port uint

+ Ports []uint

+ Reason string

+ Status string

+ func (h *PortListenerCheckStatus) Ok() bool

+ type Protocol string

+ const AMQP

+ const AMQP091

+ const AMQP10

+ const AMQPS

+ const Clustering

+ const HTTP

+ const HTTPS

+ const MQTT

+ const Prometheus

+ const STOMP

+ const WebMQTT

+ const WebSTOMP

+ type ProtocolListenerCheckStatus struct

+ Missing string

+ Protocols []string

+ Reason string

+ Status string

+ func (h *ProtocolListenerCheckStatus) Ok() bool

+ type QueueDeleteOptions struct

+ IfEmpty bool

+ IfUnused bool

+ type ResourceAlarmCheckStatus struct

+ Alarms []AlarmInEffect

+ Reason string

+ Status string

+ func (h *ResourceAlarmCheckStatus) Ok() bool

+ type ShovelStatus struct

+ Name string

+ State string

+ Timestamp string

+ Type string

+ Vhost string

+ type ShovelURISet []string

+ func (s *ShovelURISet) UnmarshalJSON(b []byte) error

+ type TimeUnit string

+ const DAYS

+ const MONTHS

+ const SECONDS

+ const YEARS

+ type UserTags []string

+ func (d *UserTags) UnmarshalJSON(b []byte) error

+ func (d UserTags) MarshalJSON() ([]byte, error)

v2.6.0

Nov 25, 2020

Changes in this version

type Client

+ func (c *Client) DeleteAllRuntimeParameters() (err error)

+ func (c *Client) EnableFeatureFlag(featureFlagName string) (res *http.Response, err error)

+ func (c *Client) ListFeatureFlags() (rec []FeatureFlag, err error)

+ type FeatureFlag struct

+ Desc string

+ DocURL string

+ Name string

+ ProvidedBy string

+ Stability Stability

+ State State

+ type Stability string

+ const StabilityExperimental

+ const StabilityStable

+ type State string

+ const StateDisabled

+ const StateEnabled

+ const StateUnsupported

v2.5.0

Sep 25, 2020

Changes in this version

+ type DeleteAfter string

+ func (d *DeleteAfter) UnmarshalJSON(b []byte) error

+ func (d DeleteAfter) MarshalJSON() ([]byte, error)

type VhostInfo

+ ClusterState map[string]string

v2.4.0

Aug 4, 2020

v2.3.0

Jul 11, 2020

Changes in this version

type Client

+ func (c *Client) ListFederationLinks() (links []map[string]interface{}, err error)

+ func (c *Client) ListFederationLinksIn(vhost string) (links []map[string]interface{}, err error)

type ShovelDefinition

+ DestinationAddForwardHeaders bool

+ DestinationAddTimestampHeader bool

+ DestinationAddress string

+ DestinationApplicationProperties string

+ DestinationProperties string

+ DestinationProtocol string

+ DestinationPublishProperties string

+ SourceAddress string

+ SourceDeleteAfter string

+ SourcePrefetchCount int

+ SourceProtocol string

v2.2.0

May 21, 2020

Changes in this version

+ const FederationUpstreamComponent

type Client

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

+ func (c *Client) GetFederationUpstream(vhost, name string) (up *FederationUpstream, err error)

+ func (c *Client) GetRuntimeParameter(component, vhost, name string) (p *RuntimeParameter, err error)

+ func (c *Client) ListFederationUpstreams() (ups []FederationUpstream, err error)

+ func (c *Client) ListFederationUpstreamsIn(vhost string) (ups []FederationUpstream, err error)

+ func (c *Client) ListRuntimeParameters() (params []RuntimeParameter, err error)

+ func (c *Client) ListRuntimeParametersFor(component string) (params []RuntimeParameter, err error)

+ func (c *Client) ListRuntimeParametersIn(component, vhost string) (p []RuntimeParameter, err error)

+ func (c *Client) PutRuntimeParameter(component, vhost, name string, value interface{}) (res *http.Response, err error)

type FederationUpstream

+ Component string

+ Name string

+ Vhost string

+ type RuntimeParameter struct

+ Component string

+ Name string

+ Value interface{}

+ Vhost string

+ type RuntimeParameterValue map[string]interface

v2.1.0

Feb 1, 2020

Changes in this version

+ func Base64EncodedSaltedPasswordHashSHA256(password string) string

+ func Base64EncodedSaltedPasswordHashSHA512(password string) string

+ func GenerateSalt(n int) string

+ func SaltedPasswordHashSHA256(password string) (string, string)

+ func SaltedPasswordHashSHA512(password string) (string, string)

+ type AcknowledgementMode bool

+ const AutomaticAcknowledgment

+ const ManualAcknowledgement

+ 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 BindingVertex string

+ const BindingDestination

+ const BindingSource

+ func (v BindingVertex) String() string

+ type BriefChannelDetail struct

+ ConnectionName string

+ Name string

+ Node string

+ Number int

+ PeerHost string

+ PeerPort int

+ User string

+ type BriefConnectionDetails struct

+ Name string

+ PeerHost string

+ PeerPort Port

+ type BriefQueueInfo struct

+ Name string

+ Vhost string

+ 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.RoundTripper) (me *Client, err error)

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

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

+ func (c *Client) ClearTopicPermissionsIn(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) DeclareShovel(vhost, shovel string, info ShovelDefinition) (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) DeleteShovel(vhost, shovel string) (res *http.Response, err error)

+ func (c *Client) DeleteTopicPermissionsIn(vhost, username string, exchange 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) GetClusterName() (rec *ClusterName, 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) GetQueueWithParameters(vhost, queue string, qs url.Values) (rec *DetailedQueueInfo, err error)

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

+ func (c *Client) GetTopicPermissionsIn(vhost, username string) (rec []TopicPermissionInfo, 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) ListConsumers() (rec []ConsumerInfo, err error)

+ func (c *Client) ListConsumersIn(vhost string) (rec []ConsumerInfo, err error)

+ func (c *Client) ListExchangeBindings(vhost, exchange string, sourceOrDestination BindingVertex) (rec []BindingInfo, err error)

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

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

+ func (c *Client) ListExchangeBindingsWithSource(vhost, exchange string) (rec []BindingInfo, 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) ListQueueBindingsBetween(vhost, exchange string, 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) ListQueuesWithParameters(params url.Values) (rec []QueueInfo, err error)

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

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

+ func (c *Client) ListTopicPermissions() (rec []TopicPermissionInfo, err error)

+ func (c *Client) ListTopicPermissionsOf(username string) (rec []TopicPermissionInfo, 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) PagedListQueuesWithParameters(params url.Values) (rec PagedQueueInfo, err error)

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

+ func (c *Client) PurgeQueue(vhost, queue string) (res *http.Response, 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) PutUserWithoutPassword(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) SetClusterName(cn ClusterName) (res *http.Response, err error)

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

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

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

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

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

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

+ type ClusterName struct

+ Name string

+ type ConnectionInfo struct

+ Channels int

+ ClientProperties Properties

+ ConnectedAt uint64

+ 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 ConsumerInfo struct

+ AcknowledgementMode AcknowledgementMode

+ Arguments map[string]interface{}

+ ChannelDetails BriefChannelDetail

+ ConsumerTag string

+ Exclusive bool

+ PrefetchCount int

+ Queue BriefQueueInfo

+ type DetailedExchangeInfo struct

+ Arguments map[string]interface{}

+ AutoDelete bool

+ Durable bool

+ Incoming []ExchangeIngressDetails

+ Internal bool

+ Name string

+ Outgoing []ExchangeEgressDetails

+ PublishStats IngressEgressStats

+ Type string

+ Vhost string

+ type DetailedQueueInfo QueueInfo

+ type ErlangApp NameDescriptionVersion

+ type ErrorResponse struct

+ Message string

+ Reason string

+ StatusCode int

+ func (rme ErrorResponse) Error() string

+ 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

+ Exchange string

+ Expires int

+ MaxHops int

+ MessageTTL int32

+ PrefetchCount int

+ Queue string

+ ReconnectDelay int

+ TrustUserId bool

+ Uri string

+ type FederationUpstream struct

+ Definition FederationDefinition

+ type HashingAlgorithm string

+ const HashingAlgorithmMD5

+ const HashingAlgorithmSHA256

+ const HashingAlgorithmSHA512

+ func (algo HashingAlgorithm) String() string

+ 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

+ Ack int64

+ AckDetails RateDetails

+ Deliver int64

+ DeliverDetails RateDetails

+ DeliverGet int64

+ DeliverGetDetails RateDetails

+ DeliverNoAck int64

+ DeliverNoAckDetails RateDetails

+ DropUnroutable int64

+ DropUnroutableDetails RateDetails

+ Get int64

+ GetDetails RateDetails

+ GetNoAck int64

+ GetNoAckDetails RateDetails

+ Publish int64

+ PublishDetails RateDetails

+ Redeliver int64

+ RedeliverDetails RateDetails

+ ReturnUnroutable int64

+ ReturnUnroutableDetails 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

+ Partitions []string

+ ProcTotal int

+ ProcUsed int

+ 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 PagedQueueInfo struct

+ FilteredCount int

+ ItemCount int

+ Items []QueueInfo

+ Page int

+ PageCount int

+ PageSize int

+ TotalCount int

+ 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

+ ActiveConsumers int64

+ Arguments map[string]interface{}

+ AutoDelete bool

+ BackingQueueStatus BackingQueueStatus

+ ConsumerUtilisation float64

+ Consumers int

+ Durable bool

+ ExclusiveConsumerTag string

+ Memory int64

+ MessageStats MessageStats

+ Messages int

+ MessagesBytes int64

+ MessagesBytesPersistent int64

+ MessagesBytesRAM int64

+ MessagesDetails RateDetails

+ MessagesPersistent int

+ MessagesRAM int

+ 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 string

+ type QueueTotals struct

+ Messages int

+ MessagesDetails RateDetails

+ MessagesReady int

+ MessagesReadyDetails RateDetails

+ MessagesUnacknowledged int

+ MessagesUnacknowledgedDetails RateDetails

+ type RateDetailSample struct

+ Sample int64

+ Timestamp int64

+ type RateDetails struct

+ Rate float32

+ Samples []RateDetailSample

+ 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

+ type TopicPermissionInfo struct

+ Exchange string

+ Read string

+ User string

+ Vhost string

+ Write string

+ type TopicPermissions struct

+ Exchange string

+ Read string

+ Write string

+ type UserInfo struct

+ HashingAlgorithm HashingAlgorithm

+ Name string

+ PasswordHash string

+ Tags string

+ type UserSettings struct

+ HashingAlgorithm HashingAlgorithm

+ Name string

+ Password string

+ PasswordHash 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

Other modules containing this package

github.com/michaelklishin/rabbit-hole

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