executor

Documentation

Index

• Constants
• type Executor
  • func NewExecutor() *Executor
  • func (p *Executor) AddNode(n adapter.AdapterProxy)
  • func (p *Executor) AddNodeByClash(m map[string]any) error
  • func (p *Executor) AddNodeByV2rayLink(s string) error
  • func (p *Executor) ChooseProxy() adapter.AdapterProxy
  • func (p *Executor) CleanDeadNodes()
  • func (p *Executor) Listen(port string) error
  • func (p *Executor) OnDelayCheck(logic func(node adapter.AdapterProxy, delay time.Duration))
  • func (p *Executor) OnNodeAdd(logic func(node adapter.AdapterProxy))
  • func (p *Executor) OnNodeDel(logic func(node adapter.AdapterProxy))
  • func (p *Executor) SetAdapterRule(ar *rule.AdapterRule)
• type ExecutorCallback

Constants

const (
	Alive    = "alive"
	Delay    = "delay"
	Speed    = "speed"
	SpeedStr = "speed_str"
)

Types

type Executor

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

func NewExecutor

func NewExecutor() *Executor

func (*Executor) AddNode

func (p *Executor) AddNode(n adapter.AdapterProxy)

func (*Executor) AddNodeByClash

func (p *Executor) AddNodeByClash(m map[string]any) error

func (*Executor) AddNodeByV2rayLink

func (p *Executor) AddNodeByV2rayLink(s string) error

func (*Executor) ChooseProxy

func (p *Executor) ChooseProxy() adapter.AdapterProxy

func (*Executor) CleanDeadNodes

func (p *Executor) CleanDeadNodes()

func (*Executor) Listen

func (p *Executor) Listen(port string) error

func (*Executor) OnDelayCheck

func (p *Executor) OnDelayCheck(logic func(node adapter.AdapterProxy, delay time.Duration))

func (*Executor) OnNodeAdd

func (p *Executor) OnNodeAdd(logic func(node adapter.AdapterProxy))

func (*Executor) OnNodeDel

func (p *Executor) OnNodeDel(logic func(node adapter.AdapterProxy))

func (*Executor) SetAdapterRule

func (p *Executor) SetAdapterRule(ar *rule.AdapterRule)

type ExecutorCallback

type ExecutorCallback struct {
	OnNodeAdd    func(node adapter.AdapterProxy)
	OnNodeDel    func(node adapter.AdapterProxy)
	OnDelayCheck func(node adapter.AdapterProxy, delay time.Duration)
}