Versions in this module Expand all Collapse all v1 v1.7.0 Feb 14, 2023 Changes in this version + var ErrInvalidConfig = errors.New("invalid secure NATs configuration") + var ErrNoCertificate = errors.New("server did not present a certificate") + var ErrNoConnection = errors.New("no nats connection found") + var ErrNoServerName = errors.New("no server name provided") + func VerifyServerCertificate(conf SecurableConfig, certificates [][]byte) error + type InMemorySecureConfig struct + func NewInMemorySecureConfig(server, caBundle string, ...) InMemorySecureConfig + func (i *InMemorySecureConfig) CreateTLSConfig() (*tls.Config, error) + func (i *InMemorySecureConfig) Validate() error + func (i InMemorySecureConfig) CAFile() string + func (i InMemorySecureConfig) ServerName() string + type OnDiskSecureConfig struct + func NewOnDiskSecureConfig(serverName, certFile, keyFile, caFile string) OnDiskSecureConfig + func (sc OnDiskSecureConfig) CAFile() string + func (sc OnDiskSecureConfig) CreateTLSConfig() (*tls.Config, error) + func (sc OnDiskSecureConfig) ServerName() string + func (sc OnDiskSecureConfig) Validate() error + type RootCertParseError struct + func (e RootCertParseError) Error() string + type SecurableConfig interface + CAFile func() string + CreateTLSConfig func() (*tls.Config, error) + ServerName func() string + Validate func() error + type SecureMessageBus struct + Conn *nats.Conn + func NewSecureMessageBus(secureConfig SecurableConfig) (*SecureMessageBus, error) + func (m *SecureMessageBus) Close() error + func (m *SecureMessageBus) Connect(url string, opts ...nats.Option) error + func (m *SecureMessageBus) IsConnected() bool + func (m *SecureMessageBus) Publish(subj string, msg []byte) error + func (m *SecureMessageBus) Subscribe(subj string, msgCh chan []byte) error
Go to main page