backends

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

type AzureConfig struct {
	Container        string `json:"container"`
	ConnectionString string `json:"connection_string"`
	Prefix           string `json:"prefix"`
	AccessTier       string `json:"access_tier"`
	Immutable        bool   `json:"immutable"`
	RetentionDays    int    `json:"retention_days"`
}

type Backend interface {
	// Write writes an event to the backend
	Write(event *core.LogEvent) error

	// WriteBatch writes multiple events efficiently
	WriteBatch(events []*core.LogEvent) error

	// Read reads events within a time range
	Read(start, end time.Time) ([]*core.LogEvent, error)

	// VerifyIntegrity verifies the integrity of stored data
	VerifyIntegrity() (*IntegrityReport, error)

	// Name returns the backend name
	Name() string

	// Close closes the backend
	Close() error
}

type BackendError struct {
	Err     error
	Backend string
	Op      string
}

type Config interface {
	Type() string
	Validate() error
}

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

type FilesystemConfig struct {
	Path     string        `json:"path"`
	SyncMode SyncMode      `json:"sync_mode"`
	MaxSize  int64         `json:"max_size"` // Max file size before rotation
	MaxAge   time.Duration `json:"max_age"`  // Max age before rotation
	Compress bool          `json:"compress"` // Compress rotated files
	Shadow   bool          `json:"shadow"`   // Shadow copy for redundancy
}

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

type GCSConfig struct {
	Bucket          string `json:"bucket"`
	ProjectID       string `json:"project_id"`
	Prefix          string `json:"prefix"`
	StorageClass    string `json:"storage_class"`
	Region          string `json:"region"`
	CredentialsFile string `json:"credentials_file"`
	RetentionDays   int    `json:"retention_days"`
	Versioning      bool   `json:"versioning"`
}

type IntegrityReport struct {
	Timestamp        time.Time `json:"timestamp"`
	Backend          string    `json:"backend"`
	Errors           []string  `json:"errors,omitempty"`
	TotalRecords     int64     `json:"total_records"`
	VerifiedRecords  int64     `json:"verified_records"`
	CorruptedRecords int64     `json:"corrupted_records"`
	Valid            bool      `json:"valid"`
}

type Query struct {
	StartTime time.Time
	EndTime   time.Time
	Filters   map[string]interface{}
	Limit     int
}

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

type S3Config struct {
	Bucket               string `json:"bucket"`
	Region               string `json:"region"`
	Prefix               string `json:"prefix"`
	StorageClass         string `json:"storage_class"`
	ServerSideEncryption bool   `json:"server_side_encryption"`
	Versioning           bool   `json:"versioning"`
	ObjectLock           bool   `json:"object_lock"`
	RetentionDays        int    `json:"retention_days"`
}

type S3Option func(*S3Backend)

type S3Stats struct {
	LastWrite     time.Time
	Bucket        string
	Prefix        string
	WriteCount    int64
	ErrorCount    int64
	RetentionDays int
	ObjectLock    bool
	Versioning    bool
	Encryption    bool
}

type SyncMode int