httpassembly

Documentation

Index

• type HttpAssembler
  • func NewAssembler(factory HttpStreamFactory) *HttpAssembler
  • func (a *HttpAssembler) Assemble(p gopacket.Packet)
  • func (a *HttpAssembler) FlushCloseOlderThan(t time.Time)
  • func (a *HttpAssembler) ReassembleJob(ctx context.Context, wg *sync.WaitGroup)
• type HttpStream
• type HttpStreamFactory

Types

type HttpAssembler

type HttpAssembler struct {
	Log *slog.Logger
	// contains filtered or unexported fields
}

func NewAssembler

func NewAssembler(factory HttpStreamFactory) *HttpAssembler

func (*HttpAssembler) Assemble

func (a *HttpAssembler) Assemble(p gopacket.Packet)

func (*HttpAssembler) FlushCloseOlderThan

func (a *HttpAssembler) FlushCloseOlderThan(t time.Time)

func (*HttpAssembler) ReassembleJob

func (a *HttpAssembler) ReassembleJob(ctx context.Context, wg *sync.WaitGroup)

type HttpStream

type HttpStream interface {
	ReassembledRequestResponse(req []byte, res []byte, duration float64)
}

type HttpStreamFactory

type HttpStreamFactory interface {
	New() HttpStream
}