containerwatcher

type ContainerReceiver interface {
	ContainerCallback(notif containercollection.PubSubEvent)
}

type ContainerWatcher interface {
	Ready() bool
	Start(ctx context.Context) error
	Stop()
	GetTracerCollection() *tracercollection.TracerCollection
	GetContainerCollection() *containercollection.ContainerCollection
	GetSocketEnricher() *socketenricher.SocketEnricher
	GetContainerSelector() *containercollection.ContainerSelector
	RegisterContainerReceiver(receiver ContainerReceiver)
	UnregisterContainerReceiver(receiver ContainerReceiver)
}

type ContainerWatcherMock struct{}

type CustomTracerInitializer interface {
	NewTracer(
		kubeManager operators.DataOperator,
		runtime runtime.Runtime,
		ociStore *orasoci.ReadOnlyStore,
		eventCallback ResultCallback,
		thirdPartyEnricher TaskBasedEnricher,
	) (TracerInterface, error)
}

type CustomTracerMock struct{}

type EnrichedEventReceiver interface {
	ReportEnrichedEvent(enrichedEvent *events.EnrichedEvent)
}

type EventReceiver interface {
	ReportEvent(eventType utils.EventType, event utils.K8sEvent)
}

type GenericEventReceiver interface {
}

type ResultCallback func(utils.K8sEvent, string, uint32)

type TaskBasedEnricher interface {
	SubmitEnrichmentTask(event utils.EnrichEvent, syscalls []uint64, callback ResultCallback, containerID string, processID uint32)
}

type ThirdPartyTracers struct {
	ThirdPartyTracersInitializers mapset.Set[CustomTracerInitializer]
	ThirdPartyEventReceivers      *maps.SafeMap[utils.EventType, mapset.Set[GenericEventReceiver]] // TODO: either EventReceiver or EnrichedEventReceiver
}

type TracerFactoryInterface interface {
	CreateAllTracers(manager TracerRegistrer)
}

type TracerInterface interface {
	// Start initializes and starts the tracer
	Start(ctx context.Context) error

	// Stop gracefully stops the tracer
	Stop() error

	// GetName returns the unique name of the tracer
	GetName() string

	// GetEventType returns the event type this tracer produces
	GetEventType() utils.EventType

	// IsEnabled checks if this tracer should be enabled based on configuration
	IsEnabled(cfg config.Config) bool
}

type TracerRegistrer interface {
	RegisterTracer(tracer TracerInterface)
}