server

Documentation

Index

• type Options
• type TohServer
  • func NewTohServer(options Options) (*TohServer, error)
  • func (s *TohServer) Run()
  • func (s *TohServer) Shutdown(ctx context.Context) error
• type TrafficEvent
• type TrafficEventConsumer

Types

type Options

type Options struct {
	Listen    string // http server listen address. required
	ACL       string // acl json file path. required
	Buf       uint64 // pipe buffer size, default is 1472. optional
	AdminKey  string // admin api authenticate key. optional
	DebugMode bool   // optional
}

type TohServer

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

func NewTohServer

func NewTohServer(options Options) (*TohServer, error)

func (*TohServer) Run

func (s *TohServer) Run()

func (*TohServer) Shutdown

func (s *TohServer) Shutdown(ctx context.Context) error

type TrafficEvent

type TrafficEvent struct {
	Key, ClientIP, RemoteAddr, Network string
	In, Out                            int64
}

type TrafficEventConsumer

type TrafficEventConsumer func(e *TrafficEvent)