cmd

type DynamicProbeServer[T probe.Probe] struct {
	// contains filtered or unexported fields
}

type EventConfig struct {
	EventSinks []EventSinkConfig `yaml:"sinks" mapstructure:"sinks" json:"sinks"`
	Probes     []ProbeConfig     `yaml:"probes" mapstructure:"probes" json:"probes"`
}

type EventProbeManager struct {
	// contains filtered or unexported fields
}

type EventServer struct {
	*DynamicProbeServer[probe.EventProbe]
}

type EventSinkConfig struct {
	Name string      `yaml:"name" mapstructure:"name" json:"name"`
	Args interface{} `yaml:"args" mapstructure:"args" json:"args"`
}

type InspServerConfig struct {
	DebugMode        bool          `yaml:"debugmode" mapstructure:"debugmode" json:"debugmode"`
	Port             uint16        `yaml:"port" mapstructure:"port" json:"port"`
	EnableController bool          `yaml:"enable_controller" mapstructure:"enable_controller" json:"enable_controller"`
	MetricsConfig    MetricsConfig `yaml:"metrics" mapstructure:"metrics" json:"metrics"`
	EventConfig      EventConfig   `yaml:"event" mapstructure:"event" json:"event"`
}

type MetricsConfig struct {
	Probes []ProbeConfig `yaml:"probes" mapstructure:"probes" json:"probes"`
}

type MetricsProbeManager struct {
	// contains filtered or unexported fields
}

type MetricsServer struct {
	*DynamicProbeServer[probe.MetricsProbe]
	// contains filtered or unexported fields
}

type ProbeConfig struct {
	Name string                 `yaml:"name" mapstructure:"name" json:"name"`
	Args map[string]interface{} `yaml:"args" mapstructure:"args" json:"args"`
}

type ProbeManager[T probe.Probe] interface {
	CreateProbe(config ProbeConfig) (T, error)
	StartProbe(ctx context.Context, probe T) error
	StopProbe(ctx context.Context, probe T) error
}