signal

Documentation

Index

• type Bus
  • func Signal() *Bus
  • func (sb *Bus) Daemon(ctx context.Context)
  • func (sb *Bus) Recover(ctx context.Context, recover string)
  • func (sb *Bus) SendProviderSignal(p uint, tp enum.ProviderStatus)
  • func (sb *Bus) SendProviderSignalSync(p uint, tp enum.ProviderStatus)
  • func (sb *Bus) SendProxySignal(p uint, tp enum.ProxyStatus)
  • func (sb *Bus) SendProxySignalSync(p uint, tp enum.ProxyStatus)
  • func (sb *Bus) SendTunnelSignal(p uint, tp enum.TunnelStatus)
  • func (sb *Bus) SendTunnelSignalSync(p uint, tp enum.TunnelStatus)

Types

type Bus

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

Bus 用于控制所有需要异步处理的状态转换

func Signal

func Signal() *Bus

func (*Bus) Daemon

func (sb *Bus) Daemon(ctx context.Context)

Daemon 控制总线守护进程

func (*Bus) Recover

func (sb *Bus) Recover(ctx context.Context, recover string)

func (*Bus) SendProviderSignal

func (sb *Bus) SendProviderSignal(p uint, tp enum.ProviderStatus)

func (*Bus) SendProviderSignalSync

func (sb *Bus) SendProviderSignalSync(p uint, tp enum.ProviderStatus)

func (*Bus) SendProxySignal

func (sb *Bus) SendProxySignal(p uint, tp enum.ProxyStatus)

func (*Bus) SendProxySignalSync

func (sb *Bus) SendProxySignalSync(p uint, tp enum.ProxyStatus)

func (*Bus) SendTunnelSignal

func (sb *Bus) SendTunnelSignal(p uint, tp enum.TunnelStatus)

func (*Bus) SendTunnelSignalSync

func (sb *Bus) SendTunnelSignalSync(p uint, tp enum.TunnelStatus)