analytics

type BatchedDataStore interface {
	AddSourceEvent(event batched.SourceEvent)
	HeartbeatProperties() batched.HeartbeatProperties
	IncrementTimeWindowInHours()
	Reset()
}

type FatalErrorAnalyticsReporter interface {
	// ReportFatalError reports a fatal app error.
	ReportFatalError(err error) error

	// Close cleans up the reporter resources.
	Close() error
}

type Identity struct {
	DeploymentID          string
	AnonymousID           string
	KubernetesVersion     k8sVersion.Info
	BotkubeVersion        version.Details
	WorkerNodeCount       int
	ControlPlaneNodeCount int
}

type NoopReporter struct{}

type ReportCommandInput struct {
	Platform   config.CommPlatformIntegration
	PluginName string
	Command    string
	Origin     command.Origin
	WithFilter bool
}

type ReportEventInput struct {
	IntegrationType       config.IntegrationType
	Platform              config.CommPlatformIntegration
	PluginName            string
	AnonymizedEventFields map[string]any
}

type ReportPanicLogger interface {
	Errorf(format string, args ...interface{})
	Fatal(args ...interface{})
}

type Reporter interface {
	// RegisterCurrentIdentity loads the current anonymous identity and registers it.
	RegisterCurrentIdentity(ctx context.Context, k8sCli kubernetes.Interface, deployID string) error

	// ReportCommand reports a new executed command. The command should be anonymized before using this method.
	ReportCommand(in ReportCommandInput) error

	// ReportBotEnabled reports an enabled bot.
	ReportBotEnabled(platform config.CommPlatformIntegration, commGroupIdx int) error

	// ReportSinkEnabled reports an enabled sink.
	ReportSinkEnabled(platform config.CommPlatformIntegration, commGroupIdx int) error

	// ReportHandledEventSuccess reports a successfully handled event using a given integration type, communication platform, and plugin.
	ReportHandledEventSuccess(event ReportEventInput) error

	// ReportHandledEventError reports a failure while handling event using a given integration type, communication platform, and plugin.
	ReportHandledEventError(event ReportEventInput, err error) error

	// ReportFatalError reports a fatal app error.
	ReportFatalError(err error) error

	// ReportPluginsEnabled reports plugins enabled.
	ReportPluginsEnabled(executors map[string]config.Executors, sources map[string]config.Sources) error

	Run(ctx context.Context) error

	// Close cleans up the reporter resources.
	Close() error
}

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