Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrNotNegotiatedByUs = errors.New("connection was not negotiated by us (wrong AuthInfo)") ErrUnableToGetPeer = errors.New("unable to get peer from context") ErrUnableToGetAuthInfo = errors.New("unable to get authinfo from peer") )
View Source
var ErrAuthenticationFailed = errors.New("authentication failed")
Functions ¶
func NewFactory ¶
Types ¶
type Config ¶
type Config struct {
// Configures the protocol to use TLS.
// The default value is nil, which will cause the protocol to not use TLS.
TLS configoptional.Optional[configtls.ServerConfig] `mapstructure:"tls,omitempty"`
ChangefeedBatchSize configoptional.Optional[int] `mapstructure:"changefeedBatchSize,omitempty"`
ChangefeedInterval configoptional.Optional[int] `mapstructure:"changefeedInterval,omitempty"`
}
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.