Versions in this module Expand all Collapse all v1 v1.5.0 Feb 10, 2019 Changes in this version + func Base64EncodedSaltedPasswordHashSHA256(password string) string + func Base64EncodedSaltedPasswordHashSHA512(password string) string + func GenerateSalt(n int) string + func PathEscape(s string) string + func SaltedPasswordHashSHA256(password string) (string, string) + func SaltedPasswordHashSHA512(password string) (string, string) + 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 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) 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) 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) 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) 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) 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.Transport) + func (c *Client) UpdatePermissionsIn(vhost, username string, permissions Permissions) (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 + 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 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 + Get int64 + GetDetails RateDetails + GetNoAck int64 + GetNoAckDetails RateDetails + Publish int64 + PublishDetails RateDetails + Redeliver int64 + RedeliverDetails 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 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