xgress

type AckSender interface {
	SendAck(ack *Acknowledgement, address Address)
}

type Acknowledgement struct {
	CircuitId      string
	Flags          uint32
	RecvBufferSize uint32
	RTT            uint16
	Sequence       []int32
}

type Address string

type BindHandler interface {
	HandleXgressBind(x *Xgress)
}

type CircuitDetail struct {
	CircuitId  string `json:"circuitId"`
	ConnId     uint32 `json:"connId"`
	Address    string `json:"address"`
	Originator string `json:"originator"`
	IsXgress   bool   `json:"isXgress"`
	CtrlId     string `json:"ctrlId"`
}

type CircuitInspectDetail struct {
	CircuitId       string                    `json:"circuitId"`
	Forwards        map[string]string         `json:"forwards"`
	XgressDetails   map[string]*InspectDetail `json:"xgressDetails"`
	RelatedEntities map[string]map[string]any `json:"relatedEntities"`
	Errors          []string                  `json:"errors"`
	// contains filtered or unexported fields
}

type CircuitsDetail struct {
	Circuits map[string]*CircuitDetail `json:"circuits"`
}

type CloseHandler interface {
	// HandleXgressClose is invoked when the connected peer terminates the communication.
	//
	HandleXgressClose(x *Xgress)
}

type CloseHandlerF func(x *Xgress)

type Connection interface {
	io.Closer
	LogContext() string
	ReadPayload() ([]byte, map[uint8][]byte, error)
	WritePayload([]byte, map[uint8][]byte) (int, error)

	HandleControlMsg(controlType ControlType, headers channel.Headers, responder ControlReceiver) error
}

type Control struct {
	Type      ControlType
	CircuitId string
	Headers   channel.Headers
}

type ControlReceiver interface {
	HandleControlReceive(controlType ControlType, headers channel.Headers)
}

type ControlType byte

type DataPlaneAdapter interface {
	// ForwardPayload is used to forward data payloads onto the data-plane from an xgress
	ForwardPayload(payload *Payload, x *Xgress, ctx context.Context)

	// RetransmitPayload is used to retransmit data payloads onto the data-plane from an xgress
	RetransmitPayload(srcAddr Address, payload *Payload) error

	// ForwardControlMessage is used to forward control messages onto the data-plane from an xgress
	ForwardControlMessage(control *Control, x *Xgress)

	// ForwardAcknowledgement is used to forward acks onto the data-plane from an xgress
	ForwardAcknowledgement(ack *Acknowledgement, address Address)

	Env
}

type Decoder struct{}

type Env interface {
	GetRetransmitter() *Retransmitter
	GetPayloadIngester() *PayloadIngester
	GetMetrics() Metrics
}

type Flag uint32

type InspectDetail struct {
	Address               string            `json:"address"`
	Originator            string            `json:"originator"`
	TimeSinceLastLinkRx   string            `json:"timeSinceLastLinkRx"`
	SendBufferDetail      *SendBufferDetail `json:"sendBufferDetail"`
	RecvBufferDetail      *RecvBufferDetail `json:"recvBufferDetail"`
	XgressPointer         string            `json:"xgressPointer"`
	LinkSendBufferPointer string            `json:"linkSendBufferPointer"`
	Goroutines            []string          `json:"goroutines"`
	Sequence              uint64            `json:"sequence"`
	Flags                 string            `json:"flags"`
	LastSizeSent          uint32            `json:"lastSizeSent"`
}

type InvalidTerminatorError struct {
	InnerError error
}

type LinkReceiveBuffer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

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

type Metrics interface {
	MarkAckReceived()
	MarkPayloadDropped()
	MarkDuplicateAck()
	MarkDuplicatePayload()
	BufferBlockedByLocalWindow()
	BufferUnblockedByLocalWindow()
	BufferBlockedByRemoteWindow()
	BufferUnblockedByRemoteWindow()

	PayloadWritten(duration time.Duration)
	BufferUnblocked(duration time.Duration)

	SendPayloadBuffered(payloadSize int64)
	SendPayloadDelivered(payloadSize int64)
}

type MisconfiguredTerminatorError struct {
	InnerError error
}

type Options struct {
	Mtu         int32
	RandomDrops bool
	Drop1InN    int32
	TxQueueSize int32

	TxPortalStartSize      uint32
	TxPortalMaxSize        uint32
	TxPortalMinSize        uint32
	TxPortalIncreaseThresh uint32
	TxPortalIncreaseScale  float64
	TxPortalRetxThresh     uint32
	TxPortalRetxScale      float64
	TxPortalDupAckThresh   uint32
	TxPortalDupAckScale    float64

	RxBufferSize uint32
	RetxStartMs  uint32
	RetxScale    float64
	RetxAddMs    uint32

	MaxCloseWait        time.Duration
	GetCircuitTimeout   time.Duration
	CircuitStartTimeout time.Duration
	ConnectTimeout      time.Duration
}

type OptionsData map[interface{}]interface{}

type Originator int32

type Payload struct {
	CircuitId string
	Flags     uint32
	RTT       uint16
	Sequence  int32
	Headers   map[uint8][]byte
	Data      []byte
	// contains filtered or unexported fields
}

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

type PayloadTransformer struct {
}

type PayloadType byte

type PeekHandler interface {
	Rx(x *Xgress, payload *Payload)
	Tx(x *Xgress, payload *Payload)
	Close(x *Xgress)
}

type RecvBufferDetail struct {
	Size           uint32 `json:"size"`
	PayloadCount   uint32 `json:"payloadCount"`
	Sequence       int32  `json:"sequence"`
	MaxSequence    int32  `json:"maxSequence"`
	NextPayload    string `json:"nextPayload"`
	AcquiredSafely bool   `json:"acquiredSafely"`
}

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

type RetransmitterFaultReporter interface {
	ReportForwardingFault(circuitId string, ctrlId string)
}

type SendBufferDetail struct {
	WindowSize            uint32  `json:"windowSize"`
	QueuedPayloadCount    int     `json:"queuedPayloadCount"`
	LinkSendBufferSize    uint32  `json:"linkSendBufferSize"`
	LinkRecvBufferSize    uint32  `json:"linkRecvBufferSize"`
	Accumulator           uint32  `json:"accumulator"`
	SuccessfulAcks        uint32  `json:"successfulAcks"`
	DuplicateAcks         uint32  `json:"duplicateAcks"`
	Retransmits           uint32  `json:"retransmits"`
	Closed                bool    `json:"closed"`
	BlockedByLocalWindow  bool    `json:"blockedByLocalWindow"`
	BlockedByRemoteWindow bool    `json:"blockedByRemoteWindow"`
	RetxScale             float64 `json:"retxScale"`
	RetxThreshold         uint32  `json:"retxThreshold"`
	TimeSinceLastRetx     string  `json:"timeSinceLastRetx"`
	CloseWhenEmpty        bool    `json:"closeWhenEmpty"`
	AcquiredSafely        bool    `json:"acquiredSafely"`
}

type SignalConnection interface {
	Connection
	FlowFromFabricToXgressClosed()
}

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

type Xgress struct {
	Options *Options
	// contains filtered or unexported fields
}