limitless

type LimitlessConnectionContext struct {
	Host  host_info_util.HostInfo
	Props *utils.RWMap[string, string]

	ConnectFunc      driver_infrastructure.ConnectFunc
	LimitlessRouters []*host_info_util.HostInfo
	// contains filtered or unexported fields
}

type LimitlessPlugin struct {
	plugins.BaseConnectionPlugin
	// contains filtered or unexported fields
}

type LimitlessPluginFactory struct {
}

type LimitlessQueryHelper interface {
	QueryForLimitlessRouters(conn driver.Conn, hostPortToMap int, props *utils.RWMap[string, string]) (hostInfoList []*host_info_util.HostInfo, err error)
}

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

type LimitlessRouterMonitor interface {
	Close()
}

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

type LimitlessRouterService interface {
	EstablishConnection(context *LimitlessConnectionContext) error
	StartMonitoring(hostInfo *host_info_util.HostInfo, props *utils.RWMap[string, string], intervalMs int) error
}

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