Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BindingDef ¶
type BindingDef struct {
Source string `json:"source"`
Vhost string `json:"vhost"`
Destination string `json:"destination"`
DestinationType string `json:"destination_type"`
RoutingKey string `json:"routing_key"`
PropertiesKey string `json:"properties_key,omitempty"`
Arguments map[string]interface{} `json:"arguments,omitempty"`
}
Json definition of a binding for communicating with rabbit admin
func BindingDefFromService ¶
func BindingDefFromService(s *Service) *BindingDef
func ExchangeBindingDefFromService ¶
func ExchangeBindingDefFromService(s *Service, azName string) *BindingDef
func (*BindingDef) Equals ¶
func (this *BindingDef) Equals(other *BindingDef) bool
func (*BindingDef) GetDestTypeCode ¶
func (this *BindingDef) GetDestTypeCode() string
type DestinationTypeL ¶
type DestinationTypeL string
const ( QUEUE DestinationTypeL = "queue" EXCHANGE DestinationTypeL = "exchange" )
type DestinationTypeS ¶
type DestinationTypeS string
const ( QUEUE_S DestinationTypeS = "q" EXCHANGE_S DestinationTypeS = "e" )
type ExchangeBinding ¶
type ExchangeDef ¶
type ExchangeDef struct {
Name string `json:"name"`
Vhost string `json:"vhost"`
Type string `json:"type"`
Durable bool `json:"durable"`
AutoDelete bool `json:"auto_delete"`
Internal bool `json:"internal"`
Arguments map[string]interface{} `json:"arguments"`
Policy string `json:"policy"`
}
Json definition of an exchange for communicating with rabbit admin
type RabbitExchange ¶
type RabbitHost ¶
type RabbitQueue ¶
type Rule ¶
type Rule struct {
Service string
Version string // technically this is a number but string is more flexible and comparison operations work the same
Weight int32
}
A Rule defines how a service should be bound
func (*Rule) GetRuleMap ¶
func (*Rule) IsApplicable ¶
Click to show internal directories.
Click to hide internal directories.