plugin_helpers

package

Go to main page

Versions in this module

v1

v1.3.0

Dec 16, 2025

v1.3.0-rc

Dec 16, 2025

v1.2.0

Dec 5, 2025

Changes in this version

type PluginServiceImpl

+ func (p *PluginServiceImpl) GetAllHosts() []*host_info_util.HostInfo

+ func (p *PluginServiceImpl) SetAllowedAndBlockedHosts(allowedAndBlockedHosts *driver_infrastructure.AllowedAndBlockedHosts)

v1.2.0-rc2

Dec 4, 2025

v1.2.0-rc

Dec 4, 2025

v1.1.1

Oct 17, 2025

v1.1.1-rc

Oct 17, 2025 GO-2025-4119

GO-2025-4119: AWS Advanced Go Wrapper: Privilege Escalation in Aurora PostgreSQL Instance in github.com/aws/aws-advanced-go-wrapper/awssql

v1.1.0

Oct 8, 2025 GO-2025-4119

GO-2025-4119: AWS Advanced Go Wrapper: Privilege Escalation in Aurora PostgreSQL Instance in github.com/aws/aws-advanced-go-wrapper/awssql

Changes in this version

+ var DEFAULT_STATUS_CACHE_EXPIRE_NANO = 60 * time.Minute

type PluginManagerImpl

+ func (pluginManager *PluginManagerImpl) IsPluginInUse(pluginCode string) bool

+ func (pluginManager *PluginManagerImpl) UnwrapPlugin(pluginCode string) driver_infrastructure.ConnectionPlugin

type PluginServiceImpl

+ func (p *PluginServiceImpl) GetBgStatus(id string) (driver_infrastructure.BlueGreenStatus, bool)

+ func (p *PluginServiceImpl) IsPluginInUse(pluginName string) bool

+ func (p *PluginServiceImpl) ResetSession()

+ func (p *PluginServiceImpl) SetBgStatus(status driver_infrastructure.BlueGreenStatus, id string)

v1.1.0-rc

Oct 8, 2025 GO-2025-4119

GO-2025-4119: AWS Advanced Go Wrapper: Privilege Escalation in Aurora PostgreSQL Instance in github.com/aws/aws-advanced-go-wrapper/awssql

v1.0.0

Jul 30, 2025 GO-2025-4119

GO-2025-4119: AWS Advanced Go Wrapper: Privilege Escalation in Aurora PostgreSQL Instance in github.com/aws/aws-advanced-go-wrapper/awssql

Changes in this version

+ const ACCEPTS_STRATEGY_METHOD

+ const ALL_METHODS

+ const CONNECT_METHOD

+ const FORCE_CONNECT_METHOD

+ const GET_HOST_INFO_BY_STRATEGY_METHOD

+ const GET_HOST_SELECT_STRATEGY_METHOD

+ const INIT_HOST_PROVIDER_METHOD

+ const NOTIFY_CONNECTION_CHANGED_METHOD

+ const NOTIFY_HOST_LIST_CHANGED_METHOD

+ var DEFAULT_HOST_AVAILABILITY_CACHE_EXPIRE_NANO time.Duration = 5 * time.Minute

+ func ClearCaches()

+ func NewPluginManagerImpl(targetDriver driver.Driver, props map[string]string, ...) driver_infrastructure.PluginManager

+ func NewPluginServiceImpl(pluginManager driver_infrastructure.PluginManager, ...) (driver_infrastructure.PluginService, error)

+ type PluginChain struct

+ func (chain *PluginChain) Connect(pluginFunc driver_infrastructure.PluginConnectFunc, props map[string]string, ...) (driver.Conn, error)

+ func (chain *PluginChain) ConnectAddToHead(plugin driver_infrastructure.ConnectionPlugin)

+ func (chain *PluginChain) ExecAddToHead(plugin driver_infrastructure.ConnectionPlugin)

+ func (chain *PluginChain) Execute(pluginFunc driver_infrastructure.PluginExecFunc, ...) (any, any, bool, error)

+ type PluginManagerImpl struct

+ func (pluginManager *PluginManagerImpl) AcceptsStrategy(strategy string) bool

+ func (pluginManager *PluginManagerImpl) Connect(hostInfo *host_info_util.HostInfo, props map[string]string, ...) (driver.Conn, error)

+ func (pluginManager *PluginManagerImpl) Execute(connInvokedOn driver.Conn, methodName string, ...) (any, any, bool, error)

+ func (pluginManager *PluginManagerImpl) ForceConnect(hostInfo *host_info_util.HostInfo, props map[string]string, ...) (driver.Conn, error)

+ func (pluginManager *PluginManagerImpl) GetConnectionProviderManager() driver_infrastructure.ConnectionProviderManager

+ func (pluginManager *PluginManagerImpl) GetDefaultConnectionProvider() driver_infrastructure.ConnectionProvider

+ func (pluginManager *PluginManagerImpl) GetEffectiveConnectionProvider() driver_infrastructure.ConnectionProvider

+ func (pluginManager *PluginManagerImpl) GetHostInfoByStrategy(role host_info_util.HostRole, strategy string, ...) (host *host_info_util.HostInfo, err error)

+ func (pluginManager *PluginManagerImpl) GetHostSelectorStrategy(strategy string) (hostSelector driver_infrastructure.HostSelector, err error)

+ func (pluginManager *PluginManagerImpl) GetTelemetryContext() context.Context

+ func (pluginManager *PluginManagerImpl) GetTelemetryFactory() telemetry.TelemetryFactory

