brokers

Documentation

Index

• func GetSidecarConnectionVars(broker string) *models.ConnectionVariables
• type AbstractBrokerFactory
  • func (abf *AbstractBrokerFactory) Get(broker string) (models.SidecarFactory, error)
  • func (abf *AbstractBrokerFactory) Subscribe(broker string, factory models.SidecarFactory) error
• type Manager
  • func GetBrokerMemory() Manager
• type SidecarManager

Functions

func GetSidecarConnectionVars

func GetSidecarConnectionVars(broker string) *models.ConnectionVariables

GetSidecarConnectionVars returns port enviroment variable names for each possible broker

Types

type AbstractBrokerFactory

type AbstractBrokerFactory struct {
}

AbstractBrokerFactory singleton and abstract factory implementation for SidecarInterface

func (*AbstractBrokerFactory) Get

func (abf *AbstractBrokerFactory) Get(broker string) (models.SidecarFactory, error)

Get returns a factory for the specifyed broker

func (*AbstractBrokerFactory) Subscribe

func (abf *AbstractBrokerFactory) Subscribe(broker string, factory models.SidecarFactory) error

Subscribe includes a broker specific factory on the Abstract broker factory

type Manager

type Manager interface {
	Get() (*apimodels.BrokersDI, error)
	Create(config brokers.BrokerConfiguration) error
	SetDefault(broker string) error
	Factory() SidecarManager
	Configs(broker string) (brokers.BrokerConfiguration, error)
}

Manager is the interface that allows for interaction with the systems multiple brokers and its configurations.

func GetBrokerMemory

func GetBrokerMemory() Manager

GetBrokerMemory allows for connection with BrokersManager sigleton

type SidecarManager

type SidecarManager interface {
	Get(broker string) (models.SidecarFactory, error)
	Subscribe(broker string, factory models.SidecarFactory) error
}

SidecarManager is the interface that allows the build and deployment of available brokers