agents

type AckAgent struct {
	FrameProducingAgent
	DisableAcks         map[PNSpace]bool
	TotalDataAcked      map[PNSpace]uint64
	DisablePathResponse bool
}

type Agent interface {
	Name() string
	Init(name string, ODCID ConnectionID)
	Run(conn *Connection)
	Stop()
	Restart()
	Join()
}

type BaseAgent struct {
	Logger *log.Logger
	// contains filtered or unexported fields
}

type BufferAgent struct {
	BaseAgent
}

type ClosingAgent struct {
	BaseAgent

	IdleDuration time.Duration
	IdleTimeout  *time.Timer
	// contains filtered or unexported fields
}

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

type DecodedHeaders struct {
	StreamID uint64
	Headers  []HTTPHeader
}

type EncodedHeaders struct {
	StreamID uint64
	Headers  []byte
}

type FlowControlAgent struct {
	FrameProducingAgent
	LocalFC               FlowControlLimits
	RemoteFC              FlowControlLimits
	DontSlideCreditWindow bool
	// contains filtered or unexported fields
}

type FlowControlLimits struct {
	StreamsBidi             uint64
	StreamsUni              uint64
	MaxData                 uint64
	MaxStreamDataBidiLocal  uint64
	MaxStreamDataBidiRemote uint64
	MaxStreamDataUni        uint64
}

type FramePriorityQueue []*item

type FrameProducer interface {
	RequestFrames(availableSpace int, level EncryptionLevel, number PacketNumber) ([]Frame, bool)
}

type FrameProducingAgent struct {
	BaseAgent
	// contains filtered or unexported fields
}

type FrameQueueAgent struct {
	FrameProducingAgent
}

type HTTP09Agent struct {
	BaseAgent
	// contains filtered or unexported fields
}

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

type HTTP3Agent struct {
	BaseAgent

	DisableQPACKStreams bool
	QPACK               QPACKAgent
	QPACKEncoderOpts    uint32

	FrameReceived    Broadcaster //type: HTTP3FrameReceived
	ReceivedSettings *http3.SETTINGS
	// contains filtered or unexported fields
}

type HTTP3FrameReceived struct {
	StreamID uint64
	Frame    http3.HTTPFrame
}

type HTTP3Response struct {
	HTTP09Response
	// contains filtered or unexported fields
}

type HTTPAgent interface {
	Agent
	SendRequest(path, method, authority string, headers map[string]string) chan HTTPResponse
	HTTPResponseReceived() Broadcaster
}

type HTTPHeader struct {
	Name, Value string
}

type HTTPResponse interface {
	StreamID() uint64
	Headers() []HTTPHeader
	Body() []byte
}

type HandshakeAgent struct {
	BaseAgent
	TLSAgent        *TLSAgent
	SocketAgent     *SocketAgent
	HandshakeStatus Broadcaster //type: HandshakeStatus
	IgnoreRetry     bool
	DontDropKeys    bool
	// contains filtered or unexported fields
}

type HandshakeStatus struct {
	Completed bool
	Packet
	Error error
}

type ParsingAgent struct {
	BaseAgent
	// contains filtered or unexported fields
}

type QLogAgent struct {
	BaseAgent
}

type QPACKAgent struct {
	BaseAgent
	EncoderStreamID uint64
	DecoderStreamID uint64
	DisableStreams  bool
	DecodeHeaders   chan EncodedHeaders
	DecodedHeaders  Broadcaster //type: DecodedHeaders
	EncodeHeaders   chan DecodedHeaders
	EncodedHeaders  Broadcaster //type: EncodedHeaders
	// contains filtered or unexported fields
}

type RTTAgent struct {
	BaseAgent

	MinRTT             uint64
	LatestRTT          uint64
	SmoothedRTT        uint64
	RTTVar             uint64
	MaxAckDelay        uint64
	SentPackets        map[PNSpace]map[PacketNumber]SentPacket
	LargestSentPackets map[PNSpace]PacketNumber
	// contains filtered or unexported fields
}

type RecoveryAgent struct {
	BaseAgent

	TimerValue time.Duration
	// contains filtered or unexported fields
}

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

type RetransmitBatch []RetransmittableFrames

type RetransmittableFrames struct {
	Frames    []Frame
	Timestamp time.Time
	Level     EncryptionLevel
}

type SendingAgent struct {
	BaseAgent
	MTU                         uint16
	FrameProducer               []FrameProducer
	DontCoalesceZeroRTT         bool
	KeepDroppedEncryptionLevels bool
}

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

type SocketAgent struct {
	BaseAgent

	TotalDataReceived int
	DatagramsReceived int
	SocketStatus      Broadcaster //type: err
	// contains filtered or unexported fields
}

type StreamAgent struct {
	FrameProducingAgent

	FlowControlAgent *FlowControlAgent
	// contains filtered or unexported fields
}

type TLSAgent struct {
	BaseAgent
	TLSStatus           Broadcaster //type: TLSStatus
	ResumptionTicket    Broadcaster //type: []byte
	DisableFrameSending bool
}

type TLSStatus struct {
	Completed bool
	Packet
	Error error
}