events

package

v0.6.0 Latest Latest Go to latest Published: Mar 19, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/apache/skywalking-rover

Links

Open Source Insights

Documentation ¶

Index ¶

func ParseConnectionID(connectionID uint64) (pid, socketFD uint32)
type Event
type SocketCloseEvent
type SocketConnectEvent
type SocketDataUploadEvent
type SocketDetailEvent

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ParseConnectionID ¶

func ParseConnectionID(connectionID uint64) (pid, socketFD uint32)

Types ¶

type Event ¶

type Event interface {
	GetConnectionID() uint64
	GetRandomID() uint64
	Timestamp() time.Time
}

type SocketCloseEvent ¶

type SocketCloseEvent struct {
	ConnectionID uint64
	RandomID     uint64

	StartTime uint64
	EndTime   uint64
	PID       uint32
	SocketFD  uint32
	Success   uint32
}

func (*SocketCloseEvent) GetConnectionID ¶

func (c *SocketCloseEvent) GetConnectionID() uint64

func (*SocketCloseEvent) GetRandomID ¶

func (c *SocketCloseEvent) GetRandomID() uint64

func (*SocketCloseEvent) Timestamp ¶

func (c *SocketCloseEvent) Timestamp() time.Time

type SocketConnectEvent ¶

type SocketConnectEvent struct {
	ConID                 uint64
	RandomID              uint64
	StartTime             uint64
	EndTime               uint64
	PID                   uint32
	SocketFD              uint32
	FuncName              uint8
	Role                  uint8
	SocketFamily          uint8
	ConnectSuccess        uint8
	Pad0                  uint32
	RemoteAddrV4          uint32
	RemoteAddrPort        uint32
	RemoteAddrV6          [16]uint8
	LocalAddrV4           uint32
	LocalAddrPort         uint32
	LocalAddrV6           [16]uint8
	ConnTrackUpstreamIPl  uint64
	ConnTrackUpstreamIPh  uint64
	ConnTrackUpstreamPort uint32
}

func (*SocketConnectEvent) GetConnectionID ¶

func (c *SocketConnectEvent) GetConnectionID() uint64

func (*SocketConnectEvent) GetRandomID ¶

func (c *SocketConnectEvent) GetRandomID() uint64

func (*SocketConnectEvent) Timestamp ¶

func (c *SocketConnectEvent) Timestamp() time.Time

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

	StartTime uint64
	EndTime   uint64

	L4Duration                    uint32
	L3Duration                    uint32
	L3LocalDuration               uint32
	L3OutputDuration              uint32
	L3ResolveMacDuration          uint32
	L3NetFilterDuration           uint32
	L2Duration                    uint32
	L2ReadySendDuration           uint32
	L2SendDuration                uint32
	L2PackageToQueueDuration      uint32
	L3TotalRcvDuration            uint32
	IfIndex                       uint32
	L4PackageRcvFromQueueDuration uint64
	L4TotalPackageSize            uint64
	L2EnterQueueCount             uint8
	L4PackageCount                uint8
	L4RetransmitPackageCount      uint8
	L3ResolveMacCount             uint8
	L3NetFilterCount              uint8
	FunctionName                  enums.SocketFunctionName
	Protocol                      enums.ConnectionProtocol
	SSL                           uint8
}

func (*SocketDetailEvent) DataID ¶

func (d *SocketDetailEvent) DataID() uint64

func (*SocketDetailEvent) GetConnectionID ¶

func (d *SocketDetailEvent) GetConnectionID() uint64

func (*SocketDetailEvent) GetRandomID ¶

func (d *SocketDetailEvent) GetRandomID() uint64

func (*SocketDetailEvent) Timestamp ¶

func (d *SocketDetailEvent) Timestamp() time.Time

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL