events

Documentation

Index

• func InitRingBuffer(mapFDlist []int) (map[int]chan []byte, error)
• type Events
  • func (ev *Events) CleanupRingBuffer()
  • func (ev *Events) ReadRingBuffer(eventRing *RingBuffer)
  • func (ev *Events) SetupRingBuffer(mapFD int, maxEntries uint32) (chan []byte, error)
• type RingBuffer
  • func (r *RingBuffer) ParseRingData(consumerPosition uint64) *RingData
• type RingData

Functions

func InitRingBuffer

func InitRingBuffer(mapFDlist []int) (map[int]chan []byte, error)

Types

type Events

type Events struct {
	RingBuffers []*RingBuffer
	PageSize    int
	RingCnt     int
	// contains filtered or unexported fields
}

func (*Events) CleanupRingBuffer

func (ev *Events) CleanupRingBuffer()

func (*Events) ReadRingBuffer

func (ev *Events) ReadRingBuffer(eventRing *RingBuffer)

Similar to libbpf poll ring

func (*Events) SetupRingBuffer

func (ev *Events) SetupRingBuffer(mapFD int, maxEntries uint32) (chan []byte, error)

type RingBuffer

type RingBuffer struct {
	Consumerpos     unsafe.Pointer
	Consumer        []byte
	Producerpos     unsafe.Pointer
	Producer        []byte
	Mask            uint64
	RingBufferMapFD int
	Data            unsafe.Pointer
}

func (*RingBuffer) ParseRingData

func (r *RingBuffer) ParseRingData(consumerPosition uint64) *RingData

type RingData

type RingData struct {
	Data          *int32
	Len           uint32
	DataLen       uint32
	RecordLen     uint32
	BusyRecord    bool
	DiscardRecord bool
}