Documentation
¶
Index ¶
- func NewReadWriteSplittingPluginFactory() driver_infrastructure.ConnectionPluginFactory
- type ReadWriteSplittingPlugin
- func (r *ReadWriteSplittingPlugin) Connect(_ *host_info_util.HostInfo, props *utils.RWMap[string, string], ...) (driver.Conn, error)
- func (r *ReadWriteSplittingPlugin) Execute(_ driver.Conn, _ string, executeFunc driver_infrastructure.ExecuteFunc, ...) (wrappedReturnValue any, wrappedReturnValue2 any, wrappedOk bool, ...)
- func (r *ReadWriteSplittingPlugin) GetPluginCode() string
- func (r *ReadWriteSplittingPlugin) GetSubscribedMethods() []string
- func (r *ReadWriteSplittingPlugin) InitHostProvider(_ *utils.RWMap[string, string], ...) error
- func (r *ReadWriteSplittingPlugin) NotifyConnectionChanged(_ map[driver_infrastructure.HostChangeOptions]bool) driver_infrastructure.OldConnectionSuggestedAction
- func (r *ReadWriteSplittingPlugin) ReleaseResources()
- type ReadWriteSplittingPluginFactory
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewReadWriteSplittingPluginFactory ¶
func NewReadWriteSplittingPluginFactory() driver_infrastructure.ConnectionPluginFactory
Types ¶
type ReadWriteSplittingPlugin ¶
type ReadWriteSplittingPlugin struct {
plugins.BaseConnectionPlugin
// contains filtered or unexported fields
}
func NewReadWriteSplittingPlugin ¶
func NewReadWriteSplittingPlugin(pluginService driver_infrastructure.PluginService, props *utils.RWMap[string, string]) *ReadWriteSplittingPlugin
func (*ReadWriteSplittingPlugin) Connect ¶
func (r *ReadWriteSplittingPlugin) Connect( _ *host_info_util.HostInfo, props *utils.RWMap[string, string], isInitialConnection bool, connectFunc driver_infrastructure.ConnectFunc) (driver.Conn, error)
func (*ReadWriteSplittingPlugin) Execute ¶
func (r *ReadWriteSplittingPlugin) Execute( _ driver.Conn, _ string, executeFunc driver_infrastructure.ExecuteFunc, methodArgs ...any) (wrappedReturnValue any, wrappedReturnValue2 any, wrappedOk bool, wrappedErr error)
func (*ReadWriteSplittingPlugin) GetPluginCode ¶
func (r *ReadWriteSplittingPlugin) GetPluginCode() string
func (*ReadWriteSplittingPlugin) GetSubscribedMethods ¶
func (r *ReadWriteSplittingPlugin) GetSubscribedMethods() []string
func (*ReadWriteSplittingPlugin) InitHostProvider ¶
func (r *ReadWriteSplittingPlugin) InitHostProvider( _ *utils.RWMap[string, string], hostListProviderService driver_infrastructure.HostListProviderService, initHostProviderFunc func() error) error
func (*ReadWriteSplittingPlugin) NotifyConnectionChanged ¶
func (r *ReadWriteSplittingPlugin) NotifyConnectionChanged( _ map[driver_infrastructure.HostChangeOptions]bool) driver_infrastructure.OldConnectionSuggestedAction
func (*ReadWriteSplittingPlugin) ReleaseResources ¶
func (r *ReadWriteSplittingPlugin) ReleaseResources()
type ReadWriteSplittingPluginFactory ¶
type ReadWriteSplittingPluginFactory struct{}
func (ReadWriteSplittingPluginFactory) ClearCaches ¶
func (factory ReadWriteSplittingPluginFactory) ClearCaches()
func (ReadWriteSplittingPluginFactory) GetInstance ¶
func (factory ReadWriteSplittingPluginFactory) GetInstance(pluginService driver_infrastructure.PluginService, props *utils.RWMap[string, string]) (driver_infrastructure.ConnectionPlugin, error)
Source Files
Click to show internal directories.
Click to hide internal directories.