domain

Documentation

Index

• type BindingDef
  • func BindingDefFromService(s *Service) *BindingDef
  • func ExchangeBindingDefFromService(s *Service, azName string) *BindingDef
  • func (this *BindingDef) Equals(other *BindingDef) bool
  • func (this *BindingDef) GetDestTypeCode() string
• type DestinationTypeL
• type DestinationTypeS
• type ExchangeBinding
• type ExchangeDef
• type RabbitExchange
• type RabbitHost
• type RabbitQueue
• type Rule
  • func (this *Rule) GetRuleMap() map[string]interface{}
  • func (this *Rule) IsApplicable(s *Service) bool
• type Service
  • func ServiceFromInstancesProto(i *instances.Instance) *Service
  • func ServiceFromServiceupProto(i *serviceup.Request) *Service

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 ExchangeBinding struct {
	FromExchange string
	ToExchange   string
}

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 RabbitExchange struct {
	Hostname string // hostname of broker it lives on
	Hostport int
	Name     string // name of exchange
	Xtype    string
	Options  map[string]interface{}
}

type RabbitHost

type RabbitHost struct {
	Host   string
	AzName string
}

type RabbitQueue

type RabbitQueue struct {
	Hostname string
	Hostport int
	Name     string
	Options  map[string]interface{}
}

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 (this *Rule) GetRuleMap() map[string]interface{}

func (*Rule) IsApplicable

func (this *Rule) IsApplicable(s *Service) bool

type Service

type Service struct {
	Service       string
	Version       string
	Instance      string
	AzName        string
	Subscriptions []string
}

func ServiceFromInstancesProto

func ServiceFromInstancesProto(i *instances.Instance) *Service

func ServiceFromServiceupProto

func ServiceFromServiceupProto(i *serviceup.Request) *Service