Versions in this module Expand all Collapse all v42 v42.101.5 Jun 13, 2024 v42.5.0 Jun 18, 2024 Changes in this version + const AutoProvision + const AutoReconnect + const CaFile + const CaPEMBlock + const CertFile + const CertPEMBlock + const CleanSession + const ClientId + const ConnectTimeout + const DefaultPubRetryAttempts + const Deliver + const Durable + const ExactlyOnce + const Format + const KeepAlive + const KeyFile + const KeyPEMBlock + const Password + const Qos + const QueueGroup + const Retained + const RetryOnFailedConnect + const SkipCertVerify + const Subject + const Username + var TlsSchemes = []string + func DoRequest(subscribe func(topics []types.TopicChannel, messageErrors chan error) error, ...) (*types.MessageEnvelope, error) + func GenerateTLSForClientClientOptions(brokerURL string, tlsConfigurationOptions TlsConfigurationOptions, ...) (*tls.Config, error) + func Load(config map[string]string, des interface{}) error + type BrokerURLErr struct + func NewBrokerURLErr(description string) BrokerURLErr + func (bue BrokerURLErr) Error() string + type CertificateErr struct + func NewCertificateErr(message string) CertificateErr + func (ce CertificateErr) Error() string + type InvalidTopicErr struct + func NewInvalidTopicErr(topic string, description string) InvalidTopicErr + func (ite InvalidTopicErr) Error() string + type MissingConfigurationErr struct + func NewMissingConfigurationErr(missingConfiguration string, message string) MissingConfigurationErr + func (mce MissingConfigurationErr) Error() string + type NoopClient struct + func (n NoopClient) Connect() error + func (n NoopClient) Disconnect() error + func (n NoopClient) Publish(message types.MessageEnvelope, topic string) error + func (n NoopClient) Request(message types.MessageEnvelope, targetServiceName string, requestTopic string, ...) (*types.MessageEnvelope, error) + func (n NoopClient) Subscribe(topics []types.TopicChannel, messageErrors chan error) error + func (n NoopClient) Unsubscribe(topics ...string) error + type PEMDecoder func(data []byte) (*pem.Block, []byte) + type PublishHostURLErr struct + func NewPublishHostURLErr(message string) PublishHostURLErr + func (p PublishHostURLErr) Error() string + type SubscribeHostURLErr struct + func NewSubscribeHostURLErr(message string) SubscribeHostURLErr + func (p SubscribeHostURLErr) Error() string + type TlsConfigurationOptions struct + CaFile string + CaPEMBlock string + CertFile string + CertPEMBlock string + KeyFile string + KeyPEMBlock string + SkipCertVerify bool + func CreateDefaultTlsConfigurationOptions() TlsConfigurationOptions + type X509CaCertCreator func(caCertPEMBlock []byte) (*x509.Certificate, error) + type X509CaCertLoader func(caCertFile string) ([]byte, error) + type X509KeyLoader func(certFile string, keyFile string) (tls.Certificate, error) + type X509KeyPairCreator func(certPEMBlock []byte, keyPEMBlock []byte) (tls.Certificate, error)
Go to main page