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 Filter interface {
	GetHandlers() ([]outHandler, error)
}

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

type HandlersBeingUsedUpdate func([]string)

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

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

type Selector struct {
	util.IPv6SupportChangeNotifier

	LandHandlers []*xsqlite.OutboundHandler
	// contains filtered or unexported fields
}

type SelectorConfig struct {
	*configs.SelectorConfig
	CreateHandler             CreateHandlerFunc
	HandlerErrorChangeSubject HandlerErrorChangeSubject
	Tester                    Tester
	Database                  Db
	OutboundManager           *outbound.Manager
	OnHandlerBeingUsedChange  HandlersBeingUsedUpdate
	LandHandlers              []*xsqlite.OutboundHandler
}

type Selectors struct {

	// notify listeners when any selector's ipv6 support changed or any selector is added or removed
	i.IPv6SupportChangeSubject
	// 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
}