engine

type AccessEvent struct {
	Container string
	Artifact  string
	Operation string
	Timestamp time.Time
	Latency   time.Duration
	Size      int64
	Success   bool
}

type Artifact struct {
	ID        string                 `json:"id"`
	Container string                 `json:"container"`
	Key       string                 `json:"key"`
	Type      string                 `json:"type"` // "blob", "wasm", "model", "vector", "dataset"
	Size      int64                  `json:"size"`
	Modified  time.Time              `json:"modified"`
	ETag      string                 `json:"etag"`
	Metadata  map[string]interface{} `json:"metadata"`

	// Hidden ML/AI fields
	Features    map[string]float64 `json:"-"` // For ML training
	Vector      []float64          `json:"-"` // For similarity search
	AccessCount int64              `json:"-"` // For smart caching
	LastAccess  time.Time          `json:"-"` // For tiering decisions
}

type ComputeEngine interface {
	LoadModule(wasm []byte) error
	Execute(input []byte) ([]byte, error)
}

type Container struct {
	ID       string                 `json:"id"`
	Name     string                 `json:"name"`
	Type     string                 `json:"type"` // "storage", "compute", "ml-model", "vector-db"
	Created  time.Time              `json:"created"`
	Metadata map[string]interface{} `json:"metadata"`

	// Hidden ML fields (not exposed in S3 API)
	Temperature float64 `json:"-"` // Access frequency score
	Tier        string  `json:"-"` // "hot", "warm", "cold", "archive"
}

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

type Driver interface {
	Name() string
	Get(ctx context.Context, container, artifact string) (io.ReadCloser, error)
	Put(ctx context.Context, container, artifact string, data io.Reader, opts ...PutOption) error
	Delete(ctx context.Context, container, artifact string) error
	List(ctx context.Context, container, prefix string) ([]string, error)
	HealthCheck(ctx context.Context) error
}

type Engine interface {
	// Storage operations (visible to users)
	Get(ctx context.Context, container, artifact string) (io.ReadCloser, error)
	Put(ctx context.Context, container, artifact string, data io.Reader, opts ...PutOption) error
	Delete(ctx context.Context, container, artifact string) error
	List(ctx context.Context, container, prefix string) ([]Artifact, error)

	// Hidden capabilities (implement as no-ops for now)
	Execute(ctx context.Context, container string, wasm []byte, input io.Reader) (io.Reader, error)
	Query(ctx context.Context, sql string) (ResultSet, error)
	Train(ctx context.Context, model string, data []byte) error
	Predict(ctx context.Context, model string, input []byte) ([]byte, error)

	// Metadata operations
	GetContainerMetadata(ctx context.Context, container string) (*Container, error)
	GetArtifactMetadata(ctx context.Context, container, artifact string) (*Artifact, error)

	// Health and metrics
	HealthCheck(ctx context.Context) error
	GetMetrics(ctx context.Context) (map[string]interface{}, error)
}

type MLEngine interface {
	LoadModel(path string) error
	Train(data [][]float64, labels []float64) error
	Predict(input []float64) (float64, error)
}

type NotFoundError struct {
	Container string
	Artifact  string
}

type Operation struct {
	Type      string // "get", "put", "delete", "compute", "query"
	Container string
	Artifact  string
	Context   context.Context
	Metadata  map[string]interface{}
}

type PermissionError struct {
	TenantID string
	Action   string
}

type PutOption func(*PutOptions)

type PutOptions struct {
	ContentType     string
	CacheControl    string
	ContentEncoding string
	ContentLanguage string
	UserMetadata    map[string]string
}

type Result struct {
	Success  bool
	Data     io.ReadCloser
	Metadata map[string]interface{}
	Error    error
}

type ResultSet interface {
	Next() bool
	Scan(dest ...interface{}) error
	Close() error
}