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
↓ 1 callers
Function
NewRWMap
()
awssql/utils/rw_map.go:27
↓ 1 callers
Function
NewRWMapFromCopy
(rwMap *RWMap[K, V])
awssql/utils/rw_map.go:40
↓ 1 callers
Function
NewRWMapFromMap
(mapForCache map[K]V)
awssql/utils/rw_map.go:47
↓ 1 callers
Function
NewRdsFailoverHandler
(plugin *FailoverPlugin)
awssql/plugins/failover_plugin.go:615
↓ 1 callers
Function
NewRejectConnectRouting
(hostAndPort string, role driver_infrastructure.BlueGreenRole)
awssql/plugins/bg/connect_routing.go:46
↓ 1 callers
Function
NewStaleDnsHelper
(pluginService driver_infrastructure.PluginService)
awssql/plugins/stale_dns_helper.go:36
↓ 1 callers
Method
OnConnect
OnConnect is called during Connect to allow strategy-specific initialization.
awssql/plugins/read_write_splitting/read_write_splitting_plugin.go:53
↓ 1 callers
Method
OpenConnection
()
awssql/plugins/bg/bg_status_monitor.go:477
↓ 1 callers
Function
OtelPostCopy
(telemetryCtx OpenTelemetryContext, traceLevel telemetry.TelemetryTraceLevel)
otlp/open_telemetry_context.go:89
↓ 1 callers
Function
ParseInstanceTemplates
ParseInstanceTemplates parses a comma-separated string of "[region]host:port" patterns into a map of region to HostInfo templates.
awssql/driver_infrastructure/topology_utils.go:673
↓ 1 callers
Method
PopulateOpenedConnectionQueue
(hostInfo *host_info_util.HostInfo, conn driver.Conn)
awssql/plugins/connection_tracker/connection_tracker.go:26
↓ 1 callers
Method
ProcessAndRemoveIf
ProcessAndRemoveIf executes the provided function on each key-value pair where the key satisfies the condition function. Matching entries are removed
awssql/utils/rw_map.go:169
↓ 1 callers
Method
ProcessEvent
(event Event)
awssql/driver_infrastructure/event.go:33
↓ 1 callers
Method
PruneNullConnections
()
awssql/plugins/connection_tracker/connection_tracker.go:30
↓ 1 callers
Method
Publish
(event Event)
awssql/driver_infrastructure/event.go:40
↓ 1 callers
Method
Put
(key string, value T, expiration time.Duration)
awssql/utils/cache_map.go:50
↓ 1 callers
Method
QueryForTopology
(conn driver.Conn)
awssql/driver_infrastructure/cluster_topology_monitor.go:96
↓ 1 callers
Method
QueryForTopology
(conn driver.Conn, initialHost *host_info_util.HostInfo, instanceTemplate *host_info_util.HostInfo)
awssql/driver_infrastructure/topology_utils.go:59
↓ 1 callers
Method
QueryForTopologyByRegion
QueryForTopologyByRegion fetches the current cluster topology using region-specific instance templates to resolve host endpoints for each region in th
awssql/driver_infrastructure/topology_utils.go:520
↓ 1 callers
Method
Refresh
()
awssql/driver_infrastructure/rds_host_list_provider.go:264
↓ 1 callers
Method
RefreshHostList
(conn driver.Conn)
awssql/plugin_helpers/plugin_service.go:393
↓ 1 callers
Method
Register
(s StorageService)
awssql/driver_infrastructure/storage_type_descriptor.go:100
↓ 1 callers
Method
RegisterIamHost
(connectHost string, iamHost string)
awssql/plugins/bg/bg_status_provider.go:740
↓ 1 callers
Method
RegisterMonitorType
RegisterMonitorType registers a new monitor type with the service.
awssql/services/monitor.go:115
↓ 1 callers
Method
RemoveExpiredEntries
RemoveExpiredEntries removes all expired entries.
awssql/utils/expiration_cache.go:187
↓ 1 callers
Method
ReplaceCacheWithCopy
(mapToCopy *RWMap[K, V])
awssql/utils/rw_map.go:140
↓ 1 callers
Method
ReplaceCacheWithMap
(entryMap map[K]V)
awssql/utils/rw_map.go:145
↓ 1 callers
Method
RequestCustomEndpointInfoUpdate
()
custom-endpoint/custom_endpoint_monitor.go:44
↓ 1 callers
Method
RequestCustomEndpointInfoUpdate
RequestCustomEndpointInfoUpdate requests the monitor to refresh custom endpoint info.
custom-endpoint/custom_endpoint_monitor.go:280
↓ 1 callers
Method
ResetContextWhenCompleted
()
awssql/plugins/bg/bg_status_provider.go:824
↓ 1 callers
Method
ResetValue
()
awssql/driver_infrastructure/session_state.go:34
↓ 1 callers
Method
SetAutoCommit
(bool)
awssql/driver_infrastructure/session_state_service.go:30
↓ 1 callers
Method
SetCatalog
(string)
awssql/driver_infrastructure/session_state_service.go:40
↓ 1 callers
Method
SetError
(err error)
otlp/open_telemetry_context.go:141
↓ 1 callers
Method
SetError
(err error)
xray/xray_telemetry_context.go:121
↓ 1 callers
Method
SetHostListProvider
(hostListProvider driver_infrastructure.HostListProvider)
awssql/plugin_helpers/plugin_service.go:87
↓ 1 callers
Method
SetHostListProvider
(hostListProvider HostListProvider)
awssql/driver_infrastructure/plugin_helpers.go:64
↓ 1 callers
Method
SetHostUnhealthy
(hostUnhealthy bool)
awssql/plugins/efm/host_monitoring_service.go:210
↓ 1 callers
Method
SetInTransaction
(inTransaction bool)
awssql/plugin_helpers/plugin_service.go:385
↓ 1 callers
Method
SetReadOnly
(bool)
awssql/driver_infrastructure/session_state_service.go:35
↓ 1 callers
Method
SetSchema
(string)
awssql/driver_infrastructure/session_state_service.go:45
↓ 1 callers
Method
SetTransactionIsolation
(level TransactionIsolationLevel)
awssql/driver_infrastructure/session_state_service.go:50
↓ 1 callers
Method
SetupPristineAutoCommit
()
awssql/driver_infrastructure/session_state_service.go:31
↓ 1 callers
Method
SetupPristineAutoCommit
()
awssql/driver_infrastructure/session_state_service.go:97
↓ 1 callers
Method
SetupPristineCatalog
()
awssql/driver_infrastructure/session_state_service.go:41
↓ 1 callers
Method
SetupPristineCatalog
()
awssql/driver_infrastructure/session_state_service.go:183
↓ 1 callers
Method
SetupPristineReadOnly
()
awssql/driver_infrastructure/session_state_service.go:36
↓ 1 callers
Method
SetupPristineReadOnly
()
awssql/driver_infrastructure/session_state_service.go:140
↓ 1 callers
Method
SetupPristineSchema
()
awssql/driver_infrastructure/session_state_service.go:46
↓ 1 callers
Method
SetupPristineSchema
()
awssql/driver_infrastructure/session_state_service.go:226
↓ 1 callers
Method
SetupPristineTransactionIsolation
()
awssql/driver_infrastructure/session_state_service.go:51
↓ 1 callers
Method
SetupPristineTransactionIsolation
()
awssql/driver_infrastructure/session_state_service.go:269
↓ 1 callers
Method
ShouldAbort
()
awssql/plugins/efm/host_monitoring_service.go:224
↓ 1 callers
Method
StartMonitoring
(hostInfo *host_info_util.HostInfo, props *utils.RWMap[string, string], intervalMs int)
awssql/plugins/limitless/limitless_router_service.go:37
↓ 1 callers
Method
StartMonitoring
(state *MonitorConnectionState)
awssql/plugins/efm/host_monitor.go:43
↓ 1 callers
Method
StartMonitoring
(conn *driver.Conn, hostInfo *host_info_util.HostInfo, props *utils.RWMap[string, string])
awssql/plugins/efm/host_monitoring_service.go:40
↓ 1 callers
Method
StartSwitchoverTimer
()
awssql/plugins/bg/bg_status_provider.go:814
↓ 1 callers
Method
StopAndRemove
StopAndRemove stops and removes a specific monitor.
awssql/services/monitor.go:203
↓ 1 callers
Method
StopAndRemove
(monitorType *MonitorType, key any)
awssql/driver_infrastructure/monitor.go:72
↓ 1 callers
Method
StopAndRemoveAll
StopAndRemoveAll stops all monitors and removes them.
awssql/services/monitor.go:232
↓ 1 callers
Method
StopMonitoring
(state *MonitorConnectionState, connToAbort driver.Conn)
awssql/plugins/efm/host_monitoring_service.go:41
↓ 1 callers
Method
StoreBlueDnsUpdateTime
()
awssql/plugins/bg/bg_status_provider.go:798
↓ 1 callers
Method
StoreGreenDnsRemoveTime
()
awssql/plugins/bg/bg_status_provider.go:802
↓ 1 callers
Method
StoreGreenHostChangeNameTime
()
awssql/plugins/bg/bg_status_provider.go:806
↓ 1 callers
Method
StoreGreenTopologyChangeTime
()
awssql/plugins/bg/bg_status_provider.go:810
↓ 1 callers
Method
StorePhaseTime
(phase driver_infrastructure.BlueGreenPhase)
awssql/plugins/bg/bg_status_provider.go:781
↓ 1 callers
Method
String
()
awssql/internal_pool/internal_pool_key.go:49
↓ 1 callers
Function
SupportsSocketTimeoutViaDsn
============================================================================= Driver Dialect Helper Functions ========================================
awssql/driver_infrastructure/driver_dialect.go:84
↓ 1 callers
Method
UpdateDialect
(conn driver.Conn)
awssql/driver_infrastructure/plugin_helpers.go:76
↓ 1 callers
Method
UpdateHostHealthStatus
(connIsValid bool, statusCheckStartTime time.Time, statusCheckEndTime time.Time)
awssql/plugins/efm/host_monitor.go:245
↓ 1 callers
Method
UpdateIpAddressFlags
()
awssql/plugins/bg/bg_status_monitor.go:249
↓ 1 callers
Method
UpdateMonitors
()
awssql/plugins/bg/bg_status_provider.go:375
↓ 1 callers
Method
UpdatePhase
(role driver_infrastructure.BlueGreenRole, interimStatus BlueGreenInterimStatus)
awssql/plugins/bg/bg_status_provider.go:215
↓ 1 callers
Method
UpdateSummaryStatus
(role driver_infrastructure.BlueGreenRole, interimStatus BlueGreenInterimStatus)
awssql/plugins/bg/bg_status_provider.go:349
↓ 1 callers
Function
XRayPostCopy
(telemetryCtx XRayTelemetryContext, traceLevel telemetry.TelemetryTraceLevel)
xray/xray_telemetry_context.go:78
↓ 1 callers
Method
add
(subscriber driver_infrastructure.EventSubscriber)
awssql/services/events.go:93
↓ 1 callers
Method
blueHostInCorrespondingHosts
(host string, role driver_infrastructure.BlueGreenRole)
awssql/plugins/bg/bg_status_provider.go:993
↓ 1 callers
Function
calculateBackoffWithJitter
calculateBackoffWithJitter returns an exponential backoff duration with jitter. backoff = min(initialBackoffMs * 2^min(attempt, 6), maxBackoffMs) * ra
awssql/driver_infrastructure/cluster_topology_monitor.go:401
↓ 1 callers
Method
canDirectExecute
(methodName string)
awssql/plugins/failover_plugin.go:291
↓ 1 callers
Method
checkForStableReaderTopologies
checkForStableReaderTopologies checks whether all host monitoring routines (readers) report the same topology. If they agree for stableTopologiesDurat
awssql/driver_infrastructure/cluster_topology_monitor.go:334
↓ 1 callers
Method
checkHostIsSet
()
awssql/host_info_util/host_info.go:241
↓ 1 callers
Method
checkMonitors
()
awssql/services/monitor.go:263
↓ 1 callers
Method
checkWriterChanged
()
awssql/plugins/aurora_connection_tracker.go:139
↓ 1 callers
Method
cleanupExpiredItems
(ctx context.Context)
awssql/utils/sliding_expiration_cache.go:227
↓ 1 callers
Method
cleanupLoop
()
awssql/services/storage.go:212
↓ 1 callers
Method
cleanupLoop
()
awssql/services/monitor.go:249
↓ 1 callers
Method
clearWithDisposalFunc
()
awssql/utils/rw_map.go:119
↓ 1 callers
Method
compare
(connA driver.Conn, hostInfoA *host_info_util.HostInfo, connB driver.Conn, hostInfoB *host_info_util.HostInfo
awssql/plugin_helpers/plugin_service.go:208
↓ 1 callers
Function
convertMethodArgsToString
(methodArgs ...any)
examples/dev_plugin_mysql_example.go:44
↓ 1 callers
Function
convertMethodArgsToString
(methodArgs ...any)
examples/dev_plugin_postgres_example.go:44
↓ 1 callers
Method
createCacheEntryForHosts
(hosts []*host_info_util.HostInfo, props map[string]string)
awssql/driver_infrastructure/round_robin_host_selector.go:125
↓ 1 callers
Method
createHostFromRow
createHostFromRow: server_id (0), is_writer (1), cpu (2), lag (3), last_update_timestamp (4).
awssql/driver_infrastructure/topology_utils.go:299
↓ 1 callers
Method
createHostFromRow
createHostFromRow: id (0), endpoint (1), port (2).
awssql/driver_infrastructure/topology_utils.go:455
↓ 1 callers
Method
createHostFromRow
createHostFromRow: server_id (0), is_writer (1), visibility_lag_in_msec (2), aws_region (3).
awssql/driver_infrastructure/topology_utils.go:586
↓ 1 callers
Function
doesStatementCloseTransaction
(statements []string)
awssql/utils/sql_method_utils.go:121
↓ 1 callers
Function
doesStatementStartTransaction
(statements []string)
awssql/utils/sql_method_utils.go:111
↓ 1 callers
Method
execContextInternal
(ctx context.Context, query string, args []driver.NamedValue)
awssql/driver/driver.go:283
↓ 1 callers
Method
failover
()
awssql/plugins/failover_plugin.go:639
↓ 1 callers
Method
failover
()
awssql/plugins/gdb_failover_plugin.go:190
↓ 1 callers
Function
failoverModeFromValue
(mode string)
awssql/plugins/failover_plugin.go:45
← previous
next →
601–700 of 1,810, ranked by callers