connection

Documentation

Index

• Constants
• func GetCurrentConnectionCount() int
• func GetLocalServerFd() (*os.File, error)
• func HandleConn(conn *net.Conn)
• func StartLocalServer() error
• func StartPProf()
• func StopConsole()
• func StopLocalServer()
• func StopPProf()
• type ConnAction
  • func (_ ConnAction) String()
• type ConnActionStatus
• type ProcessResult
• type Request
• type Stats
• type StatsMessage
• type StoppingSigalOp
  • func (sso *StoppingSigalOp) SendSignal()
  • func (sso *StoppingSigalOp) Unuse()
  • func (sso *StoppingSigalOp) Use()

Constants

const (
	HEAD_TAG_LENGTH   = 8
	STATUS_TAG_LENGTH = 8
)

const (
	// 内存保存的最大统计数据天数
	MAX_IN_MEM_STATS_LENGTH  = 30
	GC_IN_MEM_STATS_INTERVAL = time.Minute * 60
	CONNACTION_ACCEPT        = ConnAction(1)
	CONNACTION_RESPONSE      = ConnAction(2)
	CONNACTION_PROCESS_FIN   = ConnAction(3)

	CONNACTION_STATUS_OK     = ConnActionStatus(1)
	CONNACTION_STATUS_FAILED = ConnActionStatus(1)
)

Functions

func GetCurrentConnectionCount

func GetCurrentConnectionCount() int

func GetLocalServerFd

func GetLocalServerFd() (*os.File, error)

func HandleConn

func HandleConn(conn *net.Conn)

处理获取配置的连接请求

func StartLocalServer

func StartLocalServer() error

启动本地配置服务

func StartPProf

func StartPProf()

启动pprof分析服务.

func StopConsole

func StopConsole()

func StopLocalServer

func StopLocalServer()

func StopPProf

func StopPProf()

关闭pprof分析服务.

Types

type ConnAction

type ConnAction int8

func (ConnAction) String

func (_ ConnAction) String()

type ConnActionStatus

type ConnActionStatus int8

type ProcessResult

type ProcessResult struct {
	Result []byte
	Error  error
}

type Request

type Request struct {
	Closed bool
	Body   []byte
	Err    error
}

type Stats

type Stats struct {
	TotalReq    int
	FinishedReq int
	FailedReq   int
}

type StatsMessage

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

type StoppingSigalOp

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

func (*StoppingSigalOp) SendSignal

func (sso *StoppingSigalOp) SendSignal()

func (*StoppingSigalOp) Unuse

func (sso *StoppingSigalOp) Unuse()

func (*StoppingSigalOp) Use

func (sso *StoppingSigalOp) Use()