+ func (pluginManager *PluginManagerImpl) Init(pluginService driver_infrastructure.PluginService, ...) error

+ func (pluginManager *PluginManagerImpl) InitHostProvider(initialUrl string, props map[string]string, ...) error

+ func (pluginManager *PluginManagerImpl) NotifyConnectionChanged(changes map[driver_infrastructure.HostChangeOptions]bool, ...) map[driver_infrastructure.OldConnectionSuggestedAction]bool

+ func (pluginManager *PluginManagerImpl) NotifyHostListChanged(changes map[string]map[driver_infrastructure.HostChangeOptions]bool)

+ func (pluginManager *PluginManagerImpl) NotifySubscribedPlugins(methodName string, pluginFunc driver_infrastructure.PluginExecFunc, ...) error

+ func (pluginManager *PluginManagerImpl) ReleaseResources()

+ func (pluginManager *PluginManagerImpl) SetTelemetryContext(ctx context.Context)

+ type PluginServiceImpl struct

+ AllHosts []*host_info_util.HostInfo

+ func (p *PluginServiceImpl) AcceptsStrategy(strategy string) bool

+ func (p *PluginServiceImpl) Connect(hostInfo *host_info_util.HostInfo, props map[string]string, ...) (driver.Conn, error)

+ func (p *PluginServiceImpl) CreateHostListProvider(props map[string]string, dsn string) driver_infrastructure.HostListProvider

+ func (p *PluginServiceImpl) FillAliases(conn driver.Conn, hostInfo *host_info_util.HostInfo)

+ func (p *PluginServiceImpl) ForceConnect(hostInfo *host_info_util.HostInfo, props map[string]string) (driver.Conn, error)

+ func (p *PluginServiceImpl) ForceRefreshHostList(conn driver.Conn) error

+ func (p *PluginServiceImpl) ForceRefreshHostListWithTimeout(shouldVerifyWriter bool, timeoutMs int) (bool, error)

+ func (p *PluginServiceImpl) GetConnectionProvider() driver_infrastructure.ConnectionProvider

+ func (p *PluginServiceImpl) GetCurrentConnection() driver.Conn

+ func (p *PluginServiceImpl) GetCurrentConnectionRef() *driver.Conn

+ func (p *PluginServiceImpl) GetCurrentHostInfo() (*host_info_util.HostInfo, error)

+ func (p *PluginServiceImpl) GetCurrentTx() driver.Tx

+ func (p *PluginServiceImpl) GetDialect() driver_infrastructure.DatabaseDialect

+ func (p *PluginServiceImpl) GetHostInfoByStrategy(role host_info_util.HostRole, strategy string, ...) (*host_info_util.HostInfo, error)

+ func (p *PluginServiceImpl) GetHostListProvider() driver_infrastructure.HostListProvider

+ func (p *PluginServiceImpl) GetHostRole(conn driver.Conn) host_info_util.HostRole

+ func (p *PluginServiceImpl) GetHostSelectorStrategy(strategy string) (hostSelector driver_infrastructure.HostSelector, err error)

+ func (p *PluginServiceImpl) GetHosts() []*host_info_util.HostInfo

+ func (p *PluginServiceImpl) GetInitialConnectionHostInfo() *host_info_util.HostInfo

+ func (p *PluginServiceImpl) GetProperties() map[string]string

+ func (p *PluginServiceImpl) GetTargetDriverDialect() driver_infrastructure.DriverDialect

+ func (p *PluginServiceImpl) GetTelemetryContext() context.Context

+ func (p *PluginServiceImpl) GetTelemetryFactory() telemetry.TelemetryFactory

+ func (p *PluginServiceImpl) GetUpdatedHostListWithTimeout(shouldVerifyWriter bool, timeoutMs int) ([]*host_info_util.HostInfo, error)

+ func (p *PluginServiceImpl) IdentifyConnection(conn driver.Conn) (*host_info_util.HostInfo, error)

+ func (p *PluginServiceImpl) IsInTransaction() bool

+ func (p *PluginServiceImpl) IsLoginError(err error) bool

+ func (p *PluginServiceImpl) IsNetworkError(err error) bool

+ func (p *PluginServiceImpl) IsStaticHostListProvider() bool

+ func (p *PluginServiceImpl) RefreshHostList(conn driver.Conn) error

+ func (p *PluginServiceImpl) ReleaseResources()

+ func (p *PluginServiceImpl) SetAvailability(hostAliases map[string]bool, availability host_info_util.HostAvailability)

+ func (p *PluginServiceImpl) SetCurrentConnection(conn driver.Conn, hostInfo *host_info_util.HostInfo, ...) error

+ func (p *PluginServiceImpl) SetCurrentTx(tx driver.Tx)

+ func (p *PluginServiceImpl) SetDialect(dialect driver_infrastructure.DatabaseDialect)

+ func (p *PluginServiceImpl) SetHostListProvider(hostListProvider driver_infrastructure.HostListProvider)

+ func (p *PluginServiceImpl) SetInTransaction(inTransaction bool)

+ func (p *PluginServiceImpl) SetInitialConnectionHostInfo(hostInfo *host_info_util.HostInfo)

+ func (p *PluginServiceImpl) SetTelemetryContext(ctx context.Context)

+ func (p *PluginServiceImpl) UpdateDialect(conn driver.Conn)

+ func (p *PluginServiceImpl) UpdateState(sql string, methodArgs ...any)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL