server

type Conn struct {

	// Record remote ip
	KuloyClient
	// contains filtered or unexported fields
}

type HandleFunc func(ctx context.Context, conn net.Conn)

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

type TCPHandler interface {
	ServeTCP(ctx context.Context, conn net.Conn)
}

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

type TcpHandlerFunc func(*TcpSliceRouterContext)

type TcpServer struct {
	Addr    string
	Handler TCPHandler

	WriteTimeout     time.Duration
	ReadTimeout      time.Duration
	KeepAliveTimeout time.Duration

	NotifyStarted func()
	// contains filtered or unexported fields
}

type TcpSliceGroup struct {
	*TcpSliceRouter
	// contains filtered or unexported fields
}

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

type TcpSliceRouterContext struct {
	Ctx context.Context
	*TcpSliceGroup
	// contains filtered or unexported fields
}

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