MCPcopy Create free account

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

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

⨍ Functions 1,810◇ Types & classes 307
↓ 1 callersMethodfailoverToWriter
(writerCandidate *host_info_util.HostInfo, ctx context.Context)
awssql/plugins/gdb_failover_plugin.go:330
↓ 1 callersMethodfetchLatestCredentials
( hostInfo *host_info_util.HostInfo, props *utils.RWMap[string, string])
aws-secrets-manager/aws_secrets_manager_connection_plugin.go:250
↓ 1 callersMethodfindWriterClusterArn
(globalClusterIdentifier string)
auth-helpers/gdb_region_util.go:98
↓ 1 callersMethodforEach
(fn func(driver_infrastructure.EventSubscriber))
awssql/services/events.go:111
↓ 1 callersMethodgetAllowedFailoverConnection
( allowedHostsFunc func() []*host_info_util.HostInfo, verifyRole host_info_util.HostRole, failoverEnd time.
awssql/plugins/gdb_failover_plugin.go:404
↓ 1 callersMethodgetBgStatusCacheKey
()
awssql/plugins/bg/bg_plugin.go:98
↓ 1 callersMethodgetBlueGreenStatus
(conn driver.Conn)
awssql/plugins/bg/bg_status_monitor.go:182
↓ 1 callersFunctiongetCacheKey
( secretId string, region string, )
aws-secrets-manager/aws_secrets_manager_connection_util.go:39
↓ 1 callersMethodgetContextHash
()
awssql/plugins/bg/bg_status_provider.go:777
↓ 1 callersFunctiongetDomainGroup
(host string)
awssql/utils/rds_utils.go:243
↓ 1 callersFunctiongetFactoryOrder
(pluginFactoryFuncWeights []driver_infrastructure.ConnectionPlugin)
awssql/driver/connection_plugin_chain_builder.go:127
↓ 1 callersMethodgetFormActionUrl
(props *utils.RWMap[string, string], action string)
federated-auth/adfs_credentials_provider_factory.go:149
↓ 1 callersFunctiongetGlobalClusterId
(host string)
auth-helpers/gdb_region_util.go:119
↓ 1 callersMethodgetHostNamesString
()
awssql/plugins/bg/bg_interim_status.go:127
↓ 1 callersMethodgetInstanceTemplate
(instanceId string, conn driver.Conn)
awssql/driver_infrastructure/cluster_topology_monitor.go:560
↓ 1 callersFunctiongetLocalizer
()
awssql/error_util/aws_wrapper_messages.go:34
↓ 1 callersMethodgetMonitor
(hostInfo *host_info_util.HostInfo, props *utils.RWMap[string, string])
awssql/plugins/efm/host_monitoring_service.go:140
↓ 1 callersMethodgetMonitoringHostInfo
()
awssql/plugins/efm/host_monitoring_plugin.go:149
↓ 1 callersFunctiongetMonitoringProps
(props *utils.RWMap[string, string], resolver DriverPropertyResolver)
awssql/driver_infrastructure/rds_host_list_provider.go:130
↓ 1 callersMethodgetNewReaderConnection
(hosts []*host_info_util.HostInfo)
awssql/plugins/read_write_splitting/read_write_splitting_plugin.go:407
↓ 1 callersMethodgetPoolKey
(hostInfo *host_info_util.HostInfo, props map[string]string)
awssql/internal_pool/internal_pooled_connection_provider.go:127
↓ 1 callersFunctiongetRdsSecretFromAwsSecretsManager
( hostInfo *host_info_util.HostInfo, props *utils.RWMap[string, string], endpoint string, region string,
aws-secrets-manager/aws_secrets_manager_connection_util.go:46
↓ 1 callersMethodgetReader
(props *utils.RWMap[string, string], awsRegion string)
awssql/plugins/aurora_initial_connection_strategy_plugin.go:368
↓ 1 callersMethodgetReaderFailoverConnection
(endTime time.Time)
awssql/plugins/failover_plugin.go:472
↓ 1 callersMethodgetSamlAssertionFromPost
(uri string, params map[string]string, props *utils.RWMap[string, string])
federated-auth/adfs_credentials_provider_factory.go:156
↓ 1 callersFunctiongetSamlUrl
(props *utils.RWMap[string, string])
okta/okta_credentials_provider_factory.go:199
↓ 1 callersMethodgetStoredHosts
()
awssql/driver_infrastructure/rds_host_list_provider.go:328
↓ 1 callersMethodgetTopology
============================================================================= Internal Helpers =======================================================
awssql/driver_infrastructure/rds_host_list_provider.go:299
↓ 1 callersMethodgetUniqueIpAddresses
()
awssql/plugins/bg/bg_status_provider.go:594
↓ 1 callersMethodgetVerifiedReaderConnection
( urlType utils.RdsUrlType, host *host_info_util.HostInfo, props *utils.RWMap[string, string], isInitialCo
awssql/plugins/aurora_initial_connection_strategy_plugin.go:227
↓ 1 callersMethodgetVerifiedWriterConnection
( props *utils.RWMap[string, string], isInitialConnection bool, connectFunc driver_infrastructure.ConnectFu
awssql/plugins/aurora_initial_connection_strategy_plugin.go:149
↓ 1 callersMethodgetWriterId
(conn driver.Conn)
awssql/driver_infrastructure/topology_utils.go:422
↓ 1 callersMethodhandleMonitorError
(container *cacheContainer, key any, errorItem *monitorItem)
awssql/services/monitor.go:300
↓ 1 callersMethodinitGlobal
()
awssql/driver_infrastructure/global_aurora_host_list_provider.go:79
↓ 1 callersMethodinitLimitlessRouterService
()
awssql/plugins/limitless/limitless_plugin.go:138
↓ 1 callersMethodinitMonitorService
()
awssql/plugins/efm/host_monitoring_plugin.go:138
↓ 1 callersMethodinitMonitoring
()
awssql/plugins/bg/bg_status_provider.go:129
↓ 1 callersMethodinvalidateConnections
(connectionQueue *utils.RWQueue[weak.Pointer[driver.Conn]])
awssql/plugins/connection_tracker/opened_connection_tracker.go:111
↓ 1 callersMethodisConnExpired
(pc *internalPooledConn, now time.Time)
awssql/internal_pool/internal_conn_pool.go:203
↓ 1 callersMethodisEmpty
()
awssql/services/events.go:105
↓ 1 callersMethodisFailoverEnabled
()
awssql/plugins/failover_plugin.go:287
↓ 1 callersFunctionisIPOnly
(host string)
awssql/property_util/dsn_parser.go:282
↓ 1 callersMethodisInPanicMode
()
awssql/driver_infrastructure/cluster_topology_monitor.go:640
↓ 1 callersMethodisZero
()
awssql/plugins/bg/bg_status_provider.go:989
↓ 1 callersMethodlogConnectionQueue
(host string, queue *utils.RWQueue[weak.Pointer[driver.Conn]])
awssql/plugins/connection_tracker/opened_connection_tracker.go:133
↓ 1 callersFunctionmapLimitlessQueryRowsToHostInfoList
(rows driver.Rows, hostPortToMap int)
awssql/plugins/limitless/limitless_query_helper.go:84
↓ 1 callersFunctionmapLimitlessRouterLoadToHostInfoWeight
(hostName string, routerLoad float64)
awssql/plugins/limitless/limitless_query_helper.go:124
↓ 1 callersFunctionmapToBlueGreenIntervalRate
(value int32)
awssql/plugins/bg/bg_status_monitor.go:236
↓ 1 callersFunctionmaskSensitiveInfoFromMySQL
(dsn string)
awssql/property_util/mask_helper.go:104
↓ 1 callersFunctionmaskSensitiveInfoFromPgxKeywordValue
(dsn string)
awssql/property_util/mask_helper.go:42
↓ 1 callersFunctionmaskSensitiveInfoFromPgxUrl
(dsn string)
awssql/property_util/mask_helper.go:76
↓ 1 callersFunctionnewGlobalDbFailoverHandler
(plugin *FailoverPlugin)
awssql/plugins/gdb_failover_plugin.go:107
↓ 1 callersFunctionnewHostInfo
(t *testing.T, host string, port int)
bun-pg-driver/prepare_dsn_test.go:30
↓ 1 callersMethodnewStateRun
()
awssql/plugins/efm/host_monitor.go:147
↓ 1 callersFunctionnewSubscriberSet
()
awssql/services/events.go:87
↓ 1 callersMethodopenAnyConnectionAndUpdateTopology
()
awssql/driver_infrastructure/cluster_topology_monitor.go:591
↓ 1 callersMethodopenConnection
()
awssql/plugins/limitless/limitless_router_monitor.go:196
↓ 1 callersFunctionparseDSNParams
(properties *utils.RWMap[string, string], params string)
awssql/property_util/dsn_parser.go:425
↓ 1 callersFunctionparseHostPortPairWithRegionPrefix
(urlWithRegionPrefix string, defaultPort int)
awssql/driver_infrastructure/topology_utils.go:697
↓ 1 callersFunctionparseMySqlDsn
(dsn string)
awssql/property_util/dsn_parser.go:367
↓ 1 callersFunctionparsePgxKeywordValueSettings
(dsn string)
awssql/property_util/dsn_parser.go:288
↓ 1 callersFunctionparsePgxURLSettings
(connString string)
awssql/property_util/dsn_parser.go:213
↓ 1 callersMethodpublishingLoop
()
awssql/services/events.go:194
↓ 1 callersFunctionqueryWithFailoverHandling
(db *sql.DB, query string)
examples/aws_failover_postgresql_example.go:99
↓ 1 callersFunctionqueryWithFailoverHandling
(db *sql.DB, query string)
examples/read_write_splitting_mysql_example.go:118
↓ 1 callersFunctionqueryWithFailoverHandling
(db *sql.DB, query string)
examples/read_write_splitting_postgresql_example.go:118
↓ 1 callersFunctionqueryWithFailoverHandling
(db *sql.DB, query string)
examples/aws_failover_mysql_example.go:99
↓ 1 callersMethodraiseErrorIfNeeded
(methodName string, methodArgs ...any)
awssql/plugins/developer_connection_plugin.go:96
↓ 1 callersMethodraiseErrorOnConnectIfNeeded
( hostInfo *host_info_util.HostInfo, props *utils.RWMap[string, string], isInitialConnection bool)
awssql/plugins/developer_connection_plugin.go:131
↓ 1 callersMethodregister
register is the internal registration method.
awssql/services/storage.go:66
↓ 1 callersMethodrememberWriter
()
awssql/plugins/aurora_connection_tracker.go:132
↓ 1 callersMethodremove
(subscriber driver_infrastructure.EventSubscriber)
awssql/services/events.go:99
↓ 1 callersMethodremoveExpiredItems
()
awssql/services/storage.go:226
↓ 1 callersMethodreset
reset resets the monitor state, clearing the monitoring connection and failure tracking. This is called when a MonitorResetEvent is received for this
awssql/plugins/efm/host_monitor.go:341
↓ 1 callersMethodreset
reset resets the monitor state, clearing all connections and cached data. This is called when a MonitorResetEvent is received for this cluster.
awssql/driver_infrastructure/cluster_topology_monitor.go:411
↓ 1 callersMethodrun
()
awssql/driver_infrastructure/cluster_topology_monitor.go:698
↓ 1 callersMethodrunMonitoringLoop
()
awssql/plugins/bg/bg_status_monitor.go:108
↓ 1 callersMethodsendPendingEvents
()
awssql/services/events.go:208
↓ 1 callersFunctionstartsWithPrefix
(key string)
awssql/property_util/aws_wrapper_property.go:921
↓ 1 callersFunctionstringSliceToSetMap
(stringSlice []string)
custom-endpoint/custom_endpoint_info.go:105
↓ 1 callersMethodswitchConnectionIfRequired
(readOnly bool)
awssql/plugins/read_write_splitting/read_write_splitting_plugin.go:249
↓ 1 callersMethodswitchToReaderConnection
(hosts []*host_info_util.HostInfo)
awssql/plugins/read_write_splitting/read_write_splitting_plugin.go:308
↓ 1 callersMethodswitchToWriterConnection
(hosts []*host_info_util.HostInfo)
awssql/plugins/read_write_splitting/read_write_splitting_plugin.go:341
↓ 1 callersMethodsynchronousGetLimitlessRouter
(context *LimitlessConnectionContext)
awssql/plugins/limitless/limitless_router_service.go:188
↓ 1 callersMethodupdateCachePropertiesForRoundRobinClusterInfo
( roundRobinClusterInfo *RoundRobinClusterInfo, props map[string]string)
awssql/driver_infrastructure/round_robin_host_selector.go:181
↓ 1 callersMethodupdateCorrespondingHosts
()
awssql/plugins/bg/bg_status_provider.go:253
↓ 1 callersMethodupdateInternalConnectionInfo
()
awssql/plugins/read_write_splitting/read_write_splitting_plugin.go:192
↓ 1 callersMethodupdateStatusCache
()
awssql/plugins/bg/bg_status_provider.go:243
↓ 1 callersFunctionverifiedOpenedConnectionTypeFromString
(value string)
awssql/plugins/aurora_initial_connection_strategy_plugin.go:48
↓ 1 callersMethodwaitForTopologyUpdate
(verifyWriter bool, timeoutMs int)
awssql/driver_infrastructure/cluster_topology_monitor.go:489
MethodAcceptsStrategy
(strategy string)
awssql/plugin_helpers/partial_plugin_service.go:199
MethodAcceptsStrategy
(strategy string)
awssql/plugin_helpers/plugin_manager.go:312
MethodAcceptsStrategy
(strategy string)
awssql/plugin_helpers/plugin_service.go:315
MethodAcceptsStrategy
(strategy string)
awssql/plugins/default_plugin.go:122
MethodAcceptsStrategy
(_ string)
awssql/plugins/base_connection_plugin.go:64
MethodAcceptsStrategy
(strategy string)
awssql/internal_pool/internal_pooled_connection_provider.go:81
MethodAcceptsStrategy
(strategy string)
awssql/driver_infrastructure/driver_connection_provider.go:44
MethodAcceptsStrategy
(strategy string)
awssql/driver_infrastructure/connection_provider_manager.go:50
MethodAcceptsStrategy
(strategy string)
awssql/driver_infrastructure/connection_provider.go:27
MethodAcceptsStrategy
(strategy string)
awssql/driver_infrastructure/plugin_helpers.go:110
← previousnext →701–800 of 1,810, ranked by callers