rabbit

Documentation

Index

• Variables
• func DeleteQueueMessages(rabbitHost, queue string) error
• type Binding
  • func GetBindings(rabbitHost string) ([]*Binding, error)
• type Bindings
• type Exchange
  • func GetExchanges(rabbitHost string) ([]*Exchange, error)
• type Exchanges
• type Message
  • func GetExampleMessages(rabbitHost, queue string) ([]*Message, error)
• type Messages
• type Queue
  • func GetQueue(rabbitHost, queue string) (*Queue, error)
  • func GetQueues(rabbitHost string) ([]*Queue, error)
• type Queues

Variables

var RabbitPass string = "hailo"

var RabbitPort string = "15672"

var RabbitUser string = "hailo"

Functions

func DeleteQueueMessages

func DeleteQueueMessages(rabbitHost, queue string) error

Types

type Binding

type Binding struct {
	Source           string
	Vhost            string
	Destination      string
	Destination_type string
	Routing_key      string
	Arguments        map[string]interface{}
	Properties_key   string
}

func GetBindings

func GetBindings(rabbitHost string) ([]*Binding, error)

type Bindings

type Bindings []*Binding

type Exchange

type Exchange struct {
	Message_stats struct {
		Publish_in         interface{}
		Publish_in_details struct {
			Rate interface{}
		}
		Publish_out         interface{}
		Publish_out_details struct {
			Rate interface{}
		}
	}
	Name        string
	Vhost       string
	Type        string
	Durable     bool
	Auto_delete bool
	Internal    bool
	Arguments   map[string]interface{}
	Policy      string
}

type Response struct {
	Data struct {
		Children []struct {
			Data Item
		}
	}
}

func GetExchanges

func GetExchanges(rabbitHost string) ([]*Exchange, error)

type Exchanges

type Exchanges []*Exchange

type Message

type Message struct {
	Payload_bytes int
	Redelivered   bool
	Exchange      string
	Routing_key   string
	Message_count int
	Properties    struct {
		Message_id    string
		Reply_to      string
		Delivery_mode int
		Headers       map[string]string
		Content_type  string
	}
	Payload          string
	Payload_encoding string
}

func GetExampleMessages

func GetExampleMessages(rabbitHost, queue string) ([]*Message, error)

type Messages

type Messages []*Message

type Queue

type Queue struct {
	Memory        int
	Message_stats struct {
		Deliver_get         int
		Deliver_get_details struct {
			Rate float64
		}
		Deliver_no_ack         int
		Deliver_no_ack_details struct {
			Rate float64
		}
		Publish         int
		Publish_details struct {
			Rate float64
		}
	}
	Messages         int
	Messages_details struct {
		Rate float64
	}
	Messages_ready         int
	Messages_ready_details struct {
		Rate float64
	}
	Messages_unacknowledged         int
	Messages_unacknowledged_details struct {
		Rate float64
	}
	Idle_since             string
	Policy                 string
	Exclusive_consumer_tag string
	Consumers              int
	Backing_queue_status   struct {
		Q1                   int
		Q2                   int
		Delta                []interface{}
		Q3                   int
		Q4                   int
		Len                  int
		Pending_acks         int
		Target_ram_count     string
		Ram_msg_count        int
		Ram_ack_count        int
		Next_seq_id          int
		Persistent_count     int
		Avg_ingress_rate     float64
		Avg_egress_rate      float64
		Avg_ack_ingress_rate float64
		Avg_ack_egress_rate  float64
	}
	Status      string
	Name        string
	Vhost       string
	Durable     bool
	Auto_delete bool
	Arguments   map[string]interface{}
	Node        string
}

func GetQueue

func GetQueue(rabbitHost, queue string) (*Queue, error)

func GetQueues

func GetQueues(rabbitHost string) ([]*Queue, error)

type Queues

type Queues []*Queue