MCPcopy Create free account

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

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

↓ 2 callersMethodIsFailoverErrorType
()
awssql/error_util/errors.go:60
↓ 2 callersFunctionIsIPV6
(host string)
awssql/utils/rds_utils.go:119
↓ 2 callersFunctionIsIPv4
(host string)
awssql/utils/rds_utils.go:115
↓ 2 callersFunctionIsRdsDns
(host string)
awssql/utils/rds_utils.go:161
↓ 2 callersMethodIsStaticHostListProvider
()
awssql/driver_infrastructure/plugin_helpers.go:66
↓ 2 callersMethodIsWriterInstance
(conn driver.Conn)
awssql/driver_infrastructure/cluster_topology_monitor.go:98
↓ 2 callersMethodIsWriterInstance
(conn driver.Conn)
awssql/driver_infrastructure/topology_utils.go:47
↓ 2 callersMethodLogOpenedConnections
()
awssql/plugins/connection_tracker/connection_tracker.go:29
↓ 2 callersFunctionNewAuroraTopologyUtils
(dialect TopologyDialect, driverDialect DriverDialect, props *utils.RWMap[string, string])
awssql/driver_infrastructure/topology_utils.go:248
↓ 2 callersFunctionNewBatchingEventPublisher
NewBatchingEventPublisher creates a new batching event publisher with custom interval.
awssql/services/events.go:139
↓ 2 callersFunctionNewBlueGreenStatusMonitor
(blueGreenRole driver_infrastructure.BlueGreenRole, bgdId string, hostInfo *host_info_util.HostInfo, pluginSe
awssql/plugins/bg/bg_status_monitor.go:79
↓ 2 callersFunctionNewCustomEndpointPlugin
( servicesContainer driver_infrastructure.ServicesContainer, rdsClientFunc getRdsClientFunc, props *utils.R
custom-endpoint/custom_endpoint_plugin.go:101
↓ 2 callersFunctionNewDsnHostListProvider
(props *utils.RWMap[string, string], hostListProviderService HostListProviderService)
awssql/driver_infrastructure/dsn_host_list_provider.go:38
↓ 2 callersFunctionNewFailoverPlugin
( servicesContainer driver_infrastructure.ServicesContainer, props *utils.RWMap[string, string], pluginCode
awssql/plugins/failover_plugin.go:101
↓ 2 callersFunctionNewGlobalAuroraHostListProvider
( hostListProviderService HostListProviderService, topologyUtils GlobalClusterTopologyUtils, properties *ut
awssql/driver_infrastructure/global_aurora_host_list_provider.go:36
↓ 2 callersFunctionNewGlobalAuroraTopologyUtils
(dialect GlobalAuroraTopologyDialect, driverDialect DriverDialect, props *utils.RWMap[string, string])
awssql/driver_infrastructure/topology_utils.go:535
↓ 2 callersFunctionNewLimitlessQueryHelperImpl
(pluginService driver_infrastructure.PluginService)
awssql/plugins/limitless/limitless_query_helper.go:42
↓ 2 callersFunctionNewLimitlessRouters
NewLimitlessRouters creates a new LimitlessRouters instance.
awssql/plugins/limitless/limitless_routers.go:32
↓ 2 callersFunctionNewMultiAzTopologyUtils
(dialect MultiAzTopologyDialect, driverDialect DriverDialect, props *utils.RWMap[string, string])
awssql/driver_infrastructure/topology_utils.go:367
↓ 2 callersFunctionNewNilTelemetryFactory
()
awssql/utils/telemetry/nil_telemetry_factory.go:27
↓ 2 callersFunctionNewOpenTelemetryContext
(tracer trace.Tracer, name string, traceLevel telemetry.TelemetryTraceLevel, ctx context.Context)
otlp/open_telemetry_context.go:40
↓ 2 callersFunctionNewReadWriteSplittingPlugin
( servicesContainer driver_infrastructure.ServicesContainer, props *utils.RWMap[string, string], pluginCode
awssql/plugins/read_write_splitting/read_write_splitting_plugin.go:88
↓ 2 callersFunctionNewSuspendUntilCorrespondingHostFoundConnectRouting
(hostAndPort string, role driver_infrastructure.BlueGreenRole, bgId string, storageService driver_infrastruct
awssql/plugins/bg/connect_routing.go:255
↓ 2 callersFunctionNewXRayTelemetryContext
(name string, traceLevel telemetry.TelemetryTraceLevel, ctx context.Context)
xray/xray_telemetry_context.go:33
↓ 2 callersMethodNotifySubscribedPlugins
( methodName string, pluginFunc driver_infrastructure.PluginExecFunc, skipNotificationForThisPlugin driver_
awssql/plugin_helpers/plugin_manager.go:347
↓ 2 callersMethodPing
(ctx context.Context)
awssql/driver/driver.go:296
↓ 2 callersMethodPrepareDsn
(properties map[string]string, info *host_info_util.HostInfo)
awssql/driver_infrastructure/driver_dialect.go:29
↓ 2 callersMethodQuery
(args []driver.Value)
awssql/driver/driver.go:413
↓ 2 callersMethodQueryForLimitlessRouters
(conn driver.Conn, hostPortToMap int, props *utils.RWMap[string, string])
awssql/plugins/limitless/limitless_query_helper.go:35
↓ 2 callersMethodRaiseErrorOnNextCall
(err error, methodName string)
awssql/plugins/error_simulator/error_simulator.go:20
↓ 2 callersMethodRaiseErrorOnNextConnect
(err error)
awssql/plugins/error_simulator/error_simulator_manager.go:34
↓ 2 callersMethodRefresh
()
awssql/driver_infrastructure/host_list_provider.go:27
↓ 2 callersMethodResetAliases
()
awssql/host_info_util/host_info.go:66
↓ 2 callersMethodResetCollectedData
()
awssql/plugins/bg/bg_status_monitor.go:561
↓ 2 callersMethodRowsAffected
()
awssql/driver/driver.go:468
↓ 2 callersMethodSetAttribute
(key string, value string)
awssql/utils/telemetry/telemetry_util.go:66
↓ 2 callersMethodSetCallback
(errorSimulatorMethodCallback ErrorSimulatorMethodCallback)
awssql/plugins/error_simulator/error_simulator.go:21
↓ 2 callersMethodSetHostWeights
(hostWeightMap map[string]int)
awssql/driver_infrastructure/host_selector.go:48
↓ 2 callersMethodSetLastUpdateTime
(lastUpdateTime time.Time)
awssql/host_info_util/host_info.go:201
↓ 2 callersMethodSetSuccess
(success bool)
otlp/open_telemetry_context.go:124
↓ 2 callersMethodSetWeight
(weight int)
awssql/host_info_util/host_info.go:191
↓ 2 callersMethodStopMonitor
()
awssql/driver_infrastructure/host_list_provider.go:33
↓ 2 callersMethodString
()
awssql/driver_infrastructure/bg_helpers.go:150
↓ 2 callersMethodToString
()
awssql/driver_infrastructure/session_state.go:104
↓ 2 callersMethodUnsubscribe
(subscriber EventSubscriber, eventTypes []*EventType)
awssql/driver_infrastructure/event.go:39
↓ 2 callersMethodUnwrapPlugin
(pluginCode string)
awssql/driver_infrastructure/plugin_helpers.go:125
↓ 2 callersFunctionWithProperty
(key DriverPropertyKey, value int)
awssql/driver_infrastructure/driver_dialect.go:75
↓ 2 callersMethodapplySecretToProperties
(props *utils.RWMap[string, string], secret AwsRdsSecrets)
aws-secrets-manager/aws_secrets_manager_connection_plugin.go:203
↓ 2 callersFunctionbeginWithPlugins
( connInvokedOn driver.Conn, pluginManager driver_infrastructure.PluginManager, pluginService driver_infras
awssql/driver/wrapper_utils.go:123
↓ 2 callersMethodcompareHostInfos
(hostInfoA *host_info_util.HostInfo, hostInfoB *host_info_util.HostInfo)
awssql/plugin_helpers/plugin_service.go:217
↓ 2 callersMethodconnectInternal
( hostInfo *host_info_util.HostInfo, props *utils.RWMap[string, string], connectFunc driver_infrastructure.
federated-auth/federated_auth_plugin.go:111
↓ 2 callersMethodconnectInternal
( hostInfo *host_info_util.HostInfo, props *utils.RWMap[string, string], connectFunc driver_infrastructure.
okta/okta_auth_plugin.go:113
↓ 2 callersMethodconnectInternal
( hostInfo *host_info_util.HostInfo, props *utils.RWMap[string, string], connectFunc driver_infrastructure.
iam/iam_auth_plugin.go:110
↓ 2 callersMethodconnectInternal
( hostInfo *host_info_util.HostInfo, props *utils.RWMap[string, string], connProvider driver_infrastructure
awssql/plugins/default_plugin.go:97
↓ 2 callersMethodconnectInternal
( hostInfo *host_info_util.HostInfo, props *utils.RWMap[string, string], connectFunc driver_infrastructure.
aws-secrets-manager/aws_secrets_manager_connection_plugin.go:165
↓ 2 callersMethodconnectWithSubscribedPlugins
(methodName string, pluginFunc driver_infrastructure.PluginConnectFunc, targetFunc driver_infrastructure.Conn
awssql/plugin_helpers/plugin_manager.go:278
↓ 2 callersFunctioncreateClusterTopologyMonitor
( servicesContainer ServicesContainer, clusterId string, props *utils.RWMap[string, string], initialHostIn
awssql/driver_infrastructure/rds_host_list_provider.go:147
↓ 2 callersMethodcreateMonitorIfAbsent
( props *utils.RWMap[string, string])
custom-endpoint/custom_endpoint_plugin.go:219
↓ 2 callersMethoddealWithError
dealWithError inspects an error and triggers failover if appropriate.
awssql/plugins/failover_handler.go:26
↓ 2 callersMethoddelay
(useHighRefreshRate bool)
awssql/driver_infrastructure/cluster_topology_monitor.go:644
↓ 2 callersMethoddeliverEvent
(event driver_infrastructure.Event)
awssql/services/events.go:183
↓ 2 callersMethodexecuteWithSubscribedPlugins
( methodName string, pluginFunc driver_infrastructure.PluginExecFunc, targetFunc driver_infrastructure.Exec
awssql/plugin_helpers/plugin_manager.go:268
↓ 2 callersMethodextendExpiration
(ttl time.Duration)
awssql/utils/expiration_cache.go:37
↓ 2 callersMethodfetchAndSetToken
( hostInfo *host_info_util.HostInfo, host string, port int, region region_util.Region, cacheKey string,
iam/iam_auth_plugin.go:173
↓ 2 callersFunctionfindHost
(hosts []*host_info_util.HostInfo, instanceId string, instanceName string)
awssql/driver_infrastructure/rds_host_list_provider.go:251
↓ 2 callersMethodforceRefreshMonitor
(verifyTopology bool, timeoutMs int)
awssql/driver_infrastructure/rds_host_list_provider.go:191
↓ 2 callersFunctiongdbFailoverModeFromValue
(value string)
awssql/plugins/gdb_failover_plugin.go:49
↓ 2 callersMethodgetBgStatus
()
awssql/plugins/bg/connect_routing.go:148
↓ 2 callersMethodgetBgStatus
()
awssql/plugins/bg/connect_routing.go:200
↓ 2 callersMethodgetBgStatus
()
awssql/plugins/bg/execute_routing.go:36
↓ 2 callersFunctiongetDefaultProvider
(profile string)
auth-helpers/aws_credentials_management.go:52
↓ 2 callersMethodgetIpMapString
(ipMap map[string]string)
awssql/plugins/bg/bg_interim_status.go:157
↓ 2 callersMethodgetLimitlessRouters
(routerCacheKey string)
awssql/plugins/limitless/limitless_router_service.go:158
↓ 2 callersMethodgetNewWriterConnection
(hosts []*host_info_util.HostInfo)
awssql/plugins/read_write_splitting/read_write_splitting_plugin.go:398
↓ 2 callersMethodgetReaderFailoverCandidates
(hosts []*host_info_util.HostInfo)
awssql/plugins/failover_plugin.go:464
↓ 2 callersMethodgetSQLStateFromError
(err error)
pgx-driver/pgx_error_handler.go:84
↓ 2 callersMethodgetSQLStateFromError
(err error)
mysql-driver/mysql_error_handler.go:58
↓ 2 callersFunctiongetTelemetryFactory
(enableTelemetry bool, backend string)
awssql/utils/telemetry/default_telemetry_factory.go:69
↓ 2 callersMethodgetTopologyString
(topology []*host_info_util.HostInfo)
awssql/plugins/bg/bg_interim_status.go:142
↓ 2 callersMethodhasNoReaders
()
awssql/plugins/aurora_initial_connection_strategy_plugin.go:391
↓ 2 callersFunctionhasPropertyChanged
( lastPropertyValue T, wrapperProperty property_util.AwsWrapperProperty, props map[string]string)
awssql/driver_infrastructure/round_robin_host_selector.go:263
↓ 2 callersMethodinitFailoverMode
initFailoverMode initializes the failover mode based on connection properties and URL type.
awssql/plugins/failover_handler.go:22
↓ 2 callersMethodinitializeReaderConnection
(hosts []*host_info_util.HostInfo)
awssql/plugins/read_write_splitting/read_write_splitting_plugin.go:378
↓ 2 callersMethodisReader
(hostInfo *host_info_util.HostInfo)
awssql/plugins/read_write_splitting/read_write_splitting_plugin.go:448
↓ 2 callersFunctionparseMultiStatementQueries
(query string)
awssql/utils/sql_method_utils.go:95
↓ 2 callersFunctionprepareWithPlugins
( connInvokedOn driver.Conn, pluginManager driver_infrastructure.PluginManager, methodName string, prepare
awssql/driver/wrapper_utils.go:105
↓ 2 callersFunctionpruneNullConnections
()
awssql/plugins/connection_tracker/opened_connection_tracker.go:169
↓ 2 callersMethodqueryForTopology
(conn driver.Conn)
awssql/driver_infrastructure/cluster_topology_monitor.go:556
↓ 2 callersMethodraiseError
(err error, methodName string)
awssql/plugins/developer_connection_plugin.go:107
↓ 2 callersMethodraiseErrorOnConnect
(err error)
awssql/plugins/developer_connection_plugin.go:146
↓ 2 callersMethodresetRoutingTimeNano
()
awssql/plugins/bg/bg_plugin.go:265
↓ 2 callersMethodresetStateEnabledSetting
()
awssql/driver_infrastructure/session_state_service.go:82
↓ 2 callersMethodreturnReaderFailoverErr
(err error)
awssql/plugins/failover_plugin.go:459
↓ 2 callersMethodsetHostList
(newHosts []*host_info_util.HostInfo)
awssql/plugin_helpers/plugin_service.go:423
↓ 2 callersFunctionsetInitialSessionSettings
(db *sql.DB)
examples/aws_failover_postgresql_example.go:90
↓ 2 callersFunctionsetInitialSessionSettings
(db *sql.DB)
examples/aws_failover_mysql_example.go:90
↓ 2 callersMethodsetReadWriteMode
(readOnly bool)
awssql/driver/driver.go:355
↓ 2 callersMethodsetReaderConnection
(conn driver.Conn, host *host_info_util.HostInfo)
awssql/plugins/read_write_splitting/read_write_splitting_plugin.go:457
↓ 2 callersMethodsetWriterConnection
(conn driver.Conn, host *host_info_util.HostInfo)
awssql/plugins/read_write_splitting/read_write_splitting_plugin.go:452
↓ 2 callersMethodshortDelay
()
awssql/plugins/gdb_failover_plugin.go:472
← previousnext →301–400 of 1,810, ranked by callers