data

type Binding struct {
	Source      []*BindingKey
	Destination []*BindingKey
}

type BindingData struct {
	Vhost           string
	Source          string
	Destination     string
	DestinationType string `json:"destination_type"`
}

type BindingKey struct {
	Vhost, EntityName, EntityType string
}

type BindingStats map[BindingKey]*Binding

type ConnectionData struct {
	Vhost string
	State string
}

type EntityData interface {
	GetEntity(integration *integration.Integration, entityName string) (*integration.Entity, []metric.Attribute, error)
	EntityVhost() string
	EntityName() string
	EntityType() string
}

type ExchangeData struct {
	Name         string
	Vhost        string
	MessageStats struct {
		PublishIn        *int64 `json:"publish_in" metric_name:"exchange.messagesPublishedPerChannel" source_type:"gauge"`
		PublishOut       *int64 `json:"publish_out" metric_name:"exchange.messagesPublishedQueue" source_type:"gauge"`
		PublishInDetails struct {
			Rate *float64 `metric_name:"exchange.messagesPublishedPerChannelPerSecond" source_type:"gauge"`
		} `json:"publish_in_details"`
		PublishOutDetails struct {
			Rate *float64 `metric_name:"exchange.messagesPublishedQueuePerSecond" source_type:"gauge"`
		} `json:"publish_out_details"`
	} `json:"message_stats"`
	Type       string
	Durable    bool
	AutoDelete bool `json:"auto_delete"`
	Arguments  map[string]interface{}
}

type NodeData struct {
	Name                 string
	ConfigFiles          []string `json:"config_files"`
	DiskAlarm            *bool    `json:"disk_free_alarm" metric_name:"node.diskAlarm" source_type:"gauge"`
	DiskFreeSpace        *int64   `json:"disk_free" metric_name:"node.diskSpaceFreeInBytes" source_type:"gauge"`
	FileDescriptorsUsed  *int64   `json:"fd_used" metric_name:"node.fileDescriptorsTotalUsed" source_type:"gauge"`
	FileDescriptorsTotal *int64   `json:"fd_total" metric_name:"node.fileDescriptorsTotal" source_type:"gauge"`
	ProcessesTotal       *int64   `json:"proc_total" metric_name:"node.processesTotal" source_type:"gauge"`
	ProcessesUsed        *int64   `json:"proc_used" metric_name:"node.processesUsed" source_type:"gauge"`
	MemoryAlarm          *bool    `json:"mem_alarm" metric_name:"node.hostMemoryAlarm" source_type:"gauge"`
	MemoryUsed           *int64   `json:"mem_used" metric_name:"node.totalMemoryUsedInBytes" source_type:"gauge"`
	Partitions           int      `json:"-" metric_name:"node.partitionsSeen" source_type:"gauge"`
	Running              *bool    `metric_name:"node.running" source_type:"gauge"`
	RunQueue             *int64   `json:"run_queue" metric_name:"node.averageErlangProcessesWaiting" source_type:"gauge"`
	SocketsTotal         *int64   `json:"sockets_total" metric_name:"node.fileDescriptorsTotalSockets" source_type:"gauge"`
	SocketsUsed          *int64   `json:"sockets_used" metric_name:"node.fileDescriptorsUsedSockets" source_type:"gauge"`
}

type NodeTest struct {
	Node *NodeData
	Test *TestData
}

type OverviewData struct {
	ClusterName       string `json:"cluster_name"`
	RabbitMQVersion   string `json:"rabbitmq_version"`
	ManagementVersion string `json:"management_version"`
}

type QueueData struct {
	Name                string
	Vhost               string
	Exclusive           bool
	Durable             bool
	Arguments           map[string]interface{}
	AutoDelete          bool     `json:"auto_delete"`
	Consumers           *int64   `metric_name:"queue.consumers" source_type:"gauge"`
	ConsumerUtilisation *float64 `json:"consumer_utilisation" metric_name:"queue.consumerMessageUtilizationPerSecond" source_type:"gauge"`
	ActiveConsumers     *int64   `json:"active_consumers" metric_name:"queue.countActiveConsumersReceiveMessages" source_type:"gauge"`
	Memory              *int64   `metric_name:"queue.erlangBytesConsumedInBytes" source_type:"gauge"`
	Messages            *int64   `metric_name:"queue.totalMessages" source_type:"gauge"`
	MessagesDetails     struct {
		Rate *float64 `metric_name:"queue.totalMessagesPerSecond" source_type:"gauge"`
	} `json:"messages_details"`
	MessagesReady       *int64 `json:"messages_ready" metric_name:"queue.messagesReadyDeliveryClients" source_type:"gauge"`
	MessagesReadyDetail struct {
		Rate *float64 `metric_name:"queue.messagesReadyDeliveryClientsPerSecond" source_type:"gauge"`
	} `json:"messages_ready_details"`
	MessagesUnacknowledged       *int64 `json:"messages_unacknowledged" metric_name:"queue.messagesReadyUnacknowledged" source_type:"gauge"`
	MessagesUnacknowledgedDetail struct {
		Rate *float64 `metric_name:"queue.messagesReadyUnacknowledgedPerSecond" source_type:"gauge"`
	} `json:"messages_unacknowledged_details"`
	MessageStats struct {
		Ack        *int64 `metric_name:"queue.messagesAcknowledged" source_type:"gauge"`
		AckDetails struct {
			Rate *float64 `metric_name:"queue.messagesAcknowledgedPerSecond" source_type:"gauge"`
		} `json:"ack_details"`
		Deliver        *int64 `json:"deliver" metric_name:"queue.messagesDeliveredAckMode" source_type:"gauge"`
		DeliverDetails struct {
			Rate *float64 `metric_name:"queue.messagesDeliveredAckModePerSecond" source_type:"gauge"`
		} `json:"deliver_details"`
		DeliverGet        *int64 `json:"deliver_get" metric_name:"queue.sumMessagesDelivered" source_type:"gauge"`
		DeliverGetDetails struct {
			Rate *float64 `metric_name:"queue.sumMessagesDeliveredPerSecond" source_type:"gauge"`
		} `json:"deliver_get_details"`
		Publish        *int64 `metric_name:"queue.messagesPublished" source_type:"gauge"`
		PublishDetails struct {
			Rate *float64 `metric_name:"queue.messagesPublishedPerSecond" source_type:"gauge"`
		} `json:"publish_details"`
		Redeliver        *int64 `metric_name:"queue.messagesRedeliverGet" source_type:"gauge"`
		RedeliverDetails struct {
			Rate *float64 `metric_name:"queue.messagesRedeliverGetPerSecond" source_type:"gauge"`
		} `json:"redeliver_details"`
	} `json:"message_stats"`
}

type TestData struct {
	Status string
	Reason string
}

type VhostData struct {
	Name string
}

type VhostTest struct {
	Vhost *VhostData
	Test  *TestData
}