sqlprovider

Documentation

Index

• type ConnectionClientConfig
• type Provider
  • func NewProvider() *Provider
  • func (p *Provider) CloseClientConnection(client neosync_benthos_sql.SqlDbtx) error
  • func (p *Provider) GetConnectionClient(driver, connectionString string, opts *ConnectionClientConfig) (neosync_benthos_sql.SqlDbtx, error)
  • func (p *Provider) GetConnectionClientConfig(cc *mgmtv1alpha1.ConnectionConfig) (*ConnectionClientConfig, error)
  • func (p *Provider) GetConnectionDetails(cc *mgmtv1alpha1.ConnectionConfig, connectionTimeout *uint32, ...) (connectiontunnelmanager.ConnectionDetails, error)

Types

type ConnectionClientConfig

type ConnectionClientConfig struct {
	MaxConnectionLimit *int32
}

type Provider

type Provider struct{}

func NewProvider

func NewProvider() *Provider

func (*Provider) CloseClientConnection

func (p *Provider) CloseClientConnection(client neosync_benthos_sql.SqlDbtx) error

func (*Provider) GetConnectionClient

func (p *Provider) GetConnectionClient(driver, connectionString string, opts *ConnectionClientConfig) (neosync_benthos_sql.SqlDbtx, error)

func (*Provider) GetConnectionClientConfig

func (p *Provider) GetConnectionClientConfig(cc *mgmtv1alpha1.ConnectionConfig) (*ConnectionClientConfig, error)

func (*Provider) GetConnectionDetails

func (p *Provider) GetConnectionDetails(
	cc *mgmtv1alpha1.ConnectionConfig,
	connectionTimeout *uint32,
	logger *slog.Logger,
) (connectiontunnelmanager.ConnectionDetails, error)