router

Documentation

Index

• Constants
• func ConfigForQpidDispatch(q QpidDispatch) string
• func NewDeployment(namespace string, qpidDispatch QpidDispatch, opts QpidDispatchDeploymentOpts) (*apps.Deployment, error)
• type Address
• type AutoLink
• type Connector
• type LinkRoute
• type Listener
• type Log
• type QpidDispatch
• type QpidDispatchConfigMap
  • func NewConfigMap(q QpidDispatch, namespace string, labels map[string]string) *QpidDispatchConfigMap
• type QpidDispatchDeploymentOpts
• type RouterRoleType
• type SslProfile
• type TcpConnector
• type TcpListener

Constants

const QpidDispatchImageEnvVar = "QPID_DISPATCH_IMAGE"

Functions

func ConfigForQpidDispatch

func ConfigForQpidDispatch(q QpidDispatch) string

ConfigForQpidDispatch returns a string representation of a serialized QpidDispatch configuration

func NewDeployment

func NewDeployment(namespace string, qpidDispatch QpidDispatch, opts QpidDispatchDeploymentOpts) (*apps.Deployment, error)

Types

type Address

type Address struct {
	Prefix         string `json:"prefix,omitempty"`
	Pattern        string `json:"pattern,omitempty"`
	Distribution   string `json:"distribution,omitempty"`
	Waypoint       bool   `json:"waypoint,omitempty"`
	IngressPhase   *int32 `json:"ingressPhase,omitempty"`
	EgressPhase    *int32 `json:"egressPhase,omitempty"`
	Priority       *int32 `json:"priority,omitempty"`
	EnableFallback bool   `json:"enableFallback,omitempty"`
}

type AutoLink

type AutoLink struct {
	Address         string `json:"address"`
	Direction       string `json:"direction"`
	ContainerId     string `json:"containerId,omitempty"`
	Connection      string `json:"connection,omitempty"`
	ExternalAddress string `json:"externalAddress,omitempty"`
	Phase           *int32 `json:"phase,omitempty"`
	Fallback        bool   `json:"fallback,omitempty"`
}

type Connector

type Connector struct {
	Name           string `json:"name,omitempty"`
	Host           string `json:"host"`
	Port           int32  `json:"port"`
	RouteContainer bool   `json:"routeContainer,omitempty"`
	Cost           int32  `json:"cost,omitempty"`
	VerifyHostname bool   `json:"verifyHostname,omitempty"`
	SslProfile     string `json:"sslProfile,omitempty"`
	LinkCapacity   int32  `json:"linkCapacity,omitempty"`
}

type LinkRoute

type LinkRoute struct {
	Prefix            string `json:"prefix,omitempty"`
	Pattern           string `json:"pattern,omitempty"`
	Direction         string `json:"direction,omitempty"`
	ContainerId       string `json:"containerId,omitempty"`
	Connection        string `json:"connection,omitempty"`
	AddExternalPrefix string `json:"addExternalPrefix,omitempty"`
	DelExternalPrefix string `json:"delExternalPrefix,omitempty"`
}

type Listener

type Listener struct {
	Name             string `json:"name,omitempty"`
	Host             string `json:"host,omitempty"`
	Port             int32  `json:"port"`
	RouteContainer   bool   `json:"routeContainer,omitempty"`
	Http             bool   `json:"http,omitempty"`
	Cost             int32  `json:"cost,omitempty"`
	SslProfile       string `json:"sslProfile,omitempty"`
	SaslMechanisms   string `json:"saslMechanisms,omitempty"`
	AuthenticatePeer bool   `json:"authenticatePeer,omitempty"`
	Expose           bool   `json:"expose,omitempty"`
	LinkCapacity     int32  `json:"linkCapacity,omitempty"`
}

type Log

type Log struct {
	Module           string `json:"module"`
	Enable           string `json:"enable"`
	IncludeTimestamp bool   `json:"includeTimestamp,omitempty"`
	IncludeSource    bool   `json:"includeSource,omitempty"`
	OutputFile       string `json:"outputFile,omitempty"`
}

type QpidDispatch

type QpidDispatch struct {
	Id                    string         `json:"id,omitempty"`
	Role                  RouterRoleType `json:"role,omitempty"`
	Users                 string         `json:"users,omitempty"`
	Listeners             []Listener     `json:"listeners,omitempty"`
	InterRouterListeners  []Listener     `json:"interRouterListeners,omitempty"`
	EdgeListeners         []Listener     `json:"edgeListeners,omitempty"`
	SslProfiles           []SslProfile   `json:"sslProfiles,omitempty"`
	Addresses             []Address      `json:"addresses,omitempty"`
	AutoLinks             []AutoLink     `json:"autoLinks,omitempty"`
	LinkRoutes            []LinkRoute    `json:"linkRoutes,omitempty"`
	Connectors            []Connector    `json:"connectors,omitempty"`
	InterRouterConnectors []Connector    `json:"interRouterConnectors,omitempty"`
	EdgeConnectors        []Connector    `json:"edgeConnectors,omitempty"`
	TcpConnectors         []TcpConnector `json:"tcpConnectors,omitempty"`
	TcpListeners          []TcpListener  `json:"tcpListeners,omitempty"`
	Logs                  []Log          `json:"logs,omitempty"`
}

QdpidDispatch representation

type QpidDispatchConfigMap

type QpidDispatchConfigMap core.ConfigMap

func NewConfigMap

func NewConfigMap(q QpidDispatch, namespace string, labels map[string]string) *QpidDispatchConfigMap

type QpidDispatchDeploymentOpts

type QpidDispatchDeploymentOpts struct {
	k8s.DeploymentOpts
	ConfigMap *QpidDispatchConfigMap
}

type RouterRoleType

type RouterRoleType string

const (
	RouterRoleInterior RouterRoleType = "interior"
	RouterRoleEdge                    = "edge"
)

type SslProfile

type SslProfile struct {
	Name                string `json:"name,omitempty"`
	Credentials         string `json:"credentials,omitempty"`
	CaCert              string `json:"caCert,omitempty"`
	GenerateCredentials bool   `json:"generateCredentials,omitempty"`
	GenerateCaCert      bool   `json:"generateCaCert,omitempty"`
	MutualAuth          bool   `json:"mutualAuth,omitempty"`
	Ciphers             string `json:"ciphers,omitempty"`
	Protocols           string `json:"protocols,omitempty"`
}

type TcpConnector

type TcpConnector struct {
	Host    string `json:"host"`
	Port    string `json:"port"`
	Address string `json:"address"`
	SiteId  string `json:"siteId,omitempty"`
}

type TcpListener

type TcpListener struct {
	Host    string `json:"host"`
	Port    string `json:"port"`
	Address string `json:"address"`
	SiteId  string `json:"siteId,omitempty"`
}