custom_endpoint

package module

v1.0.2 Latest Latest Go to latest Published: Feb 3, 2026 License: Apache-2.0 Imports: 23 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

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

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func ClearCache()
func NewCustomEndpointPluginFactory() driver_infrastructure.ConnectionPluginFactory
type CustomEndpointInfo
- func NewCustomEndpointInfo(endpoint types.DBClusterEndpoint) (*CustomEndpointInfo, error)
type CustomEndpointMonitor
type CustomEndpointMonitorImpl
- func NewCustomEndpointMonitorImpl(pluginService driver_infrastructure.PluginService, ...) *CustomEndpointMonitorImpl
type CustomEndpointPlugin
- func NewCustomEndpointPlugin(pluginService driver_infrastructure.PluginService, ...) (*CustomEndpointPlugin, error)
- func NewCustomEndpointPluginWithHostInfo(pluginService driver_infrastructure.PluginService, ...) (*CustomEndpointPlugin, error)
type CustomEndpointPluginFactory
- func (factory CustomEndpointPluginFactory) ClearCaches()
- func (factory CustomEndpointPluginFactory) GetInstance(pluginService driver_infrastructure.PluginService, ...) (driver_infrastructure.ConnectionPlugin, error)
type MemberListType
type RoleType

Constants ¶

View Source

const CUSTOM_ENDPOINT_INFO_EXPIRATION_NANO = time.Minute * 5

View Source

const TELEMETRY_ENDPOINT_INFO_CHANGED = "customEndpoint.infoChanged.counter"

View Source

const TELEMETRY_WAIT_FOR_INFO_COUNTER = "customEndpoint.waitForInfo.counter"

Variables ¶

View Source

var CUSTOM_ENDPOINT_MONITORS *utils.SlidingExpirationCache[CustomEndpointMonitor]

Functions ¶

func ClearCache ¶

func ClearCache()

func NewCustomEndpointPluginFactory ¶

func NewCustomEndpointPluginFactory() driver_infrastructure.ConnectionPluginFactory

Types ¶

type CustomEndpointInfo ¶

type CustomEndpointInfo struct {
	// contains filtered or unexported fields
}

func NewCustomEndpointInfo ¶

func NewCustomEndpointInfo(endpoint types.DBClusterEndpoint) (*CustomEndpointInfo, error)

func (*CustomEndpointInfo) Equals ¶

func (a *CustomEndpointInfo) Equals(b *CustomEndpointInfo) bool

func (*CustomEndpointInfo) GetExcludedMembers ¶

func (a *CustomEndpointInfo) GetExcludedMembers() map[string]bool

func (*CustomEndpointInfo) GetStaticMembers ¶

func (a *CustomEndpointInfo) GetStaticMembers() map[string]bool

type CustomEndpointMonitor ¶

type CustomEndpointMonitor interface {
	ShouldDispose() bool
	Close()
	HasCustomEndpointInfo() bool
}

type CustomEndpointMonitorImpl ¶

type CustomEndpointMonitorImpl struct {
	// contains filtered or unexported fields
}

func NewCustomEndpointMonitorImpl ¶

func NewCustomEndpointMonitorImpl(
	pluginService driver_infrastructure.PluginService,
	customEndpointHostInfo *host_info_util.HostInfo,
	endpointIdentifier string,
	region region_util.Region,
	refreshRateMs time.Duration,
	infoChangedCounter telemetry.TelemetryCounter,
	rdsClient *rds.Client) *CustomEndpointMonitorImpl

func (*CustomEndpointMonitorImpl) Close ¶

func (monitor *CustomEndpointMonitorImpl) Close()

func (*CustomEndpointMonitorImpl) HasCustomEndpointInfo ¶

func (monitor *CustomEndpointMonitorImpl) HasCustomEndpointInfo() bool

func (*CustomEndpointMonitorImpl) ShouldDispose ¶

func (monitor *CustomEndpointMonitorImpl) ShouldDispose() bool

type CustomEndpointPlugin ¶

type CustomEndpointPlugin struct {
	plugins.BaseConnectionPlugin
	// contains filtered or unexported fields
}

func NewCustomEndpointPlugin ¶

func NewCustomEndpointPlugin(
	pluginService driver_infrastructure.PluginService,
	rdsClientFunc getRdsClientFunc,
	props *utils.RWMap[string, string]) (*CustomEndpointPlugin, error)

func NewCustomEndpointPluginWithHostInfo ¶

func NewCustomEndpointPluginWithHostInfo(
	pluginService driver_infrastructure.PluginService,
	rdsClientFunc getRdsClientFunc,
	props *utils.RWMap[string, string],
	customEndpointHostInfo *host_info_util.HostInfo) (*CustomEndpointPlugin, error)

NOTE: This method is for testing purposes.

func (*CustomEndpointPlugin) Connect ¶

func (plugin *CustomEndpointPlugin) Connect(
	hostInfo *host_info_util.HostInfo,
	props *utils.RWMap[string, string],
	_ bool,
	connectFunc driver_infrastructure.ConnectFunc) (driver.Conn, error)

func (*CustomEndpointPlugin) Execute ¶

func (plugin *CustomEndpointPlugin) Execute(
	_ driver.Conn,
	_ string,
	executeFunc driver_infrastructure.ExecuteFunc,
	_ ...any) (wrappedReturnValue any, wrappedReturnValue2 any, wrappedOk bool, wrappedErr error)

func (*CustomEndpointPlugin) GetSubscribedMethods ¶

func (plugin *CustomEndpointPlugin) GetSubscribedMethods() []string

type CustomEndpointPluginFactory ¶

type CustomEndpointPluginFactory struct{}

func (CustomEndpointPluginFactory) ClearCaches ¶

func (factory CustomEndpointPluginFactory) ClearCaches()

func (CustomEndpointPluginFactory) GetInstance ¶

func (factory CustomEndpointPluginFactory) GetInstance(
	pluginService driver_infrastructure.PluginService,
	props *utils.RWMap[string, string]) (driver_infrastructure.ConnectionPlugin, error)

type MemberListType ¶

type MemberListType string

const (
	STATIC_LIST    MemberListType = "STATIC_LIST"
	EXCLUSION_LIST MemberListType = "EXCLUSION_LIST"
)

type RoleType ¶

type RoleType string

const (
	ANY    RoleType = "ANY"
	WRITER RoleType = "WRITER"
	READER RoleType = "READER"
)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL