Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/aws/aws-advanced-go-wrapper
/ functions
Functions
1,810 in github.com/aws/aws-advanced-go-wrapper
⨍
Functions
1,810
◇
Types & classes
307
↓ 2 callers
Method
IsFailoverErrorType
()
awssql/error_util/errors.go:60
↓ 2 callers
Function
IsIPV6
(host string)
awssql/utils/rds_utils.go:119
↓ 2 callers
Function
IsIPv4
(host string)
awssql/utils/rds_utils.go:115
↓ 2 callers
Function
IsRdsDns
(host string)
awssql/utils/rds_utils.go:161
↓ 2 callers
Method
IsStaticHostListProvider
()
awssql/driver_infrastructure/plugin_helpers.go:66
↓ 2 callers
Method
IsWriterInstance
(conn driver.Conn)
awssql/driver_infrastructure/cluster_topology_monitor.go:98
↓ 2 callers
Method
IsWriterInstance
(conn driver.Conn)
awssql/driver_infrastructure/topology_utils.go:47
↓ 2 callers
Method
LogOpenedConnections
()
awssql/plugins/connection_tracker/connection_tracker.go:29
↓ 2 callers
Function
NewAuroraTopologyUtils
(dialect TopologyDialect, driverDialect DriverDialect, props *utils.RWMap[string, string])
awssql/driver_infrastructure/topology_utils.go:248
↓ 2 callers
Function
NewBatchingEventPublisher
NewBatchingEventPublisher creates a new batching event publisher with custom interval.
awssql/services/events.go:139
↓ 2 callers
Function
NewBlueGreenStatusMonitor
(blueGreenRole driver_infrastructure.BlueGreenRole, bgdId string, hostInfo *host_info_util.HostInfo, pluginSe
awssql/plugins/bg/bg_status_monitor.go:79
↓ 2 callers
Function
NewCustomEndpointPlugin
( servicesContainer driver_infrastructure.ServicesContainer, rdsClientFunc getRdsClientFunc, props *utils.R
custom-endpoint/custom_endpoint_plugin.go:101
↓ 2 callers
Function
NewDsnHostListProvider
(props *utils.RWMap[string, string], hostListProviderService HostListProviderService)
awssql/driver_infrastructure/dsn_host_list_provider.go:38
↓ 2 callers
Function
NewFailoverPlugin
( servicesContainer driver_infrastructure.ServicesContainer, props *utils.RWMap[string, string], pluginCode
awssql/plugins/failover_plugin.go:101
↓ 2 callers
Function
NewGlobalAuroraHostListProvider
( hostListProviderService HostListProviderService, topologyUtils GlobalClusterTopologyUtils, properties *ut
awssql/driver_infrastructure/global_aurora_host_list_provider.go:36
↓ 2 callers
Function
NewGlobalAuroraTopologyUtils
(dialect GlobalAuroraTopologyDialect, driverDialect DriverDialect, props *utils.RWMap[string, string])
awssql/driver_infrastructure/topology_utils.go:535
↓ 2 callers
Function
NewLimitlessQueryHelperImpl
(pluginService driver_infrastructure.PluginService)
awssql/plugins/limitless/limitless_query_helper.go:42
↓ 2 callers
Function
NewLimitlessRouters
NewLimitlessRouters creates a new LimitlessRouters instance.
awssql/plugins/limitless/limitless_routers.go:32
↓ 2 callers
Function
NewMultiAzTopologyUtils
(dialect MultiAzTopologyDialect, driverDialect DriverDialect, props *utils.RWMap[string, string])
awssql/driver_infrastructure/topology_utils.go:367
↓ 2 callers
Function
NewNilTelemetryFactory
()
awssql/utils/telemetry/nil_telemetry_factory.go:27
↓ 2 callers
Function
NewOpenTelemetryContext
(tracer trace.Tracer, name string, traceLevel telemetry.TelemetryTraceLevel, ctx context.Context)
otlp/open_telemetry_context.go:40
↓ 2 callers
Function
NewReadWriteSplittingPlugin
( servicesContainer driver_infrastructure.ServicesContainer, props *utils.RWMap[string, string], pluginCode
awssql/plugins/read_write_splitting/read_write_splitting_plugin.go:88
↓ 2 callers
Function
NewSuspendUntilCorrespondingHostFoundConnectRouting
(hostAndPort string, role driver_infrastructure.BlueGreenRole, bgId string, storageService driver_infrastruct
awssql/plugins/bg/connect_routing.go:255
↓ 2 callers
Function
NewXRayTelemetryContext
(name string, traceLevel telemetry.TelemetryTraceLevel, ctx context.Context)
xray/xray_telemetry_context.go:33
↓ 2 callers
Method
NotifySubscribedPlugins
( methodName string, pluginFunc driver_infrastructure.PluginExecFunc, skipNotificationForThisPlugin driver_
awssql/plugin_helpers/plugin_manager.go:347
↓ 2 callers
Method
Ping
(ctx context.Context)
awssql/driver/driver.go:296
↓ 2 callers
Method
PrepareDsn
(properties map[string]string, info *host_info_util.HostInfo)
awssql/driver_infrastructure/driver_dialect.go:29
↓ 2 callers
Method
Query
(args []driver.Value)
awssql/driver/driver.go:413
↓ 2 callers
Method
QueryForLimitlessRouters
(conn driver.Conn, hostPortToMap int, props *utils.RWMap[string, string])
awssql/plugins/limitless/limitless_query_helper.go:35
↓ 2 callers
Method
RaiseErrorOnNextCall
(err error, methodName string)
awssql/plugins/error_simulator/error_simulator.go:20
↓ 2 callers
Method
RaiseErrorOnNextConnect
(err error)
awssql/plugins/error_simulator/error_simulator_manager.go:34
↓ 2 callers
Method
Refresh
()
awssql/driver_infrastructure/host_list_provider.go:27
↓ 2 callers
Method
ResetAliases
()
awssql/host_info_util/host_info.go:66
↓ 2 callers
Method
ResetCollectedData
()
awssql/plugins/bg/bg_status_monitor.go:561
↓ 2 callers
Method
RowsAffected
()
awssql/driver/driver.go:468
↓ 2 callers
Method
SetAttribute
(key string, value string)
awssql/utils/telemetry/telemetry_util.go:66
↓ 2 callers
Method
SetCallback
(errorSimulatorMethodCallback ErrorSimulatorMethodCallback)
awssql/plugins/error_simulator/error_simulator.go:21
↓ 2 callers
Method
SetHostWeights
(hostWeightMap map[string]int)
awssql/driver_infrastructure/host_selector.go:48
↓ 2 callers
Method
SetLastUpdateTime
(lastUpdateTime time.Time)
awssql/host_info_util/host_info.go:201
↓ 2 callers
Method
SetSuccess
(success bool)
otlp/open_telemetry_context.go:124
↓ 2 callers
Method
SetWeight
(weight int)
awssql/host_info_util/host_info.go:191
↓ 2 callers
Method
StopMonitor
()
awssql/driver_infrastructure/host_list_provider.go:33
↓ 2 callers
Method
String
()
awssql/driver_infrastructure/bg_helpers.go:150
↓ 2 callers
Method
ToString
()
awssql/driver_infrastructure/session_state.go:104
↓ 2 callers
Method
Unsubscribe
(subscriber EventSubscriber, eventTypes []*EventType)
awssql/driver_infrastructure/event.go:39
↓ 2 callers
Method
UnwrapPlugin
(pluginCode string)
awssql/driver_infrastructure/plugin_helpers.go:125
↓ 2 callers
Function
WithProperty
(key DriverPropertyKey, value int)
awssql/driver_infrastructure/driver_dialect.go:75
↓ 2 callers
Method
applySecretToProperties
(props *utils.RWMap[string, string], secret AwsRdsSecrets)
aws-secrets-manager/aws_secrets_manager_connection_plugin.go:203
↓ 2 callers
Function
beginWithPlugins
( connInvokedOn driver.Conn, pluginManager driver_infrastructure.PluginManager, pluginService driver_infras
awssql/driver/wrapper_utils.go:123
↓ 2 callers
Method
compareHostInfos
(hostInfoA *host_info_util.HostInfo, hostInfoB *host_info_util.HostInfo)
awssql/plugin_helpers/plugin_service.go:217
↓ 2 callers
Method
connectInternal
( hostInfo *host_info_util.HostInfo, props *utils.RWMap[string, string], connectFunc driver_infrastructure.
federated-auth/federated_auth_plugin.go:111
↓ 2 callers
Method
connectInternal
( hostInfo *host_info_util.HostInfo, props *utils.RWMap[string, string], connectFunc driver_infrastructure.
okta/okta_auth_plugin.go:113
↓ 2 callers
Method
connectInternal
( hostInfo *host_info_util.HostInfo, props *utils.RWMap[string, string], connectFunc driver_infrastructure.
iam/iam_auth_plugin.go:110
↓ 2 callers
Method
connectInternal
( hostInfo *host_info_util.HostInfo, props *utils.RWMap[string, string], connProvider driver_infrastructure
awssql/plugins/default_plugin.go:97
↓ 2 callers
Method
connectInternal
( hostInfo *host_info_util.HostInfo, props *utils.RWMap[string, string], connectFunc driver_infrastructure.
aws-secrets-manager/aws_secrets_manager_connection_plugin.go:165
↓ 2 callers
Method
connectWithSubscribedPlugins
(methodName string, pluginFunc driver_infrastructure.PluginConnectFunc, targetFunc driver_infrastructure.Conn
awssql/plugin_helpers/plugin_manager.go:278
↓ 2 callers
Function
createClusterTopologyMonitor
( servicesContainer ServicesContainer, clusterId string, props *utils.RWMap[string, string], initialHostIn
awssql/driver_infrastructure/rds_host_list_provider.go:147
↓ 2 callers
Method
createMonitorIfAbsent
( props *utils.RWMap[string, string])
custom-endpoint/custom_endpoint_plugin.go:219
↓ 2 callers
Method
dealWithError
dealWithError inspects an error and triggers failover if appropriate.
awssql/plugins/failover_handler.go:26
↓ 2 callers
Method
delay
(useHighRefreshRate bool)
awssql/driver_infrastructure/cluster_topology_monitor.go:644
↓ 2 callers
Method
deliverEvent
(event driver_infrastructure.Event)
awssql/services/events.go:183
↓ 2 callers
Method
executeWithSubscribedPlugins
( methodName string, pluginFunc driver_infrastructure.PluginExecFunc, targetFunc driver_infrastructure.Exec
awssql/plugin_helpers/plugin_manager.go:268
↓ 2 callers
Method
extendExpiration
(ttl time.Duration)
awssql/utils/expiration_cache.go:37
↓ 2 callers
Method
fetchAndSetToken
( hostInfo *host_info_util.HostInfo, host string, port int, region region_util.Region, cacheKey string,
iam/iam_auth_plugin.go:173
↓ 2 callers
Function
findHost
(hosts []*host_info_util.HostInfo, instanceId string, instanceName string)
awssql/driver_infrastructure/rds_host_list_provider.go:251
↓ 2 callers
Method
forceRefreshMonitor
(verifyTopology bool, timeoutMs int)
awssql/driver_infrastructure/rds_host_list_provider.go:191
↓ 2 callers
Function
gdbFailoverModeFromValue
(value string)
awssql/plugins/gdb_failover_plugin.go:49
↓ 2 callers
Method
getBgStatus
()
awssql/plugins/bg/connect_routing.go:148
↓ 2 callers
Method
getBgStatus
()
awssql/plugins/bg/connect_routing.go:200
↓ 2 callers
Method
getBgStatus
()
awssql/plugins/bg/execute_routing.go:36
↓ 2 callers
Function
getDefaultProvider
(profile string)
auth-helpers/aws_credentials_management.go:52
↓ 2 callers
Method
getIpMapString
(ipMap map[string]string)
awssql/plugins/bg/bg_interim_status.go:157
↓ 2 callers
Method
getLimitlessRouters
(routerCacheKey string)
awssql/plugins/limitless/limitless_router_service.go:158
↓ 2 callers
Method
getNewWriterConnection
(hosts []*host_info_util.HostInfo)
awssql/plugins/read_write_splitting/read_write_splitting_plugin.go:398
↓ 2 callers
Method
getReaderFailoverCandidates
(hosts []*host_info_util.HostInfo)
awssql/plugins/failover_plugin.go:464
↓ 2 callers
Method
getSQLStateFromError
(err error)
pgx-driver/pgx_error_handler.go:84
↓ 2 callers
Method
getSQLStateFromError
(err error)
mysql-driver/mysql_error_handler.go:58
↓ 2 callers
Function
getTelemetryFactory
(enableTelemetry bool, backend string)
awssql/utils/telemetry/default_telemetry_factory.go:69
↓ 2 callers
Method
getTopologyString
(topology []*host_info_util.HostInfo)
awssql/plugins/bg/bg_interim_status.go:142
↓ 2 callers
Method
hasNoReaders
()
awssql/plugins/aurora_initial_connection_strategy_plugin.go:391
↓ 2 callers
Function
hasPropertyChanged
( lastPropertyValue T, wrapperProperty property_util.AwsWrapperProperty, props map[string]string)
awssql/driver_infrastructure/round_robin_host_selector.go:263
↓ 2 callers
Method
initFailoverMode
initFailoverMode initializes the failover mode based on connection properties and URL type.
awssql/plugins/failover_handler.go:22
↓ 2 callers
Method
initializeReaderConnection
(hosts []*host_info_util.HostInfo)
awssql/plugins/read_write_splitting/read_write_splitting_plugin.go:378
↓ 2 callers
Method
isReader
(hostInfo *host_info_util.HostInfo)
awssql/plugins/read_write_splitting/read_write_splitting_plugin.go:448
↓ 2 callers
Function
parseMultiStatementQueries
(query string)
awssql/utils/sql_method_utils.go:95
↓ 2 callers
Function
prepareWithPlugins
( connInvokedOn driver.Conn, pluginManager driver_infrastructure.PluginManager, methodName string, prepare
awssql/driver/wrapper_utils.go:105
↓ 2 callers
Function
pruneNullConnections
()
awssql/plugins/connection_tracker/opened_connection_tracker.go:169
↓ 2 callers
Method
queryForTopology
(conn driver.Conn)
awssql/driver_infrastructure/cluster_topology_monitor.go:556
↓ 2 callers
Method
raiseError
(err error, methodName string)
awssql/plugins/developer_connection_plugin.go:107
↓ 2 callers
Method
raiseErrorOnConnect
(err error)
awssql/plugins/developer_connection_plugin.go:146
↓ 2 callers
Method
resetRoutingTimeNano
()
awssql/plugins/bg/bg_plugin.go:265
↓ 2 callers
Method
resetStateEnabledSetting
()
awssql/driver_infrastructure/session_state_service.go:82
↓ 2 callers
Method
returnReaderFailoverErr
(err error)
awssql/plugins/failover_plugin.go:459
↓ 2 callers
Method
setHostList
(newHosts []*host_info_util.HostInfo)
awssql/plugin_helpers/plugin_service.go:423
↓ 2 callers
Function
setInitialSessionSettings
(db *sql.DB)
examples/aws_failover_postgresql_example.go:90
↓ 2 callers
Function
setInitialSessionSettings
(db *sql.DB)
examples/aws_failover_mysql_example.go:90
↓ 2 callers
Method
setReadWriteMode
(readOnly bool)
awssql/driver/driver.go:355
↓ 2 callers
Method
setReaderConnection
(conn driver.Conn, host *host_info_util.HostInfo)
awssql/plugins/read_write_splitting/read_write_splitting_plugin.go:457
↓ 2 callers
Method
setWriterConnection
(conn driver.Conn, host *host_info_util.HostInfo)
awssql/plugins/read_write_splitting/read_write_splitting_plugin.go:452
↓ 2 callers
Method
shortDelay
()
awssql/plugins/gdb_failover_plugin.go:472
← previous
next →
301–400 of 1,810, ranked by callers