messagebus

package
v0.0.0-...-8e45eed Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 12, 2024 License: Apache-2.0 Imports: 10 Imported by: 7

Documentation

Index

Constants

View Source
const LoadBalancingAlgorithm string = "lb_algo"

Variables

This section is empty.

Functions

This section is empty.

Types

type Message

type Message struct {
	URIs                []string          `json:"uris"`
	Host                string            `json:"host"`
	Protocol            string            `json:"protocol,omitempty"`
	Port                *int              `json:"port,omitempty"`
	TLSPort             *int              `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, host string, route config.Route, privateInstanceId string) error
	Close()
}

func NewMessageBus

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

Directories

Path Synopsis
Code generated by counterfeiter.
Code generated by counterfeiter.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL