Versions in this module Expand all Collapse all v1 v1.6.65 Sep 23, 2024 Changes in this version + const RECV_BUFSIZE_320K v1.6.64 Sep 13, 2024 v1.6.4 Sep 13, 2024 Changes in this version + const DROP_DETECT_WINDOW_SIZE + const LOG_INTERVAL + const ONE_HOUR + const QUEUE_BATCH_NUM + const QUEUE_CACHE_FLUSH_TIMEOUT + const RECORD_STATUS_TIMEOUT + const RECV_BUFSIZE_256K + const RECV_BUFSIZE_2K + const RECV_BUFSIZE_512K + const RECV_BUFSIZE_64K + const RECV_BUFSIZE_8K + const RECV_BUFSIZE_MAX + const RECV_TIMEOUT + const SOCKET_READ_ERROR + const TRIDENT_ADAPTER_STATUS_CMD + func ReadN(r *bufio.Reader, buffer []byte) error + func RegisterTridentStatusCommand() *cobra.Command + func ReleaseRecvBuffer(b *RecvBuffer) + func ValidateFlowVersion(t datatype.MessageType, version uint32) error + type AdapterStatus struct + TCPMetrisStatus []*Status + TCPStatusFlow [datatype.MESSAGE_TYPE_MAX]map[uint16]*Status + TCPStatusLocks [datatype.MESSAGE_TYPE_MAX]sync.RWMutex + TCPStatusOthers [datatype.MESSAGE_TYPE_MAX]map[string]*Status + UDPMetrisStatus []*Status + UDPStatusFlow [datatype.MESSAGE_TYPE_MAX]map[uint16]*Status + UDPStatusLocks [datatype.MESSAGE_TYPE_MAX]sync.Mutex + UDPStatusOthers [datatype.MESSAGE_TYPE_MAX]map[string]*Status + func (s *AdapterStatus) GetStatus(msgType datatype.MessageType) string + func (s *AdapterStatus) Update(now uint32, msgType datatype.MessageType, vtapID, orgId uint16, ip net.IP, ...) + type Handler struct + type QueueCache struct + type Receiver struct + TCPAddress string + TCPListener net.Listener + TCPReadBuffer int + TCPReaderBuffer int + UDPAddress *net.UDPAddr + UDPConn *net.UDPConn + UDPReadBuffer int + func NewReceiver(listenPort, UDPReadBuffer, TCPReadBuffer, TCPReaderBuffer int) *Receiver + func (r *Receiver) Close() error + func (r *Receiver) Closed() bool + func (r *Receiver) GetCounter() interface{} + func (r *Receiver) GetTridentStatus(orgId uint16) []*Status + func (r *Receiver) HandleSimpleCommand(op uint16, arg string) string + func (r *Receiver) ProcessTCPServer() + func (r *Receiver) ProcessUDPServer() + func (r *Receiver) RegistHandler(msgType datatype.MessageType, outQueues queue.MultiQueueWriter, nQueues int) error + func (r *Receiver) SetServerType(serverType ServerType) + func (r *Receiver) Start() + type ReceiverCounter struct + Invalid uint64 + MaxDelay int64 + MinDelay int64 + NewBufferCount uint64 + RxPackets uint64 + UDPDisorder uint64 + UDPDisorderSize uint64 + UDPDropped uint64 + Unregistered uint64 + type RecvBuffer struct + Begin int + Buffer []byte + End int + IP net.IP + OrgID uint16 + SocketType ServerType + TeamID uint32 + VtapID uint16 + func AcquireRecvBuffer(length int, socketType ServerType) (*RecvBuffer, bool) + func (r *RecvBuffer) AddReferenceCount() + func (r *RecvBuffer) String() string + func (r *RecvBuffer) SubReferenceCount() bool + type ServerType byte + const BOTH + const TCP + const UDP + func (s ServerType) String() string + type Status struct + LastLocalTimestamp uint32 + VTAPID uint16 + func NewStatus(now uint32, msgType datatype.MessageType, vtapID, orgId uint16, ip net.IP, ...) *Status
Go to main page