Versions in this module Expand all Collapse all v2 v2.6.11 Dec 28, 2020 Changes in this version type Client + func (c *Client) ListDefinitions() (p *ExportedDefinitions, 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{} v2.6.2 Dec 28, 2020 Changes in this version + const FederationUpstreamComponent + 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) DeleteAllRuntimeParameters() (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, name 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, opts ...QueueDeleteOptions) (res *http.Response, err error) + func (c *Client) DeleteRuntimeParameter(component, vhost, name 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) EnableFeatureFlag(featureFlagName 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) GetFederationUpstream(vhost, name string) (up *FederationUpstream, 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) GetRuntimeParameter(component, vhost, name string) (p *RuntimeParameter, 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) ListFeatureFlags() (rec []FeatureFlag, err error) + func (c *Client) ListFederationLinks() (links []map[string]interface{}, err error) + func (c *Client) ListFederationLinksIn(vhost string) (links []map[string]interface{}, err error) + func (c *Client) ListFederationUpstreams() (ups []FederationUpstream, err error) + func (c *Client) ListFederationUpstreamsIn(vhost string) (ups []FederationUpstream, 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) ListRuntimeDefinitions() (p *RuntimeDefinitions, 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) 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, name string, def FederationDefinition) (res *http.Response, err error) + func (c *Client) PutPolicy(vhost string, name string, policy Policy) (res *http.Response, err error) + func (c *Client) PutRuntimeParameter(component, vhost, name string, value interface{}) (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 DeleteAfter string + func (d *DeleteAfter) UnmarshalJSON(b []byte) error + func (d DeleteAfter) MarshalJSON() ([]byte, error) + 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 FeatureFlag struct + Desc string + DocURL string + Name string + ProvidedBy string + Stability Stability + State State + 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 + Component string + Definition FederationDefinition + Name string + Vhost string + 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 QueueDeleteOptions struct + IfEmpty bool + IfUnused bool + 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 RuntimeDefinitions struct + Bindings []BindingInfo + Exchanges []ExchangeInfo + GlobalParameters interface{} + Parameters []RuntimeParameter + Permissions []Permissions + Policies []PolicyDefinition + ProductName string + ProductVersion string + Queues []QueueInfo + RabbitMQVersion string + RabbitVersion string + TopicPermissions []TopicPermissionInfo + Users []UserInfo + Vhosts []VhostInfo + type RuntimeParameter struct + Component string + Name string + Value interface{} + Vhost string + type RuntimeParameterValue map[string]interface + type ShovelDefinition struct + AckMode string + AddForwardHeaders bool + DeleteAfter DeleteAfter + DestinationAddForwardHeaders bool + DestinationAddTimestampHeader bool + DestinationAddress string + DestinationApplicationProperties string + DestinationExchange string + DestinationExchangeKey string + DestinationProperties string + DestinationProtocol string + DestinationPublishProperties string + DestinationQueue string + DestinationURI []string + PrefetchCount int + ReconnectDelay int + SourceAddress string + SourceDeleteAfter string + SourceExchange string + SourceExchangeKey string + SourcePrefetchCount int + SourceProtocol string + SourceQueue string + SourceURI []string + type ShovelDefinitionDTO struct + Definition ShovelDefinition + type ShovelInfo struct + Component string + Definition ShovelDefinition + Name string + Vhost string + type Stability string + const StabilityExperimental + const StabilityStable + type State string + const StateDisabled + const StateEnabled + const StateUnsupported + 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 UserTags + type UserSettings struct + HashingAlgorithm HashingAlgorithm + Name string + Password string + PasswordHash string + Tags UserTags + type UserTags []string + func (d *UserTags) UnmarshalJSON(b []byte) error + func (d UserTags) MarshalJSON() ([]byte, error) + type VhostInfo struct + ClusterState map[string]string + 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 UserTags Other modules containing this package github.com/pathcl/rabbit-hole github.com/pathcl/rabbit-hole/v3
Go to main page