base

type NetworkTopologyConfig struct {
	ReportInterval string `mapstructure:"report_interval"` // The duration of data report interval
	MeterPrefix    string `mapstructure:"meter_prefix"`    // The prefix of meter name
}

type OnCPUConfig struct {
	Period string `mapstructure:"dump_period"` // The duration of dump stack
}

type ProfileTaskRunner interface {
	// Init runner with profiling task and process
	Init(task *ProfilingTask, processes []api.ProcessInterface) error
	// Run profiling, if throw error or method finish means the profiling task finished
	Run(ctx context.Context, notify ProfilingRunningSuccessNotify) error
	// Stop the runner initiative, is typically used to specify the profiling duration
	Stop() error
	// FlushData means dump the exists profiling data and flush them to the backend protocol format
	FlushData() ([]*v3.EBPFProfilingData, error)
}

type ProfilingRunningSuccessNotify func()

type ProfilingTask struct {
	// TaskID of profiling task
	TaskID string
	// ProcessIDList of need to monitoring process
	ProcessIDList []string
	// UpdateTime of profiling task
	UpdateTime int64
	// StartTime of profiling task, when need to start to profiling
	StartTime int64
	// TriggerType of task
	TriggerType TriggerType
	// TargetType of task
	TargetType TargetType
	// MaxRunningDuration of task
	MaxRunningDuration time.Duration
}

type Runner struct {
	StackNotFoundCache map[uint32]bool
	ShutdownOnce       sync.Once
}

type TargetType string

type TaskConfig struct {
	OnCPU   *OnCPUConfig           `mapstructure:"on_cpu"`  // ON_CPU type of profiling task config
	Network *NetworkTopologyConfig `mapstructure:"network"` // NETWORK type of profiling task config
}

type TriggerType string