observer

Feb 20, 2023

Changes in this version

+ var SensorManager *sensors.Manager

+ func AllListeners(msg notify.Message)

+ func DataAdd(id dataapi.DataEventId, msgData []byte) error

+ func DataGet(id dataapi.DataEventId) ([]byte, error)

+ func DataPurge()

+ func DockerRun(t *testing.T, args ...string) (containerId string)

+ func ExecWGCurl(readyWG *sync.WaitGroup, retries uint, args ...string) error

+ func GetDefaultSensorsWithFile(t *testing.T, ctx context.Context, file, lib string) ([]*sensors.Sensor, error)

+ func GetMyPid() uint32

+ func InitDataCache(size int) error

+ func LoopEvents(ctx context.Context, t *testing.T, doneWG, readyWG *sync.WaitGroup, ...)

+ func RegisterEventHandlerAtInit(ev uint8, handler func(r *bytes.Reader) ([]Event, error))

+ func RemovePrograms(bpfDir, mapDir string)

+ func WaitForProcess(process string) error

+ func WriteConfigFile(fileName, config string) error

+ type Channel struct

+ func NewChannel(conn net.Conn) *Channel

+ func (o Channel) Close() error

+ func (o Channel) Notify(msg interface{}) error

+ type Event notify.Message

+ func HandleData(r *bytes.Reader) ([]Event, error)

+ func HandlePerfData(data []byte) (byte, []Event, error)

+ type Listener interface

+ Notify func(msg notify.Message) error

+ type Observer struct

+ func GetDefaultObserver(t *testing.T, ctx context.Context, lib string) (*Observer, error)

+ func GetDefaultObserverWithBase(t *testing.T, ctx context.Context, b *sensors.Sensor, file, lib string) (*Observer, error)

+ func GetDefaultObserverWithFile(t *testing.T, ctx context.Context, file, lib string) (*Observer, error)

+ func GetDefaultObserverWithFileNoTest(t *testing.T, ctx context.Context, file, lib string, fail bool) (*Observer, error)

+ func GetDefaultObserverWithLib(t *testing.T, ctx context.Context, config, lib string) (*Observer, error)

+ func GetDefaultObserverWithWatchers(t *testing.T, ctx context.Context, base *sensors.Sensor, opts ...TestOption) (*Observer, error)

+ func NewObserver(configFile string) *Observer

+ func (k *Observer) AddListener(listener Listener)

+ func (k *Observer) InitSensorManager() error

+ func (k *Observer) LogPinnedBpf(observerDir string)

+ func (k *Observer) PrintStats()

+ func (k *Observer) ReadErrorEvents() uint64

+ func (k *Observer) ReadLostEvents() uint64

+ func (k *Observer) ReadReceivedEvents() uint64

+ func (k *Observer) Remove()

+ func (k *Observer) RemoveListener(listener Listener)

+ func (k *Observer) RemovePrograms()

+ func (k *Observer) Start(ctx context.Context) error

+ func (k *Observer) UpdateRuntimeConf(mapDir string) error

+ type TestOption func(*TestOptions)

+ func WithConfig(config string) TestOption

+ func WithLib(lib string) TestOption

+ type TestOptions struct