Documentation
¶
Index ¶
- Variables
- func IsDialectLimitless(databaseDialect driver_infrastructure.DatabaseDialect) bool
- func NewLimitlessPluginFactory() driver_infrastructure.ConnectionPluginFactory
- type LimitlessConnectionContext
- type LimitlessPlugin
- type LimitlessPluginFactory
- type LimitlessQueryHelper
- type LimitlessQueryHelperImpl
- type LimitlessRouterMonitor
- type LimitlessRouterMonitorImpl
- type LimitlessRouterService
- type LimitlessRouterServiceImpl
- func (routerService *LimitlessRouterServiceImpl) EstablishConnection(context *LimitlessConnectionContext) error
- func (routerService *LimitlessRouterServiceImpl) SetPluginService(pluginService driver_infrastructure.PluginService)
- func (routerService *LimitlessRouterServiceImpl) StartMonitoring(hostInfo *host_info_util.HostInfo, props map[string]string, intervalMs int) error
Constants ¶
This section is empty.
Variables ¶
View Source
var LIMITLESS_ROUTER_CACHE *utils.SlidingExpirationCache[[]*host_info_util.HostInfo]
View Source
var LIMITLESS_ROUTER_MONITOR_CACHE *utils.SlidingExpirationCache[LimitlessRouterMonitor]
View Source
var LIMITLESS_SYNC_ROUTER_FETCH_LOCK_MAP *utils.SlidingExpirationCache[*sync.Mutex]
Functions ¶
func IsDialectLimitless ¶
func IsDialectLimitless(databaseDialect driver_infrastructure.DatabaseDialect) bool
func NewLimitlessPluginFactory ¶
func NewLimitlessPluginFactory() driver_infrastructure.ConnectionPluginFactory
Types ¶
type LimitlessConnectionContext ¶
type LimitlessConnectionContext struct {
Host host_info_util.HostInfo
Props map[string]string
ConnectFunc driver_infrastructure.ConnectFunc
LimitlessRouters []*host_info_util.HostInfo
// contains filtered or unexported fields
}
func NewConnectionContext ¶
func NewConnectionContext( hostInfo host_info_util.HostInfo, props map[string]string, conn driver.Conn, connectFunc driver_infrastructure.ConnectFunc, limitlessRouters []*host_info_util.HostInfo, plugin driver_infrastructure.ConnectionPlugin) *LimitlessConnectionContext
func (*LimitlessConnectionContext) GetConnection ¶
func (connectionContext *LimitlessConnectionContext) GetConnection() driver.Conn
func (*LimitlessConnectionContext) SetConnection ¶
func (connectionContext *LimitlessConnectionContext) SetConnection(connection driver.Conn)
type LimitlessPlugin ¶
type LimitlessPlugin struct {
plugins.BaseConnectionPlugin
// contains filtered or unexported fields
}
func NewLimitlessPlugin ¶
func NewLimitlessPlugin(pluginService driver_infrastructure.PluginService, props map[string]string) (*LimitlessPlugin, error)
func NewLimitlessPluginWithRouterService ¶
func NewLimitlessPluginWithRouterService(pluginService driver_infrastructure.PluginService, props map[string]string, routerService LimitlessRouterService) *LimitlessPlugin
Note: This method is for testing purposes.
func (*LimitlessPlugin) Connect ¶
func (plugin *LimitlessPlugin) Connect( hostInfo *host_info_util.HostInfo, props map[string]string, isInitialConnection bool, connectFunc driver_infrastructure.ConnectFunc) (driver.Conn, error)
func (*LimitlessPlugin) GetSubscribedMethods ¶
func (plugin *LimitlessPlugin) GetSubscribedMethods() []string
type LimitlessPluginFactory ¶
type LimitlessPluginFactory struct {
}
func (LimitlessPluginFactory) ClearCaches ¶
func (factory LimitlessPluginFactory) ClearCaches()
func (LimitlessPluginFactory) GetInstance ¶
func (factory LimitlessPluginFactory) GetInstance(pluginService driver_infrastructure.PluginService, props map[string]string) (driver_infrastructure.ConnectionPlugin, error)
type LimitlessQueryHelper ¶
type LimitlessQueryHelperImpl ¶
type LimitlessQueryHelperImpl struct {
// contains filtered or unexported fields
}
func NewLimitlessQueryHelperImpl ¶
func NewLimitlessQueryHelperImpl(pluginService driver_infrastructure.PluginService) *LimitlessQueryHelperImpl
func (*LimitlessQueryHelperImpl) QueryForLimitlessRouters ¶
func (queryHelper *LimitlessQueryHelperImpl) QueryForLimitlessRouters( conn driver.Conn, hostPortToMap int, props map[string]string) (hostInfoList []*host_info_util.HostInfo, err error)
type LimitlessRouterMonitor ¶
type LimitlessRouterMonitor interface {
Close()
}
type LimitlessRouterMonitorImpl ¶
type LimitlessRouterMonitorImpl struct {
// contains filtered or unexported fields
}
func NewLimitlessRouterMonitorImpl ¶
func NewLimitlessRouterMonitorImpl( queryHelper LimitlessQueryHelper, pluginService driver_infrastructure.PluginService, hostInfo *host_info_util.HostInfo, routerCache *utils.SlidingExpirationCache[[]*host_info_util.HostInfo], routerCacheKey string, intervalMs int, props map[string]string) *LimitlessRouterMonitorImpl
func (*LimitlessRouterMonitorImpl) Close ¶
func (monitor *LimitlessRouterMonitorImpl) Close()
type LimitlessRouterService ¶
type LimitlessRouterService interface {
EstablishConnection(context *LimitlessConnectionContext) error
StartMonitoring(hostInfo *host_info_util.HostInfo, props map[string]string, intervalMs int) error
}
type LimitlessRouterServiceImpl ¶
type LimitlessRouterServiceImpl struct {
// contains filtered or unexported fields
}
func NewLimitlessRouterServiceImpl ¶
func NewLimitlessRouterServiceImpl(pluginService driver_infrastructure.PluginService, props map[string]string) *LimitlessRouterServiceImpl
func NewLimitlessRouterServiceImplInternal ¶
func NewLimitlessRouterServiceImplInternal( pluginService driver_infrastructure.PluginService, queryHelper LimitlessQueryHelper, props map[string]string) *LimitlessRouterServiceImpl
func (*LimitlessRouterServiceImpl) EstablishConnection ¶
func (routerService *LimitlessRouterServiceImpl) EstablishConnection(context *LimitlessConnectionContext) error
func (*LimitlessRouterServiceImpl) SetPluginService ¶
func (routerService *LimitlessRouterServiceImpl) SetPluginService(pluginService driver_infrastructure.PluginService)
func (*LimitlessRouterServiceImpl) StartMonitoring ¶
func (routerService *LimitlessRouterServiceImpl) StartMonitoring(hostInfo *host_info_util.HostInfo, props map[string]string, intervalMs int) error
Source Files
Click to show internal directories.
Click to hide internal directories.