tools

package

v0.0.0-...-74dbf8d Latest Latest Go to latest Published: May 4, 2022 License: Apache-2.0 Imports: 24 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/viakiba/gate-long-link

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func Base64SuccMessage() []byte
func CalReadData(readLen int, buf []byte, temp []byte) (int32, []byte, []byte)
func CalSendByteData(writeData []byte) []byte
func CalSendData(writeData string) []byte
func CommonInit()
func Debug(args ...interface{})
func Error(args ...interface{})
func Handle(conn net.Conn, agent net.Conn, gate *Gate)
func HandlerShake(conn net.Conn, dialTimeout time.Duration, conType ConnectType) (net.Conn, error)
func Info(args ...interface{})
func InitConfig()
func InitLog(logPath string, errorPath string)
func InitLogSimple()
func WsHandle(conn net.Conn, agent net.Conn, gate *Gate)
func WsHandshake(conn net.Conn, dialTimeout time.Duration) (net.Conn, error)
type CommonConfig
type ConnectType
type Gate
type IKeyIdentify
type IpHostIdentify
type JwtKeyIdentify

Constants ¶

This section is empty.

Variables ¶

View Source

var BytesPool = sync.Pool{
	New: func() interface{} {
		var buffer = bytes.NewBuffer(make([]byte, 2048))
		return buffer
	},
}

BytesPool 字节数据流池化

View Source

var TomlConfig = &tomlConfig{}

TomlConfig 配置

Functions ¶

func Base64SuccMessage ¶

func Base64SuccMessage() []byte

func CalReadData ¶

func CalReadData(readLen int, buf []byte, temp []byte) (int32, []byte, []byte)

func CalSendByteData ¶

func CalSendByteData(writeData []byte) []byte

func CalSendData ¶

func CalSendData(writeData string) []byte

func CommonInit ¶

func CommonInit()

CommonInit 初始化统一的配置

func Debug ¶

func Debug(args ...interface{})

func Error ¶

func Error(args ...interface{})

func Handle ¶

func Handle(conn net.Conn, agent net.Conn, gate *Gate)

Handle 客户端请求处理

func HandlerShake ¶

func HandlerShake(conn net.Conn, dialTimeout time.Duration, conType ConnectType) (net.Conn, error)

HandlerShake 握手

func Info ¶

func Info(args ...interface{})

func InitConfig ¶

func InitConfig()

InitConfig 初始化配置

func InitLog ¶

func InitLog(logPath string, errorPath string)

func InitLogSimple ¶

func InitLogSimple()

func WsHandle ¶

func WsHandle(conn net.Conn, agent net.Conn, gate *Gate)

WsHandle ws 客户端请求处理

func WsHandshake ¶

func WsHandshake(conn net.Conn, dialTimeout time.Duration) (net.Conn, error)

WsHandshake 客户端握手 websocket

Types ¶

type CommonConfig ¶

type CommonConfig struct {
	DialRetry          int    `toml:"dial_retry"`
	HeaderIdentify     string `toml:"header_identify"`
	SuccessRespMessage string `toml:"success_resp_message"`
	ConnectTimeout     int64  `toml:"connect_timeout"`
	KcpIs              int64  `toml:"connect_timeout"`
	KcpReciprocity     bool   `toml:"kcp_reciprocity"`
}

type ConnectType ¶

type ConnectType int

const (
	CONNECT_TYPE_TCP ConnectType = 0
	CONNECT_TYPE_KCP ConnectType = 1
	CONNECT_TYPE_WS  ConnectType = 2
)

type Gate ¶

type Gate struct {
	Port        int  `toml:"port"`
	Enabled     bool `toml:"enabled"`
	DialTimeout int  `toml:"dial_timeout"`
	ZeroCopy    bool `toml:"zero_copy"`
}

Gate 配置

type IKeyIdentify ¶

type IKeyIdentify interface {
	// contains filtered or unexported methods
}

IKeyIdentify 接口

type IpHostIdentify ¶

type IpHostIdentify struct {
}

IpHostIdentify ip:port

type JwtKeyIdentify ¶

type JwtKeyIdentify struct {
}

JwtKeyIdentify jwt token

Source Files ¶

View all Source files

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