connection

package
v0.0.0-...-4972dd0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 15, 2020 License: BSD-3-Clause Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source
const (
	HEAD_TAG_LENGTH   = 8
	STATUS_TAG_LENGTH = 8
)
View Source
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)
)

Variables

This section is empty.

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()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL