engine

Documentation

Index

• type ActionType
  • func JudgeAction(curr, spec bool) ActionType
• type Engine
  • func NewEngine(ctx context.Context, cfg *config.Config) (*Engine, error)
  • func (e *Engine) Cleanup()
  • func (e *Engine) Start()
• type Option
  • func NewEngineOption() *Option
  • func (s *Option) GetProxyStatus() bool
  • func (s *Option) GetTunnelStatus() bool
  • func (s *Option) SetProxyStatus(status bool)
  • func (s *Option) SetTunnelStatus(status bool)
• type ProxyContext
• type ProxyEngine
  • func (p *ProxyEngine) Handler() error
  • func (p *ProxyEngine) Status() bool
• type TunnelEngine
  • func (c *TunnelEngine) CleanupDriver()
  • func (c *TunnelEngine) Handler() error
  • func (c *TunnelEngine) InitDriver() error
  • func (c *TunnelEngine) Status() bool

Types

type ActionType

type ActionType string

const (
	StartType   ActionType = "Start"
	StopType    ActionType = "Stop"
	RestartType ActionType = "Restart"
	SkipType    ActionType = "Skip"
)

func JudgeAction

func JudgeAction(curr, spec bool) ActionType

type Engine

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

func NewEngine

func NewEngine(ctx context.Context, cfg *config.Config) (*Engine, error)

func (*Engine) Cleanup

func (e *Engine) Cleanup()

func (*Engine) Start

func (e *Engine) Start()

type Option

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

func NewEngineOption

func NewEngineOption() *Option

func (*Option) GetProxyStatus

func (s *Option) GetProxyStatus() bool

func (*Option) GetTunnelStatus

func (s *Option) GetTunnelStatus() bool

func (*Option) SetProxyStatus

func (s *Option) SetProxyStatus(status bool)

func (*Option) SetTunnelStatus

func (s *Option) SetTunnelStatus(status bool)

type ProxyContext

type ProxyContext interface {
	ReloadClientContext(ctx context.Context)
	ReloadServerContext(ctx context.Context)
	GetClientContext() context.Context
	GetServerContext() context.Context
	GetClientCancelFunc() context.CancelFunc
	GetServerCancelFunc() context.CancelFunc
}

type ProxyEngine

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

func (*ProxyEngine) Handler

func (p *ProxyEngine) Handler() error

func (*ProxyEngine) Status

func (p *ProxyEngine) Status() bool

type TunnelEngine

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

func (*TunnelEngine) CleanupDriver

func (c *TunnelEngine) CleanupDriver()

func (*TunnelEngine) Handler

func (c *TunnelEngine) Handler() error

sync syncs full state according to the gateway list.

func (*TunnelEngine) InitDriver

func (c *TunnelEngine) InitDriver() error

func (*TunnelEngine) Status

func (c *TunnelEngine) Status() bool