pkg

Nov 6, 2023

Changes in this version

+ const ExactlyOnce

May 23, 2023

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 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)