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
↓ 3 callers
Method
IsPresent
()
awssql/driver_infrastructure/bg_helpers.go:297
↓ 3 callers
Method
IsValid
()
awssql/driver/driver.go:308
↓ 3 callers
Function
NewSuspendConnectRouting
( hostAndPort string, role driver_infrastructure.BlueGreenRole, bgId string, storageService driver_infrastru
awssql/plugins/bg/connect_routing.go:187
↓ 3 callers
Function
NewSuspendExecuteRouting
( hostAndPort string, role driver_infrastructure.BlueGreenRole, bgId string, storageService driver_infrastru
awssql/plugins/bg/execute_routing.go:76
↓ 3 callers
Function
NewTopology
NewTopology creates a new Topology with the given hosts.
awssql/driver_infrastructure/topology.go:43
↓ 3 callers
Method
NotifyConnectionChanged
( changes map[HostChangeOptions]bool, skipNotificationForThisPlugin ConnectionPlugin)
awssql/driver_infrastructure/plugin_helpers.go:112
↓ 3 callers
Method
ParseInt64
ParseInt64 extracts an int64 from a driver.Value
awssql/driver_infrastructure/driver_dialect.go:52
↓ 3 callers
Method
ParseTime
ParseTime extracts a time.Time from a driver.Value
awssql/driver_infrastructure/driver_dialect.go:50
↓ 3 callers
Method
RegisterMonitorType
(monitorType *MonitorType, settings *MonitorSettings, producedDataType string)
awssql/driver_infrastructure/monitor.go:68
↓ 3 callers
Method
ReleaseResources
()
awssql/internal_pool/internal_pooled_connection_provider.go:140
↓ 3 callers
Method
Rollback
()
awssql/driver/driver.go:498
↓ 3 callers
Method
SetCurrentTx
(driver.Tx)
awssql/driver_infrastructure/plugin_helpers.go:62
↓ 3 callers
Method
SetInTransaction
(inTransaction bool)
awssql/driver_infrastructure/plugin_helpers.go:60
↓ 3 callers
Method
SetInactive
()
awssql/plugins/efm/host_monitoring_service.go:216
↓ 3 callers
Method
Subscribe
(subscriber EventSubscriber, eventTypes []*EventType)
awssql/driver_infrastructure/event.go:38
↓ 3 callers
Method
closeConnectionIfIdle
(conn driver.Conn)
awssql/plugins/read_write_splitting/read_write_splitting_plugin.go:421
↓ 3 callers
Function
execWithPlugins
( connInvokedOn driver.Conn, pluginManager driver_infrastructure.PluginManager, methodName string, execFun
awssql/driver/wrapper_utils.go:87
↓ 3 callers
Method
failover
failover performs the actual failover procedure.
awssql/plugins/failover_handler.go:24
↓ 3 callers
Method
fetchTopologyAndUpdateCache
(conn driver.Conn)
awssql/driver_infrastructure/cluster_topology_monitor.go:538
↓ 3 callers
Method
getSQLStateFromError
(err error)
bun-pg-driver/bun_error_handler.go:81
↓ 3 callers
Method
getStoredTopology
()
awssql/driver_infrastructure/cluster_topology_monitor.go:481
↓ 3 callers
Method
init
()
awssql/driver_infrastructure/dsn_host_list_provider.go:51
↓ 3 callers
Method
initProvider
()
awssql/plugins/bg/bg_plugin.go:237
↓ 3 callers
Function
isDsnMySql
(dsn string)
awssql/property_util/dsn_parser.go:209
↓ 3 callers
Function
isDsnPgxKeyValueString
(dsn string)
awssql/property_util/dsn_parser.go:205
↓ 3 callers
Function
isDsnPgxUrl
(dsn string)
awssql/property_util/dsn_parser.go:201
↓ 3 callers
Method
makePluginChain
( name string, creatingExecChain bool, pluginToSkip driver_infrastructure.ConnectionPlugin)
awssql/plugin_helpers/plugin_manager.go:291
↓ 3 callers
Method
notifyChannel
(channel chan bool)
awssql/driver_infrastructure/cluster_topology_monitor.go:677
↓ 3 callers
Function
queryHostRole
============================================================================= Shared topology query helpers ==========================================
awssql/driver_infrastructure/topology_utils.go:164
↓ 3 callers
Function
queryInstanceId
queryInstanceId executes the instance ID query and returns (id, name). Automatically handles single-column queries (returns id, id) and two-column que
awssql/driver_infrastructure/topology_utils.go:187
↓ 3 callers
Function
queryIsWriter
queryIsWriter executes the writer ID query and checks if connected to writer. For Aurora: writer if query returns non-empty server ID. For Multi-AZ: w
awssql/driver_infrastructure/topology_utils.go:216
↓ 3 callers
Function
queryWithPlugins
( connInvokedOn driver.Conn, pluginManager driver_infrastructure.PluginManager, methodName string, queryFu
awssql/driver/wrapper_utils.go:60
↓ 3 callers
Method
readerRoutineFetchTopology
(conn driver.Conn, writerHostInfo *host_info_util.HostInfo)
awssql/driver_infrastructure/cluster_topology_monitor.go:801
↓ 3 callers
Function
resolveQueryTimeoutMs
(driverDialect DriverDialect, props *utils.RWMap[string, string])
awssql/driver_infrastructure/topology_utils.go:152
↓ 3 callers
Method
retryConnectWithLeastLoadedRouters
(context *LimitlessConnectionContext)
awssql/plugins/limitless/limitless_router_service.go:248
↓ 3 callers
Method
returnFailoverSuccessError
()
awssql/plugins/failover_plugin.go:295
↓ 3 callers
Method
shouldErrorTriggerConnectionSwitch
(err error)
awssql/plugins/failover_plugin.go:594
↓ 3 callers
Function
testQuery
(db *sql.DB)
examples/aws_internal_connection_pool_password_warning_postgresql_example.go:90
↓ 3 callers
Function
testQuery
(db *sql.DB)
examples/aws_internal_connection_pool_password_warning_mysql_example.go:90
↓ 3 callers
Method
updateHostsAvailability
(hosts []*host_info_util.HostInfo)
awssql/driver_infrastructure/cluster_topology_monitor.go:568
↓ 3 callers
Function
verifyWriter
(hosts []*host_info_util.HostInfo)
awssql/driver_infrastructure/topology_utils.go:83
↓ 3 callers
Method
withExtendExpiration
(itemExpirationNano time.Duration)
awssql/utils/sliding_expiration_cache.go:260
↓ 2 callers
Method
AcceptsUrl
(hostInfo host_info_util.HostInfo, props map[string]string)
awssql/driver_infrastructure/connection_provider.go:26
↓ 2 callers
Method
AddSubstituteBlueWithIpAddressConnectRouting
()
awssql/plugins/bg/bg_status_provider.go:481
↓ 2 callers
Method
Apply
( plugin ConnectionPlugin, hostInfo *host_info_util.HostInfo, properties *utils.RWMap[string, string],
awssql/driver_infrastructure/bg_helpers.go:241
↓ 2 callers
Method
Begin
()
awssql/driver_infrastructure/session_state_service.go:54
↓ 2 callers
Method
CheckNamedValue
(val *driver.NamedValue)
awssql/driver/driver.go:334
↓ 2 callers
Method
CleanUp
()
awssql/utils/cache_map.go:145
↓ 2 callers
Method
CreateHost
CreateHost creates a HostInfo from topology data. Returns nil if creation fails.
awssql/driver_infrastructure/topology_utils.go:49
↓ 2 callers
Method
CreateProps
(opts ...DriverPropertyOption)
awssql/driver_infrastructure/driver_dialect.go:65
↓ 2 callers
Method
CreateStandardContainer
CreateStandardContainer creates a fully-wired service container for normal connections.
awssql/services/factory.go:116
↓ 2 callers
Method
Dequeue
()
awssql/utils/rw_queue.go:38
↓ 2 callers
Method
Equals
(host *HostInfo)
awssql/host_info_util/host_info.go:112
↓ 2 callers
Method
FillAliases
(conn driver.Conn, hostInfo *host_info_util.HostInfo)
awssql/driver_infrastructure/plugin_helpers.go:80
↓ 2 callers
Method
ForceRefresh
============================================================================= HostListProvider Interface Implementation ==============================
awssql/driver_infrastructure/rds_host_list_provider.go:187
↓ 2 callers
Method
FormatIdpEndpoint
(endpoint string)
auth-helpers/credentials_provider_factory.go:75
↓ 2 callers
Method
GetAllowedHostIds
()
awssql/driver_infrastructure/allowed_and_blocked_hosts.go:51
↓ 2 callers
Method
GetAutoCommit
()
awssql/driver_infrastructure/session_state_service.go:86
↓ 2 callers
Method
GetBlockedHostIds
()
awssql/driver_infrastructure/allowed_and_blocked_hosts.go:55
↓ 2 callers
Method
GetCatalog
()
awssql/driver_infrastructure/session_state_service.go:172
↓ 2 callers
Method
GetConnectRoutings
()
awssql/driver_infrastructure/bg_helpers.go:179
↓ 2 callers
Method
GetConnectedIpAddress
()
awssql/plugins/bg/bg_status_monitor.go:552
↓ 2 callers
Method
GetCorrespondingHosts
()
awssql/plugins/bg/bg_test_helpers.go:231
↓ 2 callers
Method
GetErrorToRaise
(methodName string, methodArgs ...any)
awssql/plugins/error_simulator/error_simulator_method_callback.go:20
↓ 2 callers
Method
GetExecuteRoutings
()
awssql/driver_infrastructure/bg_helpers.go:183
↓ 2 callers
Method
GetFromMap
(props map[string]string)
awssql/property_util/aws_wrapper_property.go:68
↓ 2 callers
Method
GetHost
()
awssql/host_info_util/host_info.go:91
↓ 2 callers
Method
GetIntervalRate
()
awssql/plugins/bg/bg_status_monitor.go:232
↓ 2 callers
Method
GetName
()
awssql/driver_infrastructure/bg_helpers.go:93
↓ 2 callers
Method
GetPluginCode
()
awssql/driver_infrastructure/connection_plugin.go:41
↓ 2 callers
Method
GetProperties
()
awssql/driver_infrastructure/plugin_helpers.go:82
↓ 2 callers
Method
GetReadOnly
()
awssql/driver_infrastructure/session_state_service.go:129
↓ 2 callers
Method
GetReaderConnection
GetReaderConnection returns a new reader connection.
awssql/plugins/read_write_splitting/read_write_splitting_plugin.go:56
↓ 2 callers
Method
GetReaderHosts
(role driver_infrastructure.BlueGreenRole)
awssql/plugins/bg/bg_status_provider.go:341
↓ 2 callers
Method
GetRole
(hostInfo *host_info_util.HostInfo)
awssql/driver_infrastructure/bg_helpers.go:198
↓ 2 callers
Method
GetSchema
()
awssql/driver_infrastructure/session_state_service.go:215
↓ 2 callers
Function
GetSeparateSqlStatements
(query string)
awssql/utils/sql_method_utils.go:64
↓ 2 callers
Method
GetSetAutoCommitQuery
(autoCommit bool)
awssql/driver_infrastructure/database_dialect.go:36
↓ 2 callers
Method
GetSetCatalogQuery
(catalog string)
awssql/driver_infrastructure/database_dialect.go:38
↓ 2 callers
Method
GetSetReadOnlyQuery
(readOnly bool)
awssql/driver_infrastructure/database_dialect.go:37
↓ 2 callers
Method
GetSetSchemaQuery
(schema string)
awssql/driver_infrastructure/database_dialect.go:39
↓ 2 callers
Method
GetSetTransactionIsolationQuery
(level TransactionIsolationLevel)
awssql/driver_infrastructure/database_dialect.go:40
↓ 2 callers
Method
GetState
()
awssql/driver_infrastructure/monitor.go:46
↓ 2 callers
Method
GetStatusOfPost
()
awssql/plugins/bg/bg_status_provider.go:612
↓ 2 callers
Method
GetTransactionIsolation
()
awssql/driver_infrastructure/session_state_service.go:258
↓ 2 callers
Method
GetUrl
()
awssql/internal_pool/internal_pool_key.go:37
↓ 2 callers
Method
GetVerifiedConnection
( host string, isInitialConnection bool, hostListProviderService driver_infrastructure.HostListProviderServ
awssql/plugins/stale_dns_helper.go:44
↓ 2 callers
Method
GetWriterHost
(role driver_infrastructure.BlueGreenRole)
awssql/plugins/bg/bg_status_provider.go:333
↓ 2 callers
Method
HasCustomEndpointInfo
()
custom-endpoint/custom_endpoint_monitor.go:43
↓ 2 callers
Method
Init
()
awssql/driver_infrastructure/cluster_topology_monitor.go:694
↓ 2 callers
Method
InitHostProvider
(props *utils.RWMap[string, string], hostListProviderService HostListProviderService)
awssql/driver_infrastructure/plugin_helpers.go:102
↓ 2 callers
Method
InvalidateAllConnectionsMultipleHosts
(hosts ...string)
awssql/plugins/connection_tracker/opened_connection_tracker.go:90
↓ 2 callers
Method
InvalidateAllConnectionsMultipleHosts
(hosts ...string)
awssql/plugins/connection_tracker/connection_tracker.go:28
↓ 2 callers
Method
InvalidateCurrentConnection
()
awssql/plugins/failover_plugin.go:578
↓ 2 callers
Method
IsActive
()
awssql/plugins/efm/host_monitoring_service.go:240
↓ 2 callers
Method
IsActiveSwitchoverOrCompleted
()
awssql/driver_infrastructure/bg_helpers.go:101
↓ 2 callers
Method
IsAlreadySuccessfullyConnected
(connectHost string, iamHost string)
awssql/plugins/bg/bg_status_provider.go:772
↓ 2 callers
Method
IsDialect
(drv driver.Driver)
bun-pg-driver/bun_driver_dialect.go:57
↓ 2 callers
Method
IsDialectConfirmed
()
awssql/driver_infrastructure/plugin_helpers.go:77
↓ 2 callers
Function
IsDialectLimitless
(databaseDialect driver_infrastructure.DatabaseDialect)
awssql/plugins/limitless/limitless_utils.go:21
← previous
next →
201–300 of 1,810, ranked by callers