tcp_proxy_middleware

package
v0.0.0-...-2828958 Latest Latest
Warning

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

Go to latest
Published: May 22, 2021 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IPWhiteListMiddleWare

func IPWhiteListMiddleWare() func(c *TCPSliceRouterContext)

IPWhiteListMiddleWare TCP 权限认证中间件 定义了一份IP白名单,这里是设置127.0.0.1这个 IP 可以通过验证

func TCPBlackListMiddleware

func TCPBlackListMiddleware() func(c *TCPSliceRouterContext)

HTTPBlackListMiddleware ip黑名单

func TCPFlowCountMiddleware

func TCPFlowCountMiddleware() func(c *TCPSliceRouterContext)

func TCPFlowLimitMiddleware

func TCPFlowLimitMiddleware() func(c *TCPSliceRouterContext)

func TCPWhiteListMiddleware

func TCPWhiteListMiddleware() func(c *TCPSliceRouterContext)

HTTPWhiteListMiddleware ip白名单列表

Types

type TCPHandlerFunc

type TCPHandlerFunc func(*TCPSliceRouterContext)

TCPHandlerFunc description

type TCPSliceGroup

type TCPSliceGroup struct {
	*TCPSliceRouter
	// contains filtered or unexported fields
}

TCPSliceGroup group 结构体

func (*TCPSliceGroup) Use

func (g *TCPSliceGroup) Use(middlewares ...TCPHandlerFunc) *TCPSliceGroup

Use 构造回调方法

type TCPSliceRouter

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

TCPSliceRouter router 结构体

func NewTCPSliceRouter

func NewTCPSliceRouter() *TCPSliceRouter

NewTCPSliceRouter 构造 router

func (*TCPSliceRouter) Group

func (g *TCPSliceRouter) Group(path string) *TCPSliceGroup

Group 创建 Group

type TCPSliceRouterContext

type TCPSliceRouterContext struct {
	Ctx context.Context
	*TCPSliceGroup
	// contains filtered or unexported fields
}

TCPSliceRouterContext 上下文

func (*TCPSliceRouterContext) Abort

func (c *TCPSliceRouterContext) Abort()

Abort 跳出中间件方法

func (*TCPSliceRouterContext) Get

func (c *TCPSliceRouterContext) Get(key interface{}) interface{}

Get 获取上下文的值

func (*TCPSliceRouterContext) IsAbort

func (c *TCPSliceRouterContext) IsAbort() bool

IsAbort 是否跳过了回调方法

func (*TCPSliceRouterContext) Next

func (c *TCPSliceRouterContext) Next()

Next 从最先加入的中间件开始回调

func (*TCPSliceRouterContext) Reset

func (c *TCPSliceRouterContext) Reset()

Reset 重置回调

func (*TCPSliceRouterContext) Set

func (c *TCPSliceRouterContext) Set(key, val interface{})

Set 设置上下文的值

type TCPSliceRouterHandler

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

TCPSliceRouterHandler description

func NewTCPSliceRouterHandler

func NewTCPSliceRouterHandler(coreFunc func(*TCPSliceRouterContext) tcp_server.TCPHandler,
	router *TCPSliceRouter) *TCPSliceRouterHandler

NewTCPSliceRouterHandler 创建 TCP 路由处理器

func (*TCPSliceRouterHandler) ServeTCP

func (w *TCPSliceRouterHandler) ServeTCP(ctx context.Context, conn net.Conn)

ServeTCP description

Jump to

Keyboard shortcuts

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