Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var RabbitPass string = "hailo"
View Source
var RabbitPort string = "15672"
View Source
var RabbitUser string = "hailo"
Functions ¶
func DeleteQueueMessages ¶
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 ¶
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 ¶
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 ¶
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 }
Click to show internal directories.
Click to hide internal directories.