Versions in this module Expand all Collapse all v1 v1.0.1 Mar 21, 2025 Changes in this version type Glutton + func (g *Glutton) ProduceTCP(handler string, conn net.Conn, md connection.Metadata, payload []byte, ...) error v1.0.0 Jul 23, 2023 Changes in this version + func NewConsoleLogger(id string) zapcore.Core + func NewFileLogger(id string) zapcore.Core + func NewLogger(id string) *zap.Logger + type DummyLogger struct + func (DummyLogger) Debug(args ...interface{}) + func (DummyLogger) Debugf(format string, args ...interface{}) + func (DummyLogger) Error(args ...interface{}) + func (DummyLogger) Errorf(format string, args ...interface{}) + func (DummyLogger) Fatal(args ...interface{}) + func (DummyLogger) Fatalf(format string, args ...interface{}) + func (DummyLogger) Info(args ...interface{}) + func (DummyLogger) Infof(format string, args ...interface{}) + func (DummyLogger) Panic(args ...interface{}) + func (DummyLogger) Panicf(format string, args ...interface{}) + func (DummyLogger) Warn(args ...interface{}) + func (DummyLogger) Warnf(format string, args ...interface{}) + type Glutton struct + Logger *zap.Logger + Producer *producer.Producer + Server *Server + func New(ctx context.Context) (*Glutton, error) + func (g *Glutton) ConnectionByFlow(ckey [2]uint64) *connection.Metadata + func (g *Glutton) Init() error + func (g *Glutton) MetadataByConnection(conn net.Conn) (*connection.Metadata, error) + func (g *Glutton) NewSSHProxy(destinationURL string) error + func (g *Glutton) NewTelnetProxy(destinationURL string) error + func (g *Glutton) Produce(handler string, conn net.Conn, md *connection.Metadata, payload []byte, ...) error + func (g *Glutton) ProduceUDP(handler string, srcAddr, dstAddr *net.UDPAddr, md *connection.Metadata, ...) error + func (g *Glutton) Shutdown() error + func (g *Glutton) Start() error + func (g *Glutton) UpdateConnectionTimeout(ctx context.Context, conn net.Conn) + type Server struct + func NewServer(tcpPort, udpPort uint) *Server + func (s *Server) Shutdown() error + func (s *Server) Start() error