plugins

package
v1.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 8, 2025 License: Apache-2.0 Imports: 15 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewConnectTimePluginFactory added in v1.1.0 

func NewConnectTimePluginFactory() driver_infrastructure.ConnectionPluginFactory

func NewExecutionTimePluginFactory 

func NewExecutionTimePluginFactory() driver_infrastructure.ConnectionPluginFactory

func NewFailoverPluginFactory 

func NewFailoverPluginFactory() driver_infrastructure.ConnectionPluginFactory

Types

type BaseConnectionPlugin 

type BaseConnectionPlugin struct {
}

func (BaseConnectionPlugin) AcceptsStrategy 

func (b BaseConnectionPlugin) AcceptsStrategy(_ string) bool

func (BaseConnectionPlugin) Connect 

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

func (BaseConnectionPlugin) Execute 

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

func (BaseConnectionPlugin) ForceConnect 

func (b BaseConnectionPlugin) ForceConnect(
	_ *host_info_util.HostInfo,
	props *utils.RWMap[string, string],
	_ bool,
	connectFunc driver_infrastructure.ConnectFunc) (driver.Conn, error)

func (BaseConnectionPlugin) GetHostInfoByStrategy 

func (b BaseConnectionPlugin) GetHostInfoByStrategy(_ host_info_util.HostRole, _ string, _ []*host_info_util.HostInfo) (*host_info_util.HostInfo, error)

func (BaseConnectionPlugin) GetHostSelectorStrategy 

func (b BaseConnectionPlugin) GetHostSelectorStrategy(_ string) (driver_infrastructure.HostSelector, error)

func (BaseConnectionPlugin) GetPluginCode added in v1.1.0 

func (b BaseConnectionPlugin) GetPluginCode() string

func (BaseConnectionPlugin) GetSubscribedMethods 

func (b BaseConnectionPlugin) GetSubscribedMethods() []string

func (BaseConnectionPlugin) InitHostProvider 

func (b BaseConnectionPlugin) InitHostProvider(
	_ *utils.RWMap[string, string],
	_ driver_infrastructure.HostListProviderService,
	initHostProviderFunc func() error) error

func (BaseConnectionPlugin) NotifyConnectionChanged 

func (b BaseConnectionPlugin) NotifyConnectionChanged(_ map[driver_infrastructure.HostChangeOptions]bool) driver_infrastructure.OldConnectionSuggestedAction

func (BaseConnectionPlugin) NotifyHostListChanged 

func (b BaseConnectionPlugin) NotifyHostListChanged(_ map[string]map[driver_infrastructure.HostChangeOptions]bool)

type ConnectTimePlugin added in v1.1.0 

type ConnectTimePlugin struct {
	BaseConnectionPlugin
	// contains filtered or unexported fields
}

func NewConnectTimePlugin added in v1.1.0 

func NewConnectTimePlugin(_ driver_infrastructure.PluginService,
	_ *utils.RWMap[string, string]) (*ConnectTimePlugin, error)

func (*ConnectTimePlugin) Connect added in v1.1.0 

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

func (*ConnectTimePlugin) ForceConnect added in v1.1.0 

func (d *ConnectTimePlugin) ForceConnect(
	_ *host_info_util.HostInfo,
	props *utils.RWMap[string, string],
	_ bool,
	forceConnectFunc driver_infrastructure.ConnectFunc) (driver.Conn, error)

func (*ConnectTimePlugin) GetPluginCode added in v1.1.0 

func (d *ConnectTimePlugin) GetPluginCode() string

func (*ConnectTimePlugin) GetSubscribedMethods added in v1.1.0 

func (d *ConnectTimePlugin) GetSubscribedMethods() []string

func (*ConnectTimePlugin) GetTotalConnectTime added in v1.1.0 

func (d *ConnectTimePlugin) GetTotalConnectTime() int64

func (*ConnectTimePlugin) ResetConnectTime added in v1.1.0 

func (d *ConnectTimePlugin) ResetConnectTime()

type ConnectTimePluginFactory added in v1.1.0 

type ConnectTimePluginFactory struct{}

func (ConnectTimePluginFactory) ClearCaches added in v1.1.0 

func (factory ConnectTimePluginFactory) ClearCaches()

func (ConnectTimePluginFactory) GetInstance added in v1.1.0 

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

type DefaultPlugin 

type DefaultPlugin struct {
	PluginService       driver_infrastructure.PluginService
	DefaultConnProvider driver_infrastructure.ConnectionProvider
	ConnProviderManager driver_infrastructure.ConnectionProviderManager
}

func (*DefaultPlugin) AcceptsStrategy 

func (d *DefaultPlugin) AcceptsStrategy(strategy string) bool

func (*DefaultPlugin) Connect 

func (d *DefaultPlugin) Connect(
	hostInfo *host_info_util.HostInfo,
	props *utils.RWMap[string, string],
	isInitialConnection bool,
	_ driver_infrastructure.ConnectFunc) (driver.Conn, error)

func (*DefaultPlugin) Execute 

func (d *DefaultPlugin) Execute(
	connInvokedOn driver.Conn,
	methodName string,
	executeFunc driver_infrastructure.ExecuteFunc,
	methodArgs ...any) (wrappedReturnValue any, wrappedReturnValue2 any, wrappedOk bool, wrappedErr error)

func (*DefaultPlugin) ForceConnect 

func (d *DefaultPlugin) ForceConnect(
	hostInfo *host_info_util.HostInfo,
	props *utils.RWMap[string, string],
	isInitialConnection bool,
	_ driver_infrastructure.ConnectFunc) (driver.Conn, error)

func (*DefaultPlugin) GetHostInfoByStrategy 

