observability

type EventReport struct {
	ExecutionID string         `json:"execution_id"`
	EventType   string         `json:"event_type"`
	EventData   map[string]any `json:"event_data"`
	CreatedAt   string         `json:"created_at"`
}

type ExecutionReport struct {
	ID           string    `json:"id"`
	WorkflowID   string    `json:"workflow_id"`
	TriggerType  string    `json:"trigger_type"`
	Status       string    `json:"status"`
	TriggeredBy  string    `json:"triggered_by,omitempty"`
	ErrorMessage string    `json:"error_message,omitempty"`
	StartedAt    time.Time `json:"started_at"`
	CompletedAt  time.Time `json:"completed_at,omitempty"`
	DurationMs   int64     `json:"duration_ms"`
}

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

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

type IngestStore interface {
	IngestExecutions(ctx context.Context, instance string, items []ExecutionReport) error
	IngestLogs(ctx context.Context, instance string, items []LogReport) error
	IngestEvents(ctx context.Context, instance string, items []EventReport) error
	RegisterInstance(ctx context.Context, name string, registeredAt time.Time) error
	Heartbeat(ctx context.Context, name string, timestamp time.Time) error
}

type LogReport struct {
	WorkflowID  string `json:"workflow_id"`
	ExecutionID string `json:"execution_id,omitempty"`
	Level       string `json:"level"`
	Message     string `json:"message"`
	ModuleName  string `json:"module_name,omitempty"`
	Fields      string `json:"fields,omitempty"`
	CreatedAt   string `json:"created_at"`
}

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

type ReporterConfig struct {
	// AdminURL is the base URL of the admin server (e.g., "http://admin-server:8081").
	AdminURL string `yaml:"admin_url" json:"admin_url"`
	// FlushInterval is how often buffered data is sent to the admin server.
	FlushInterval time.Duration `yaml:"flush_interval" json:"flush_interval"`
	// BatchSize is the maximum number of items per flush batch.
	BatchSize int `yaml:"batch_size" json:"batch_size"`
	// InstanceName identifies this worker instance.
	InstanceName string `yaml:"instance_name" json:"instance_name"`
	// HeartbeatInterval is how often to send heartbeats to the admin server.
	HeartbeatInterval time.Duration `yaml:"heartbeat_interval" json:"heartbeat_interval"`
}

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

type WorkerInstance struct {
	Name         string `json:"name"`
	Status       string `json:"status"`
	LastSeen     string `json:"last_seen"`
	RegisteredAt string `json:"registered_at"`
}