ctrl

Documentation

Index

• Constants
• Variables
• type XKeeper
  • func NewXKeeper(cnf *conf.Conf, runner *XRunner) *XKeeper
  • func (that *XKeeper) PingKeeper() bool
  • func (that *XKeeper) Run()
  • func (that *XKeeper) SendQuitSig() string
• type XRunner
  • func NewXRunner(cnf *conf.Conf) (r *XRunner)
  • func (that *XRunner) CtrlServer()
  • func (that *XRunner) CtrlShell()
  • func (that *XRunner) GetGeoInfo() (fgeoip, fgeosite string)
  • func (that *XRunner) HasGeoInfo() bool
  • func (that *XRunner) PingXtray() bool
  • func (that *XRunner) RegisterKeeper(keeper *exec.Cmd)
  • func (that *XRunner) RegisterStarter(starter *exec.Cmd)
  • func (that *XRunner) Restart(idx int) (result string)
  • func (that *XRunner) Start()
  • func (that *XRunner) Stop()
  • func (that *XRunner) SwitchyOmega() (omegaPath string)

Constants

const (
	ExtraSocksName = "xtray_runner"
	KtrlSocksName  = "xtray_ktrl"
	XtrayOK        = "ok"
)

const (
	KeeperSocksName = "xtray_keeper"
)

Variables

var StopChan = make(chan struct{})

Types

type XKeeper

type XKeeper struct {
	Conf *conf.Conf
	Cron *cron.Cron
	// contains filtered or unexported fields
}

func NewXKeeper

func NewXKeeper(cnf *conf.Conf, runner *XRunner) *XKeeper

func (*XKeeper) PingKeeper

func (that *XKeeper) PingKeeper() bool

func (*XKeeper) Run

func (that *XKeeper) Run()

func (*XKeeper) SendQuitSig

func (that *XKeeper) SendQuitSig() string

type XRunner

type XRunner struct {
	Client     *client.XClient
	Verifier   *proxy.Verifier
	XKeeper    *XKeeper
	Conf       *conf.Conf
	Cron       *cron.Cron
	ExtraSocks string
	KtrlSocks  string
	Ktrl       *goktrl.Ktrl
	// contains filtered or unexported fields
}

func NewXRunner

func NewXRunner(cnf *conf.Conf) (r *XRunner)

func (*XRunner) CtrlServer

func (that *XRunner) CtrlServer()

func (*XRunner) CtrlShell

func (that *XRunner) CtrlShell()

func (*XRunner) GetGeoInfo

func (that *XRunner) GetGeoInfo() (fgeoip, fgeosite string)

func (*XRunner) HasGeoInfo

func (that *XRunner) HasGeoInfo() bool

func (*XRunner) PingXtray

func (that *XRunner) PingXtray() bool

func (*XRunner) RegisterKeeper

func (that *XRunner) RegisterKeeper(keeper *exec.Cmd)

func (*XRunner) RegisterStarter

func (that *XRunner) RegisterStarter(starter *exec.Cmd)

func (*XRunner) Restart

func (that *XRunner) Restart(idx int) (result string)

func (*XRunner) Start

func (that *XRunner) Start()

func (*XRunner) Stop

func (that *XRunner) Stop()

func (*XRunner) SwitchyOmega

func (that *XRunner) SwitchyOmega() (omegaPath string)