selector

type Balancer interface {
	GetHandler(*session.Info) i.Outbound
	UpdateHandlers(handlers []i.HandlerWith6Info)
	Support6() bool
}

type CreateHandlerFunc func(h *configs.HandlerConfig, landHandlerIds []*xsqlite.OutboundHandler) (i.Outbound, error)

type Db interface {
	GetAllHandlers() ([]*xsqlite.OutboundHandler, error)
	GetHandlersByGroup(group string) ([]*xsqlite.OutboundHandler, error)
	GetBatchedHandlers(batchSize int, offset int) ([]*xsqlite.OutboundHandler, error)
	GetHandler(id int) *xsqlite.OutboundHandler
}

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

type FastRecoveryChangeObserver interface {
	OnFastRecoveryChanged(isRecovery bool)
}

type Filter interface {
	GetHandlers() ([]outHandler, error)
}

type FilterUpdate interface {
	UpdateFilterConfig(filterConfig *configs.SelectorConfig_Filter)
}

type HandlerErrorChangeSubject interface {
	AddHandlerErrorObserver(observer i.HandlerErrorObserver)
	RemoveHandlerErrorObserver(observer i.HandlerErrorObserver)
}

type HandlersBeingUsedUpdate func([]string)

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

type OnFastRecoveryChangedFunc func()

type OnSelectedHandlersChangedFunc func()

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

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

type SelectedHandlersChangeObserver interface {
	OnSelectedHandlersChanged(tag string, handlers []string)
}

type Selector struct {
	FastRecoveryChangeNotifier

	util.IPv6SupportChangeNotifier
	// contains filtered or unexported fields
}

type SelectorConfig struct {
	*configs.SelectorConfig
	CreateHandler             CreateHandlerFunc
	HandlerErrorChangeSubject HandlerErrorChangeSubject
	Tester                    Tester
	Filter                    Filter
	OnHandlerBeingUsedChange  HandlersBeingUsedUpdate
}

type Selectors struct {

	// notify listeners when any selector's ipv6 support changed or any selector is added or removed
	i.IPv6SupportChangeSubject
	SelectedHandlersChangeNotifier
	// contains filtered or unexported fields
}

type Tester interface {
	TestSpeed(context.Context, i.Outbound, bool) int64
	TestUsable(context.Context, i.Outbound, bool) bool
	TestIPv6(context.Context, i.Outbound) bool
	TestPing(context.Context, i.Outbound) int
}