sqlprovider

Documentation

Index

• type Provider
  • func NewProvider(sqlconnector sqlconnect.SqlConnector) *Provider
  • func (p *Provider) CloseClientConnection(client neosync_benthos_sql.SqlDbtx) error
  • func (p *Provider) GetConnectionClient(cc *mgmtv1alpha1.ConnectionConfig) (neosync_benthos_sql.SqlDbtx, error)

Types

type Provider

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

func NewProvider

func NewProvider(
	sqlconnector sqlconnect.SqlConnector,
) *Provider

func (*Provider) CloseClientConnection

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

func (*Provider) GetConnectionClient

func (p *Provider) GetConnectionClient(cc *mgmtv1alpha1.ConnectionConfig) (neosync_benthos_sql.SqlDbtx, error)