Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BasicRabbitConnector ¶
type BasicRabbitConnector struct {
BasicRabbitDialer RabbitDialer
}
func CreateBasicRabbitConnector ¶
func CreateBasicRabbitConnector() *BasicRabbitConnector
func (*BasicRabbitConnector) CreateConnection ¶
func (c *BasicRabbitConnector) CreateConnection(connectionURL string) (*amqp.Connection, error)
type BasicRabbitDialer ¶
type BasicRabbitDialer struct { }
func (*BasicRabbitDialer) Dial ¶
func (s *BasicRabbitDialer) Dial(connectionURL string) (*amqp.Connection, error)
type CertPoolMaker ¶
type FileReader ¶
type IOFileReader ¶
type IOFileReader struct { }
type KeyLoader ¶
type KeyLoader interface {
LoadKeyPair(certFile, keyFile string) (tls.Certificate, error)
}
type RabbitConnector ¶
type RabbitConnector interface {
CreateConnection(connectionURL string) (*amqp.Connection, error)
}
func CreateConnector ¶
func CreateConnector(connectionURL string) RabbitConnector
type RabbitDialer ¶
type RabbitDialer interface {
Dial(connectionURL string) (*amqp.Connection, error)
}
type TlsRabbitConnector ¶
type TlsRabbitConnector struct { TlsConfig *tls.Config FileReader FileReader CertPoolMaker CertPoolMaker KeyLoader KeyLoader TlsDialer TlsRabbitDialer }
func CreateTlsRabbitConnector ¶
func CreateTlsRabbitConnector() *TlsRabbitConnector
func (*TlsRabbitConnector) CreateConnection ¶
func (c *TlsRabbitConnector) CreateConnection(connectionURL string) (*amqp.Connection, error)
type TlsRabbitDialer ¶
type X509CertPoolMaker ¶
type X509CertPoolMaker struct { }
func (*X509CertPoolMaker) NewCertPoolWithAppendedCa ¶
func (x *X509CertPoolMaker) NewCertPoolWithAppendedCa(caCert []byte) *x509.CertPool
type X509KeyPairLoader ¶
type X509KeyPairLoader struct { }
func (*X509KeyPairLoader) LoadKeyPair ¶
func (x *X509KeyPairLoader) LoadKeyPair(certFile string, keyFile string) (tls.Certificate, error)
type X509TlsDialer ¶
type X509TlsDialer struct { }
func (*X509TlsDialer) DialTLS ¶
func (s *X509TlsDialer) DialTLS(connectionURL string, tlsConfig *tls.Config) (*amqp.Connection, error)
Click to show internal directories.
Click to hide internal directories.