messagebus

Documentation

Index

• Constants
• type Message
• type MessageBus
  • func NewMessageBus(logger lager.Logger, availabilityZone string) MessageBus

Constants

const LoadBalancingAlgorithm string = "loadbalancing"

Types

type Message

type Message struct {
	URIs                []string          `json:"uris"`
	Host                string            `json:"host"`
	Protocol            string            `json:"protocol,omitempty"`
	Port                *uint16           `json:"port,omitempty"`
	TLSPort             *uint16           `json:"tls_port,omitempty"`
	Tags                map[string]string `json:"tags"`
	RouteServiceUrl     string            `json:"route_service_url,omitempty"`
	PrivateInstanceId   string            `json:"private_instance_id"`
	ServerCertDomainSAN string            `json:"server_cert_domain_san,omitempty"`
	AvailabilityZone    string            `json:"availability_zone,omitempty"`
	Options             map[string]string `json:"options,omitempty"`
}

type MessageBus

type MessageBus interface {
	Connect(servers []config.MessageBusServer, tlsConfig *tls.Config) error
	SendMessage(subject string, route config.Route, privateInstanceId string) error
	Close()
}

func NewMessageBus

func NewMessageBus(logger lager.Logger, availabilityZone string) MessageBus