Documentation
¶
Index ¶
- type ConnectionTracker
- type OpenedConnectionTracker
- func (o *OpenedConnectionTracker) ClearCache()
- func (o *OpenedConnectionTracker) GetOpenedConnections() map[string]*utils.RWQueue[weak.Pointer[driver.Conn]]
- func (o *OpenedConnectionTracker) InvalidateAllConnections(hostInfo *host_info_util.HostInfo)
- func (o *OpenedConnectionTracker) InvalidateAllConnectionsMultipleHosts(hosts ...string)
- func (o *OpenedConnectionTracker) LogOpenedConnections()
- func (o *OpenedConnectionTracker) PopulateOpenedConnectionQueue(hostInfo *host_info_util.HostInfo, conn driver.Conn)
- func (o *OpenedConnectionTracker) PruneNullConnections()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConnectionTracker ¶
type ConnectionTracker interface {
PopulateOpenedConnectionQueue(hostInfo *host_info_util.HostInfo, conn driver.Conn)
InvalidateAllConnections(hostInfo *host_info_util.HostInfo)
InvalidateAllConnectionsMultipleHosts(hosts ...string)
LogOpenedConnections()
PruneNullConnections()
ClearCache()
}
type OpenedConnectionTracker ¶
type OpenedConnectionTracker struct {
// contains filtered or unexported fields
}
func NewOpenedConnectionTracker ¶
func NewOpenedConnectionTracker(pluginService driver_infrastructure.PluginService) *OpenedConnectionTracker
func (*OpenedConnectionTracker) ClearCache ¶
func (o *OpenedConnectionTracker) ClearCache()
func (*OpenedConnectionTracker) GetOpenedConnections ¶
func (*OpenedConnectionTracker) InvalidateAllConnections ¶
func (o *OpenedConnectionTracker) InvalidateAllConnections(hostInfo *host_info_util.HostInfo)
func (*OpenedConnectionTracker) InvalidateAllConnectionsMultipleHosts ¶
func (o *OpenedConnectionTracker) InvalidateAllConnectionsMultipleHosts(hosts ...string)
func (*OpenedConnectionTracker) LogOpenedConnections ¶
func (o *OpenedConnectionTracker) LogOpenedConnections()
func (*OpenedConnectionTracker) PopulateOpenedConnectionQueue ¶
func (o *OpenedConnectionTracker) PopulateOpenedConnectionQueue(hostInfo *host_info_util.HostInfo, conn driver.Conn)
func (*OpenedConnectionTracker) PruneNullConnections ¶
func (o *OpenedConnectionTracker) PruneNullConnections()
Click to show internal directories.
Click to hide internal directories.