schema

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

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

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

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

type Property struct {
	Type        string               `json:"type"`
	Description string               `json:"description"`
	Format      string               `json:"format,omitempty"`
	Pattern     string               `json:"pattern,omitempty"`
	Enum        []any                `json:"enum,omitempty"`
	Minimum     *float64             `json:"minimum,omitempty"`
	Maximum     *float64             `json:"maximum,omitempty"`
	MinLength   *int                 `json:"min_length,omitempty"`
	MaxLength   *int                 `json:"max_length,omitempty"`
	Items       *Property            `json:"items,omitempty"`
	Properties  map[string]*Property `json:"properties,omitempty"`
	Required    []string             `json:"required,omitempty"`
	Default     any                  `json:"default,omitempty"`
	Examples    []any                `json:"examples,omitempty"`
	Metadata    map[string]any       `json:"metadata,omitempty"`
}

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

type RegistryConfig struct {
	EnableCache        bool          `json:"enable_cache"        yaml:"enable_cache"`
	CacheTTL           time.Duration `json:"cache_ttl"           yaml:"cache_ttl"`
	AutoRegister       bool          `json:"auto_register"       yaml:"auto_register"`
	VersioningStrategy string        `json:"versioning_strategy" yaml:"versioning_strategy"` // "strict", "compatible", "none"
	ValidationLevel    string        `json:"validation_level"    yaml:"validation_level"`    // "strict", "lenient", "disabled"
	AllowEvolution     bool          `json:"allow_evolution"     yaml:"allow_evolution"`
	MaxVersions        int           `json:"max_versions"        yaml:"max_versions"`
}

type Schema struct {
	ID          string               `json:"id"`
	Name        string               `json:"name"`
	Version     int                  `json:"version"`
	Type        string               `json:"type"`
	Title       string               `json:"title"`
	Description string               `json:"description"`
	Properties  map[string]*Property `json:"properties"`
	Required    []string             `json:"required"`
	Metadata    map[string]any       `json:"metadata"`
	CreatedAt   string               `json:"created_at"`
	UpdatedAt   string               `json:"updated_at"`
}

type SchemaCache interface {
	// Get retrieves a schema from cache
	Get(key string) (*Schema, bool)

	// Set stores a schema in cache
	Set(key string, schema *Schema, ttl time.Duration)

	// Delete removes a schema from cache
	Delete(key string)

	// Clear clears all cached schemas
	Clear()

	// Stats returns cache statistics
	Stats() map[string]any
}

type SchemaChange struct {
	Type        string `json:"type"` // "add", "remove", "modify", "rename"
	Path        string `json:"path"` // JSON path to the changed property
	OldValue    any    `json:"old_value,omitempty"`
	NewValue    any    `json:"new_value,omitempty"`
	Description string `json:"description,omitempty"`
}

type SchemaEvolution struct {
	EventType      string              `json:"event_type"`
	FromVersion    int                 `json:"from_version"`
	ToVersion      int                 `json:"to_version"`
	Changes        []SchemaChange      `json:"changes"`
	Compatible     bool                `json:"compatible"`
	Transformation *TransformationRule `json:"transformation,omitempty"`
	Metadata       map[string]any      `json:"metadata,omitempty"`
}

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

type SchemaStore interface {
	// SaveSchema saves a schema to persistent storage
	SaveSchema(ctx context.Context, schema *Schema) error

	// GetSchema retrieves a schema by type and version
	GetSchema(ctx context.Context, eventType string, version int) (*Schema, error)

	// GetSchemaByID retrieves a schema by ID
	GetSchemaByID(ctx context.Context, schemaID string) (*Schema, error)

	// GetLatestSchema retrieves the latest version of a schema
	GetLatestSchema(ctx context.Context, eventType string) (*Schema, error)

	// GetSchemaVersions retrieves all versions of a schema
	GetSchemaVersions(ctx context.Context, eventType string) ([]*Schema, error)

	// DeleteSchema deletes a schema
	DeleteSchema(ctx context.Context, schemaID string) error

	// ListEventTypes lists all registered event types
	ListEventTypes(ctx context.Context) ([]string, error)

	// Close closes the schema store
	Close(ctx context.Context) error
}

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

type TransformationRule struct {
	Rule         string         `json:"rule"` // "copy", "rename", "transform", "default"
	SourcePath   string         `json:"source_path,omitempty"`
	TargetPath   string         `json:"target_path,omitempty"`
	Transform    string         `json:"transform,omitempty"` // transformation expression
	DefaultValue any            `json:"default_value,omitempty"`
	Metadata     map[string]any `json:"metadata,omitempty"`
}

type ValidationConfig struct {
	StrictMode       bool     `json:"strict_mode"        yaml:"strict_mode"`
	RequiredFields   []string `json:"required_fields"    yaml:"required_fields"`
	AllowExtraFields bool     `json:"allow_extra_fields" yaml:"allow_extra_fields"`
	ValidateMetadata bool     `json:"validate_metadata"  yaml:"validate_metadata"`
	MaxDepth         int      `json:"max_depth"          yaml:"max_depth"`
	MaxSize          int      `json:"max_size"           yaml:"max_size"`
}

type ValidationError struct {
	Field    string `json:"field"`
	Value    any    `json:"value"`
	Expected string `json:"expected"`
	Message  string `json:"message"`
	Code     string `json:"code"`
}

type ValidationResult struct {
	Valid   bool               `json:"valid"`
	Errors  []*ValidationError `json:"errors"`
	Schema  *Schema            `json:"schema"`
	EventID string             `json:"event_id"`
}

type Validator interface {
	// Validate validates data against the schema
	Validate(data any) error

	// GetSchema returns the schema
	GetSchema() *Schema

	// GetType returns the validator type
	GetType() string
}