providers

Documentation

Index

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

Types

type Provider

type Provider struct {
	// contains filtered or unexported fields
}

func NewProvider

func NewProvider(
	mp connectiontunnelmanager.ConnectionProvider[neosync_benthos_mongodb.MongoClient, any],
	sp connectiontunnelmanager.ConnectionProvider[neosync_benthos_sql.SqlDbtx, *sqlprovider.ConnectionClientConfig],
) *Provider

func (*Provider) CloseClientConnection

func (p *Provider) CloseClientConnection(client any) error

func (*Provider) GetConnectionClient

func (p *Provider) GetConnectionClient(driver, connectionString string, opts any) (any, error)

func (*Provider) GetConnectionClientConfig

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

func (*Provider) GetConnectionDetails

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