statistic

Documentation

Index

• Variables
• func WithProxy(p proxy.Proxy) func(*Shunt)
• type MODE
  • func (m MODE) String() string
• type Shunt
  • func NewShunt(conf config.ConfigObserver, opts ...func(*Shunt)) *Shunt
  • func (s *Shunt) Get(domain string) MODE
  • func (s *Shunt) Refresh() error
• type Statistic
  • func NewStatistic(conf config.ConfigObserver, dialer proxy.Proxy) *Statistic
  • func (c *Statistic) AddClient(f func(*statistic.RateResp) error) (id int64)
  • func (c *Statistic) AddDownload(n uint64)
  • func (c *Statistic) AddUpload(n uint64)
  • func (c *Statistic) CloseConn(_ context.Context, x *statistic.CloseConnsReq) (*emptypb.Empty, error)
  • func (c *Statistic) Conn(host string) (net.Conn, error)
  • func (c *Statistic) Conns(context.Context, *emptypb.Empty) (*statistic.ConnResp, error)
  • func (c *Statistic) PacketConn(host string) (net.PacketConn, error)
  • func (c *Statistic) RemoveClient(id int64)
  • func (c *Statistic) Statistic(_ *emptypb.Empty, srv statistic.Connections_StatisticServer) error

Variables

var BYPASS_DATA []byte

go:embed statics/bypass.gz

var Mode = map[string]*MODE{
	"direct": &DIRECT,

	"block": &BLOCK,
}

Functions

func WithProxy

func WithProxy(p proxy.Proxy) func(*Shunt)

Types

type MODE

type MODE string

var (
	OTHERS MODE = "OTHERS"
	BLOCK  MODE = "BLOCK"
	DIRECT MODE = "DIRECT"
	PROXY  MODE = "PROXY"
	MAX    MODE = "MAX"

	UNKNOWN MODE = "UNKNOWN"
)

func (MODE) String

func (m MODE) String() string

type Shunt

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

func NewShunt

func NewShunt(conf config.ConfigObserver, opts ...func(*Shunt)) *Shunt

NewShunt file: bypass file; lookup: domain resolver, can be nil

func (*Shunt) Get

func (s *Shunt) Get(domain string) MODE

func (*Shunt) Refresh

func (s *Shunt) Refresh() error

type Statistic

type Statistic struct {
	statistic.UnimplementedConnectionsServer
	// contains filtered or unexported fields
}

func NewStatistic

func NewStatistic(conf config.ConfigObserver, dialer proxy.Proxy) *Statistic

func (*Statistic) AddClient

func (c *Statistic) AddClient(f func(*statistic.RateResp) error) (id int64)

func (*Statistic) AddDownload

func (c *Statistic) AddDownload(n uint64)

func (*Statistic) AddUpload

func (c *Statistic) AddUpload(n uint64)

func (*Statistic) CloseConn

func (c *Statistic) CloseConn(_ context.Context, x *statistic.CloseConnsReq) (*emptypb.Empty, error)

func (*Statistic) Conn

func (c *Statistic) Conn(host string) (net.Conn, error)

func (*Statistic) Conns

func (c *Statistic) Conns(context.Context, *emptypb.Empty) (*statistic.ConnResp, error)

func (*Statistic) PacketConn

func (c *Statistic) PacketConn(host string) (net.PacketConn, error)

func (*Statistic) RemoveClient

func (c *Statistic) RemoveClient(id int64)

func (*Statistic) Statistic

func (c *Statistic) Statistic(_ *emptypb.Empty, srv statistic.Connections_StatisticServer) error