plugins

package
v1.0.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

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(strategy string) bool

func (BaseConnectionPlugin) Connect 

func (b BaseConnectionPlugin) Connect(
	hostInfo *host_info_util.HostInfo,
	props map[string]string,
	isInitialConnection bool,
	connectFunc driver_infrastructure.ConnectFunc) (driver.Conn, error)

func (BaseConnectionPlugin) Execute 

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

func (BaseConnectionPlugin) ForceConnect 

func (b BaseConnectionPlugin) ForceConnect(
	hostInfo *host_info_util.HostInfo,
	props map[string]string,
	isInitialConnection bool,
	connectFunc driver_infrastructure.ConnectFunc) (driver.Conn, error)

func (BaseConnectionPlugin) GetHostInfoByStrategy 

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

func (BaseConnectionPlugin) GetHostSelectorStrategy 

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

func (BaseConnectionPlugin) GetSubscribedMethods 

func (b BaseConnectionPlugin) GetSubscribedMethods() []string

func (BaseConnectionPlugin) InitHostProvider 

func (b BaseConnectionPlugin) InitHostProvider(
	initialUrl string,
	props map[string]string,
	hostListProviderService driver_infrastructure.HostListProviderService,
	initHostProviderFunc func() error) error

func (BaseConnectionPlugin) NotifyConnectionChanged 

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

func (BaseConnectionPlugin) NotifyHostListChanged 

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

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 map[string]string,
	isInitialConnection bool,
	connectFunc 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 map[string]string,
	isInitialConnection bool,
	forceConnectFunc 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) GetSubscribedMethods 

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

func (*DefaultPlugin) InitHostProvider 

func (d *DefaultPlugin) InitHostProvider(
	initialUrl string,
	props map[string]string,
	hostListProviderService driver_infrastructure.HostListProviderService,
	initHostProviderFunc func() error) error

func (*DefaultPlugin) NotifyConnectionChanged 

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

func (*DefaultPlugin) NotifyHostListChanged 

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

type ExecutionTimePlugin 

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

func NewExecutionTimePlugin 

func NewExecutionTimePlugin(pluginService driver_infrastructure.PluginService,
	props map[string]string) (*ExecutionTimePlugin, error)

func (*ExecutionTimePlugin) Execute 

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

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 map[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 map[string]string) (*FailoverPlugin, error)

func (*FailoverPlugin) Connect 

func (p *FailoverPlugin) Connect(
	hostInfo *host_info_util.HostInfo,
	props map[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(
	connInvokedOn driver.Conn,
	methodName string,
	executeFunc driver_infrastructure.ExecuteFunc,
	methodArgs ...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) GetSubscribedMethods 

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

func (*FailoverPlugin) InitFailoverMode 

func (p *FailoverPlugin) InitFailoverMode()

func (*FailoverPlugin) InitHostProvider 

func (p *FailoverPlugin) InitHostProvider(
	initialUrl string,
	props map[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 map[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 map[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.