MCPcopy Create free account

hub / github.com/aws/aws-advanced-go-wrapper / functions

Functions1,810 in github.com/aws/aws-advanced-go-wrapper

↓ 1 callersFunctionNewRWMap
()
awssql/utils/rw_map.go:27
↓ 1 callersFunctionNewRWMapFromCopy
(rwMap *RWMap[K, V])
awssql/utils/rw_map.go:40
↓ 1 callersFunctionNewRWMapFromMap
(mapForCache map[K]V)
awssql/utils/rw_map.go:47
↓ 1 callersFunctionNewRdsFailoverHandler
(plugin *FailoverPlugin)
awssql/plugins/failover_plugin.go:615
↓ 1 callersFunctionNewRejectConnectRouting
(hostAndPort string, role driver_infrastructure.BlueGreenRole)
awssql/plugins/bg/connect_routing.go:46
↓ 1 callersFunctionNewStaleDnsHelper
(pluginService driver_infrastructure.PluginService)
awssql/plugins/stale_dns_helper.go:36
↓ 1 callersMethodOnConnect
OnConnect is called during Connect to allow strategy-specific initialization.
awssql/plugins/read_write_splitting/read_write_splitting_plugin.go:53
↓ 1 callersMethodOpenConnection
()
awssql/plugins/bg/bg_status_monitor.go:477
↓ 1 callersFunctionOtelPostCopy
(telemetryCtx OpenTelemetryContext, traceLevel telemetry.TelemetryTraceLevel)
otlp/open_telemetry_context.go:89
↓ 1 callersFunctionParseInstanceTemplates
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 callersMethodPopulateOpenedConnectionQueue
(hostInfo *host_info_util.HostInfo, conn driver.Conn)
awssql/plugins/connection_tracker/connection_tracker.go:26
↓ 1 callersMethodProcessAndRemoveIf
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 callersMethodProcessEvent
(event Event)
awssql/driver_infrastructure/event.go:33
↓ 1 callersMethodPruneNullConnections
()
awssql/plugins/connection_tracker/connection_tracker.go:30
↓ 1 callersMethodPublish
(event Event)
awssql/driver_infrastructure/event.go:40
↓ 1 callersMethodPut
(key string, value T, expiration time.Duration)
awssql/utils/cache_map.go:50
↓ 1 callersMethodQueryForTopology
(conn driver.Conn)
awssql/driver_infrastructure/cluster_topology_monitor.go:96
↓ 1 callersMethodQueryForTopology
(conn driver.Conn, initialHost *host_info_util.HostInfo, instanceTemplate *host_info_util.HostInfo)
awssql/driver_infrastructure/topology_utils.go:59
↓ 1 callersMethodQueryForTopologyByRegion
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 callersMethodRefresh
()
awssql/driver_infrastructure/rds_host_list_provider.go:264
↓ 1 callersMethodRefreshHostList
(conn driver.Conn)
awssql/plugin_helpers/plugin_service.go:393
↓ 1 callersMethodRegister
(s StorageService)
awssql/driver_infrastructure/storage_type_descriptor.go:100
↓ 1 callersMethodRegisterIamHost
(connectHost string, iamHost string)
awssql/plugins/bg/bg_status_provider.go:740
↓ 1 callersMethodRegisterMonitorType
RegisterMonitorType registers a new monitor type with the service.
awssql/services/monitor.go:115
↓ 1 callersMethodRemoveExpiredEntries
RemoveExpiredEntries removes all expired entries.
awssql/utils/expiration_cache.go:187
↓ 1 callersMethodReplaceCacheWithCopy
(mapToCopy *RWMap[K, V])
awssql/utils/rw_map.go:140
↓ 1 callersMethodReplaceCacheWithMap
(entryMap map[K]V)
awssql/utils/rw_map.go:145
↓ 1 callersMethodRequestCustomEndpointInfoUpdate
()
custom-endpoint/custom_endpoint_monitor.go:44
↓ 1 callersMethodRequestCustomEndpointInfoUpdate
RequestCustomEndpointInfoUpdate requests the monitor to refresh custom endpoint info.
custom-endpoint/custom_endpoint_monitor.go:280
↓ 1 callersMethodResetContextWhenCompleted
()
awssql/plugins/bg/bg_status_provider.go:824
↓ 1 callersMethodResetValue
()
awssql/driver_infrastructure/session_state.go:34
↓ 1 callersMethodSetAutoCommit
(bool)
awssql/driver_infrastructure/session_state_service.go:30
↓ 1 callersMethodSetCatalog
(string)
awssql/driver_infrastructure/session_state_service.go:40
↓ 1 callersMethodSetError
(err error)
otlp/open_telemetry_context.go:141
↓ 1 callersMethodSetError
(err error)
xray/xray_telemetry_context.go:121
↓ 1 callersMethodSetHostListProvider
(hostListProvider driver_infrastructure.HostListProvider)
awssql/plugin_helpers/plugin_service.go:87
↓ 1 callersMethodSetHostListProvider
(hostListProvider HostListProvider)
awssql/driver_infrastructure/plugin_helpers.go:64
↓ 1 callersMethodSetHostUnhealthy
(hostUnhealthy bool)
awssql/plugins/efm/host_monitoring_service.go:210
↓ 1 callersMethodSetInTransaction
(inTransaction bool)
awssql/plugin_helpers/plugin_service.go:385
↓ 1 callersMethodSetReadOnly
(bool)
awssql/driver_infrastructure/session_state_service.go:35
↓ 1 callersMethodSetSchema
(string)
awssql/driver_infrastructure/session_state_service.go:45
↓ 1 callersMethodSetTransactionIsolation
(level TransactionIsolationLevel)
awssql/driver_infrastructure/session_state_service.go:50
↓ 1 callersMethodSetupPristineAutoCommit
()
awssql/driver_infrastructure/session_state_service.go:31
↓ 1 callersMethodSetupPristineAutoCommit
()
awssql/driver_infrastructure/session_state_service.go:97
↓ 1 callersMethodSetupPristineCatalog
()
awssql/driver_infrastructure/session_state_service.go:41
↓ 1 callersMethodSetupPristineCatalog
()
awssql/driver_infrastructure/session_state_service.go:183
↓ 1 callersMethodSetupPristineReadOnly
()
awssql/driver_infrastructure/session_state_service.go:36
↓ 1 callersMethodSetupPristineReadOnly
()
awssql/driver_infrastructure/session_state_service.go:140
↓ 1 callersMethodSetupPristineSchema
()
awssql/driver_infrastructure/session_state_service.go:46
↓ 1 callersMethodSetupPristineSchema
()
awssql/driver_infrastructure/session_state_service.go:226
↓ 1 callersMethodSetupPristineTransactionIsolation
()
awssql/driver_infrastructure/session_state_service.go:51
↓ 1 callersMethodSetupPristineTransactionIsolation
()
awssql/driver_infrastructure/session_state_service.go:269
↓ 1 callersMethodShouldAbort
()
awssql/plugins/efm/host_monitoring_service.go:224
↓ 1 callersMethodStartMonitoring
(hostInfo *host_info_util.HostInfo, props *utils.RWMap[string, string], intervalMs int)
awssql/plugins/limitless/limitless_router_service.go:37
↓ 1 callersMethodStartMonitoring
(state *MonitorConnectionState)
awssql/plugins/efm/host_monitor.go:43
↓ 1 callersMethodStartMonitoring
(conn *driver.Conn, hostInfo *host_info_util.HostInfo, props *utils.RWMap[string, string])
awssql/plugins/efm/host_monitoring_service.go:40
↓ 1 callersMethodStartSwitchoverTimer
()
awssql/plugins/bg/bg_status_provider.go:814
↓ 1 callersMethodStopAndRemove
StopAndRemove stops and removes a specific monitor.
awssql/services/monitor.go:203
↓ 1 callersMethodStopAndRemove
(monitorType *MonitorType, key any)
awssql/driver_infrastructure/monitor.go:72
↓ 1 callersMethodStopAndRemoveAll
StopAndRemoveAll stops all monitors and removes them.
awssql/services/monitor.go:232
↓ 1 callersMethodStopMonitoring
(state *MonitorConnectionState, connToAbort driver.Conn)
awssql/plugins/efm/host_monitoring_service.go:41
↓ 1 callersMethodStoreBlueDnsUpdateTime
()
awssql/plugins/bg/bg_status_provider.go:798
↓ 1 callersMethodStoreGreenDnsRemoveTime
()
awssql/plugins/bg/bg_status_provider.go:802
↓ 1 callersMethodStoreGreenHostChangeNameTime
()
awssql/plugins/bg/bg_status_provider.go:806
↓ 1 callersMethodStoreGreenTopologyChangeTime
()
awssql/plugins/bg/bg_status_provider.go:810
↓ 1 callersMethodStorePhaseTime
(phase driver_infrastructure.BlueGreenPhase)
awssql/plugins/bg/bg_status_provider.go:781
↓ 1 callersMethodString
()
awssql/internal_pool/internal_pool_key.go:49
↓ 1 callersFunctionSupportsSocketTimeoutViaDsn
============================================================================= Driver Dialect Helper Functions ========================================
awssql/driver_infrastructure/driver_dialect.go:84
↓ 1 callersMethodUpdateDialect
(conn driver.Conn)
awssql/driver_infrastructure/plugin_helpers.go:76
↓ 1 callersMethodUpdateHostHealthStatus
(connIsValid bool, statusCheckStartTime time.Time, statusCheckEndTime time.Time)
awssql/plugins/efm/host_monitor.go:245
↓ 1 callersMethodUpdateIpAddressFlags
()
awssql/plugins/bg/bg_status_monitor.go:249
↓ 1 callersMethodUpdateMonitors
()
awssql/plugins/bg/bg_status_provider.go:375
↓ 1 callersMethodUpdatePhase
(role driver_infrastructure.BlueGreenRole, interimStatus BlueGreenInterimStatus)
awssql/plugins/bg/bg_status_provider.go:215
↓ 1 callersMethodUpdateSummaryStatus
(role driver_infrastructure.BlueGreenRole, interimStatus BlueGreenInterimStatus)
awssql/plugins/bg/bg_status_provider.go:349
↓ 1 callersFunctionXRayPostCopy
(telemetryCtx XRayTelemetryContext, traceLevel telemetry.TelemetryTraceLevel)
xray/xray_telemetry_context.go:78
↓ 1 callersMethodadd
(subscriber driver_infrastructure.EventSubscriber)
awssql/services/events.go:93
↓ 1 callersMethodblueHostInCorrespondingHosts
(host string, role driver_infrastructure.BlueGreenRole)
awssql/plugins/bg/bg_status_provider.go:993
↓ 1 callersFunctioncalculateBackoffWithJitter
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 callersMethodcanDirectExecute
(methodName string)
awssql/plugins/failover_plugin.go:291
↓ 1 callersMethodcheckForStableReaderTopologies
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 callersMethodcheckHostIsSet
()
awssql/host_info_util/host_info.go:241
↓ 1 callersMethodcheckMonitors
()
awssql/services/monitor.go:263
↓ 1 callersMethodcheckWriterChanged
()
awssql/plugins/aurora_connection_tracker.go:139
↓ 1 callersMethodcleanupExpiredItems
(ctx context.Context)
awssql/utils/sliding_expiration_cache.go:227
↓ 1 callersMethodcleanupLoop
()
awssql/services/storage.go:212
↓ 1 callersMethodcleanupLoop
()
awssql/services/monitor.go:249
↓ 1 callersMethodclearWithDisposalFunc
()
awssql/utils/rw_map.go:119
↓ 1 callersMethodcompare
(connA driver.Conn, hostInfoA *host_info_util.HostInfo, connB driver.Conn, hostInfoB *host_info_util.HostInfo
awssql/plugin_helpers/plugin_service.go:208
↓ 1 callersFunctionconvertMethodArgsToString
(methodArgs ...any)
examples/dev_plugin_mysql_example.go:44
↓ 1 callersFunctionconvertMethodArgsToString
(methodArgs ...any)
examples/dev_plugin_postgres_example.go:44
↓ 1 callersMethodcreateCacheEntryForHosts
(hosts []*host_info_util.HostInfo, props map[string]string)
awssql/driver_infrastructure/round_robin_host_selector.go:125
↓ 1 callersMethodcreateHostFromRow
createHostFromRow: server_id (0), is_writer (1), cpu (2), lag (3), last_update_timestamp (4).
awssql/driver_infrastructure/topology_utils.go:299
↓ 1 callersMethodcreateHostFromRow
createHostFromRow: id (0), endpoint (1), port (2).
awssql/driver_infrastructure/topology_utils.go:455
↓ 1 callersMethodcreateHostFromRow
createHostFromRow: server_id (0), is_writer (1), visibility_lag_in_msec (2), aws_region (3).
awssql/driver_infrastructure/topology_utils.go:586
↓ 1 callersFunctiondoesStatementCloseTransaction
(statements []string)
awssql/utils/sql_method_utils.go:121
↓ 1 callersFunctiondoesStatementStartTransaction
(statements []string)
awssql/utils/sql_method_utils.go:111
↓ 1 callersMethodexecContextInternal
(ctx context.Context, query string, args []driver.NamedValue)
awssql/driver/driver.go:283
↓ 1 callersMethodfailover
()
awssql/plugins/failover_plugin.go:639
↓ 1 callersMethodfailover
()
awssql/plugins/gdb_failover_plugin.go:190
↓ 1 callersFunctionfailoverModeFromValue
(mode string)
awssql/plugins/failover_plugin.go:45
← previousnext →601–700 of 1,810, ranked by callers