events

Documentation

Index

• type SocketCloseEvent
• type SocketConnectEvent
• type SocketDataUploadEvent
  • func (s *SocketDataUploadEvent) BufferData() []byte
  • func (s *SocketDataUploadEvent) BufferLen() int
  • func (s *SocketDataUploadEvent) BufferStartPosition() int
  • func (s *SocketDataUploadEvent) DataID() uint64
  • func (s *SocketDataUploadEvent) DataSequence() int
  • func (s *SocketDataUploadEvent) Direction() enums.SocketDataDirection
  • func (s *SocketDataUploadEvent) EndTime() uint64
  • func (s *SocketDataUploadEvent) GenerateConnectionID() string
  • func (s *SocketDataUploadEvent) HaveReduceDataAfterChunk() bool
  • func (s *SocketDataUploadEvent) IsFinished() bool
  • func (s *SocketDataUploadEvent) IsStart() bool
  • func (s *SocketDataUploadEvent) StartTime() uint64
  • func (s *SocketDataUploadEvent) TotalSize() uint64
• type SocketDetailEvent
  • func (s *SocketDetailEvent) DataID() uint64
  • func (s *SocketDetailEvent) GenerateConnectionID() string

Types

type SocketCloseEvent

type SocketCloseEvent struct {
	ConID    uint64
	RandomID uint64
	ExeTime  uint64
	Pid      uint32
	SocketFD uint32
	Protocol enums.ConnectionProtocol
	IsSSL    uint8
	Fix      uint16
	Role     enums.ConnectionRole

	SocketFamily   uint32
	RemoteAddrV4   uint32
	RemoteAddrV6   [16]uint8
	RemoteAddrPort uint32
	LocalAddrV4    uint32
	LocalAddrV6    [16]uint8
	LocalAddrPort  uint32
	Fix1           uint32

	WriteBytes   uint64
	WriteCount   uint64
	WriteExeTime uint64
	ReadBytes    uint64
	ReadCount    uint64
	ReadExeTime  uint64

	WriteRTTCount   uint32
	WriteRTTExeTime uint32
}

type SocketConnectEvent

type SocketConnectEvent struct {
	ConID        uint64
	RandomID     uint64
	ExeTime      uint64
	NeedComplete uint32
	Pid          uint32
	FD           uint32
	FuncName     uint32

	// socket information if exists
	Role           enums.ConnectionRole
	SocketFamily   uint32
	RemoteAddrV4   uint32
	RemoteAddrV6   [16]uint8
	RemoteAddrPort uint32
	LocalAddrV4    uint32
	LocalAddrV6    [16]uint8
	LocalAddrPort  uint32
}

SocketConnectEvent Socket have been connection/accept event

type SocketDataUploadEvent

type SocketDataUploadEvent struct {
	Protocol     enums.ConnectionProtocol
	HaveReduce   uint8
	Direction0   enums.SocketDataDirection
	Finished     uint8
	Sequence0    uint16
	DataLen      uint16
	StartTime0   uint64
	EndTime0     uint64
	ConnectionID uint64
	RandomID     uint64
	DataID0      uint64
	TotalSize0   uint64
	Buffer       [2048]byte
}

func (*SocketDataUploadEvent) BufferData

func (s *SocketDataUploadEvent) BufferData() []byte

func (*SocketDataUploadEvent) BufferLen

func (s *SocketDataUploadEvent) BufferLen() int

func (*SocketDataUploadEvent) BufferStartPosition

func (s *SocketDataUploadEvent) BufferStartPosition() int

func (*SocketDataUploadEvent) DataID

func (s *SocketDataUploadEvent) DataID() uint64

func (*SocketDataUploadEvent) DataSequence

func (s *SocketDataUploadEvent) DataSequence() int

func (*SocketDataUploadEvent) Direction

func (s *SocketDataUploadEvent) Direction() enums.SocketDataDirection

func (*SocketDataUploadEvent) EndTime

func (s *SocketDataUploadEvent) EndTime() uint64

func (*SocketDataUploadEvent) GenerateConnectionID

func (s *SocketDataUploadEvent) GenerateConnectionID() string

func (*SocketDataUploadEvent) HaveReduceDataAfterChunk

func (s *SocketDataUploadEvent) HaveReduceDataAfterChunk() bool

func (*SocketDataUploadEvent) IsFinished

func (s *SocketDataUploadEvent) IsFinished() bool

func (*SocketDataUploadEvent) IsStart

func (s *SocketDataUploadEvent) IsStart() bool

func (*SocketDataUploadEvent) StartTime

func (s *SocketDataUploadEvent) StartTime() uint64

func (*SocketDataUploadEvent) TotalSize

func (s *SocketDataUploadEvent) TotalSize() uint64

type SocketDetailEvent

type SocketDetailEvent struct {
	ConnectionID     uint64
	RandomID         uint64
	DataID0          uint64
	TotalPackageSize uint64
	IfIndex          uint32
	PackageCount     uint8
	FuncName         enums.SocketFunctionName
	RTTCount         uint8
	Protocol         enums.ConnectionProtocol
	RTTTime          uint32
}

func (*SocketDetailEvent) DataID

func (s *SocketDetailEvent) DataID() uint64

func (*SocketDetailEvent) GenerateConnectionID

func (s *SocketDetailEvent) GenerateConnectionID() string