func (d *DefaultPlugin) GetHostInfoByStrategy(
	role host_info_util.HostRole,
	strategy string,
	hosts []*host_info_util.HostInfo) (*host_info_util.HostInfo, error)

func (*DefaultPlugin) GetHostSelectorStrategy 

func (d *DefaultPlugin) GetHostSelectorStrategy(strategy string) (driver_infrastructure.HostSelector, error)

func (*DefaultPlugin) GetPluginCode added in v1.1.0 

func (d *DefaultPlugin) GetPluginCode() string

func (*DefaultPlugin) GetSubscribedMethods 

func (d *DefaultPlugin) GetSubscribedMethods() []string

func (*DefaultPlugin) InitHostProvider 

func (d *DefaultPlugin) InitHostProvider(
	_ *utils.RWMap[string, string],
	_ driver_infrastructure.HostListProviderService,
	_ func() error) error

func (*DefaultPlugin) NotifyConnectionChanged 

func (d *DefaultPlugin) NotifyConnectionChanged(_ map[driver_infrastructure.HostChangeOptions]bool) driver_infrastructure.OldConnectionSuggestedAction

func (*DefaultPlugin) NotifyHostListChanged 

func (d *DefaultPlugin) NotifyHostListChanged(_ map[string]map[driver_infrastructure.HostChangeOptions]bool)

type ExecutionTimePlugin 

type ExecutionTimePlugin struct {
	BaseConnectionPlugin
	// contains filtered or unexported fields
}

func NewExecutionTimePlugin 

func NewExecutionTimePlugin(_ driver_infrastructure.PluginService,
	_ *utils.RWMap[string, string]) (*ExecutionTimePlugin, error)

func (*ExecutionTimePlugin) Execute 

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

func (*ExecutionTimePlugin) GetPluginCode added in v1.1.0 

func (d *ExecutionTimePlugin) GetPluginCode() string

func (*ExecutionTimePlugin) GetSubscribedMethods 

func (d *ExecutionTimePlugin) GetSubscribedMethods() []string

func (*ExecutionTimePlugin) GetTotalExecutionTime 

func (d *ExecutionTimePlugin) GetTotalExecutionTime() int64

func (*ExecutionTimePlugin) ResetExecutionTime 

func (d *ExecutionTimePlugin) ResetExecutionTime()

type ExecutionTimePluginFactory 

type ExecutionTimePluginFactory struct{}

func (ExecutionTimePluginFactory) ClearCaches 

func (factory ExecutionTimePluginFactory) ClearCaches()

func (ExecutionTimePluginFactory) GetInstance 

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

type FailoverMode 

type FailoverMode string
const (
	MODE_STRICT_WRITER    FailoverMode = "strict-writer"
	MODE_STRICT_READER    FailoverMode = "strict-reader"
	MODE_READER_OR_WRITER FailoverMode = "reader-or-writer"
	MODE_UNKNOWN          FailoverMode = "unknown"
)

type FailoverPlugin 

type FailoverPlugin struct {
	FailoverMode FailoverMode

	BaseConnectionPlugin
	// contains filtered or unexported fields
}

func NewFailoverPlugin 

func NewFailoverPlugin(pluginService driver_infrastructure.PluginService, props *utils.RWMap[string, string]) (*FailoverPlugin, error)

func (*FailoverPlugin) Connect 

func (p *FailoverPlugin) Connect(
	hostInfo *host_info_util.HostInfo,
	props *utils.RWMap[string, string],
	isInitialConnection bool,
	connectFunc driver_infrastructure.ConnectFunc) (driver.Conn, error)

func (*FailoverPlugin) DealWithError 

func (p *FailoverPlugin) DealWithError(err error) error

func (*FailoverPlugin) Execute 

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

func (*FailoverPlugin) Failover 

func (p *FailoverPlugin) Failover() error

func (*FailoverPlugin) FailoverReader 

func (p *FailoverPlugin) FailoverReader() error

func (*FailoverPlugin) FailoverWriter 

func (p *FailoverPlugin) FailoverWriter() error

func (*FailoverPlugin) GetPluginCode added in v1.1.0 

func (p *FailoverPlugin) GetPluginCode() string

func (*FailoverPlugin) GetSubscribedMethods 

func (p *FailoverPlugin) GetSubscribedMethods() []string

func (*FailoverPlugin) InitFailoverMode 

func (p *FailoverPlugin) InitFailoverMode()

func (*FailoverPlugin) InitHostProvider 

func (p *FailoverPlugin) InitHostProvider(
	_ *utils.RWMap[string, string],
	hostListProviderService driver_infrastructure.HostListProviderService,
	initHostProviderFunc func() error) error

func (*FailoverPlugin) InvalidateCurrentConnection 

func (p *FailoverPlugin) InvalidateCurrentConnection()

type FailoverPluginFactory 

type FailoverPluginFactory struct{}

func (FailoverPluginFactory) ClearCaches 

func (f FailoverPluginFactory) ClearCaches()

func (FailoverPluginFactory) GetInstance 

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

type ReaderFailoverResult 

type ReaderFailoverResult struct {
	Conn     driver.Conn
	HostInfo *host_info_util.HostInfo
}

type StaleDnsHelper 

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

func NewStaleDnsHelper 

func NewStaleDnsHelper(pluginService driver_infrastructure.PluginService) (*StaleDnsHelper, error)

func (*StaleDnsHelper) GetVerifiedConnection 

func (s *StaleDnsHelper) GetVerifiedConnection(
	host string,
	isInitialConnection bool,
	hostListProviderService driver_infrastructure.HostListProviderService,
	props *utils.RWMap[string, string],
	connectFunc driver_infrastructure.ConnectFunc) (driver.Conn, error)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.