udp

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

type Addr struct {
	Ip   uint32
	Port uint16
}

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

type Connection struct {

	// These fields are public, because higher protocol should set then in acceptHandler and can use them in closeHandler
	MessageHandle      MessageHandler
	StreamLikeIncoming bool
	UserData           any
	// contains filtered or unexported fields
}

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

type ConnectionID struct {
	IP   uint32 // Actual remote address. Motivation - prevent collisions of hash between clients
	Port uint16 // Actual remote port. Motivation - prevent collisions of hash between clients
	Hash int64  // common connection identifier, defined in VK UDP Protocol. TODO - each side must be able to select its own hash
}

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

type ConnectionStatus uint8

type CryptoKeysUdp struct {
	ReadKey  [32]byte
	WriteKey [32]byte
}

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

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

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

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

type MessageHandler func(message *[]byte, canSave bool)

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

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

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

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

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

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

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

type TransportStats struct {
	// these metrics are valuable in per second calculation
	NewIncomingMessages           atomic.Int64
	MessageHandlerCalled          atomic.Int64 // only for reliable messages
	MessageReleased               atomic.Int64
	DatagramRead                  atomic.Int64
	DatagramWritten               atomic.Int64
	DatagramSizeRead              atomic.Int64
	DatagramSizeWritten           atomic.Int64
	UnreliableMessagesReceived    atomic.Int64
	ObsoletePidReceived           atomic.Int64
	ObsoleteHashReceived          atomic.Int64
	ObsoleteGenerationReceived    atomic.Int64
	ResendRequestReceived         atomic.Int64
	UnreliableMessagesSent        atomic.Int64
	ObsoletePidSent               atomic.Int64
	ObsoleteHashSent              atomic.Int64
	ObsoleteGenerationSent        atomic.Int64
	ResendRequestSent             atomic.Int64
	AckTimerBurned                atomic.Int64
	ResendTimerBurned             atomic.Int64
	ResendRequestTimerBurned      atomic.Int64
	RegenerateTimerBurned         atomic.Int64
	HoleSeqNumsSent               atomic.Int64
	RequestedSeqNumsOutOfWindow   atomic.Int64
	RequestedSeqNumsActuallyAcked atomic.Int64
	RequestedSeqNumsNotAcked      atomic.Int64

	// the absolute values of these metrics are decent for us
	IncomingMessagesInflight atomic.Int64 // messages, that we started to receive, but didn't pass to handler
	OutgoingMessagesInflight atomic.Int64 // not acked outgoing messages
	ConnectionsMapSize       atomic.Int64
	MemoryWaitersSize        atomic.Int64
	AcquiredMemory           atomic.Int64
}