core

Documentation

Index

• type BpfReader
• type BpfSpyer
• type ContainerInfo
• type ReaderType
• type Session
  • func NewSession(name string, config *SessionConfig, buf chan *model.SpyEvent) *Session
  • func (s *Session) ConsumeEvent() error
  • func (s *Session) Name() string
  • func (s *Session) Start() error
  • func (s *Session) Stop() error
• type SessionConfig
• type SessionReader
  • func NewSessionReader(bufSize int, perfReader *perf.Reader, ringBuf *ringbuf.Reader) *SessionReader
  • func (reader *SessionReader) DataRead() (any, error)

Types

type BpfReader

type BpfReader struct {
	PerfReader    *perf.Reader
	RingBufReader *ringbuf.Reader
}

type BpfSpyer

type BpfSpyer interface {
	Start() error
	Stop() error
	ConsumeEvent() error
	Name() string
}

type ContainerInfo

type ContainerInfo struct {
	ContainerId string
	NameSpace   string
}

type ReaderType

type ReaderType int

const (
	PerfReader ReaderType = iota
	RingBufReader
)

type Session

type Session struct {
	Config     *SessionConfig
	DataBuffer chan *model.SpyEvent
	Sig        chan os.Signal
	// contains filtered or unexported fields
}

func NewSession

func NewSession(name string, config *SessionConfig, buf chan *model.SpyEvent) *Session

func (*Session) ConsumeEvent

func (s *Session) ConsumeEvent() error

func (*Session) Name

func (s *Session) Name() string

func (*Session) Start

func (s *Session) Start() error

func (*Session) Stop

func (s *Session) Stop() error

type SessionConfig

type SessionConfig struct {
	Container  ContainerInfo
	Pid        uint32
	StackInfo  bool
	Threshold  uint32
	SampleRate uint32
	Cpu        uint32
	RunTime    uint32 // hour unit
	BufferSize uint32
}

type SessionReader

type SessionReader struct {
	ReaderType ReaderType
	Limiter    *rate.Limiter
	BpfReader  BpfReader
	BufSize    int
	Data       any
	DataChan   chan any
}

func NewSessionReader

func NewSessionReader(bufSize int, perfReader *perf.Reader, ringBuf *ringbuf.Reader) *SessionReader

func (*SessionReader) DataRead

func (reader *SessionReader) DataRead() (any, error)