Documentation
¶
Index ¶
- type Glutton
- 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) ProduceTCP(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()
- func (g *Glutton) Start() error
- func (g *Glutton) UpdateConnectionTimeout(ctx context.Context, conn net.Conn) error
- type Server
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Glutton ¶
type Glutton struct { Logger *slog.Logger Server *Server Producer *producer.Producer // contains filtered or unexported fields }
Glutton struct
func (*Glutton) ConnectionByFlow ¶
func (g *Glutton) ConnectionByFlow(ckey [2]uint64) connection.Metadata
ConnectionByFlow returns connection metadata by connection key
func (*Glutton) MetadataByConnection ¶
MetadataByConnection returns connection metadata by connection
func (*Glutton) ProduceTCP ¶ added in v1.0.1
func (*Glutton) ProduceUDP ¶
Click to show internal directories.
Click to hide internal directories.