discovery

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

type Alert struct {
	ID           string
	Type         AlertType
	Severity     AlertSeverity
	Message      string
	Details      map[string]interface{}
	Timestamp    time.Time
	Acknowledged bool
}

type AlertSeverity string

type AlertType string

type Backend interface {
	Connect(ctx context.Context) error
	GetState(ctx context.Context, key string) ([]byte, error)
	PutState(ctx context.Context, key string, data []byte) error
	DeleteState(ctx context.Context, key string) error
	ListStates(ctx context.Context) ([]string, error)
	LockState(ctx context.Context, key string) (string, error)
	UnlockState(ctx context.Context, key string, lockID string) error
}

type BackendConfig struct {
	ID           string                 `json:"id"`
	Type         string                 `json:"type"`
	Attributes   map[string]interface{} `json:"attributes"`
	FilePath     string                 `json:"file_path"`
	Module       string                 `json:"module,omitempty"`
	Workspace    string                 `json:"workspace,omitempty"`
	ConfigPath   string                 `json:"config_path"`
	Config       map[string]interface{} `json:"config"`
	WorkspaceDir string                 `json:"workspace_dir,omitempty"`
}

type BackendFactory struct{}

type BackendScanner interface {
	Scan(ctx interface{}, opts ScanOptions) ([]*BackendConfig, error)
}

type BackendType string

type CachedResource struct {
	ID           string                 `json:"id"`
	Type         string                 `json:"type"`
	Provider     string                 `json:"provider"`
	Region       string                 `json:"region"`
	Attributes   map[string]interface{} `json:"attributes"`
	Version      string                 `json:"version"`
	ETag         string                 `json:"etag,omitempty"`
	LastModified time.Time              `json:"last_modified"`
	LastChecked  time.Time              `json:"last_checked"`
	Checksum     string                 `json:"checksum"`
	TTL          time.Duration          `json:"-"`
}

type ChangeLogReader interface {
	GetChanges(ctx context.Context, since time.Time) ([]ResourceChange, error)
}

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

type CloudSDK interface {
	Name() string
	Initialize(credentials Credentials) error
	ListResources(ctx context.Context, resourceType string, params map[string]interface{}) ([]models.Resource, error)
	GetResource(ctx context.Context, resourceID string) (*models.Resource, error)
	TagResource(ctx context.Context, resourceID string, tags map[string]string) error
	GetAPICallCount() int64
	GetLastError() error
}

type Credentials struct {
	Provider       string
	AccessKey      string
	SecretKey      string
	Token          string
	Region         string
	ProjectID      string
	SubscriptionID string
	TenantID       string
	ClientID       string
	ClientSecret   string
	ServiceAccount string
	KeyFile        string
	Extra          map[string]string
}

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

type DiscoveryConfig struct {
	CacheDuration     time.Duration
	BloomFilterSize   uint
	BloomFilterHashes uint
	ParallelWorkers   int
	BatchSize         int
	UseCloudTrails    bool
	UseResourceTags   bool
	DifferentialSync  bool
}

type DiscoveryFilter struct {
	IncludeTags   map[string]string `yaml:"include_tags"`
	ExcludeTags   map[string]string `yaml:"exclude_tags"`
	ResourceTypes []string          `yaml:"resource_types"`
	AgeThreshold  time.Duration     `yaml:"age_threshold"`
	UsagePatterns []string          `yaml:"usage_patterns"`
	CostThreshold float64           `yaml:"cost_threshold"`
	SecurityScore int               `yaml:"security_score"`
	Environment   string            `yaml:"environment"`
}

type DiscoveryMetrics struct {
	TotalDiscoveries int
	AverageDuration  time.Duration
	SuccessRate      float64
	ErrorCount       int
}

type DiscoveryOptions struct {
	Regions       []string
	ResourceTypes []string
	Tags          map[string]string
	MaxResults    int
}

type DiscoveryPlugin struct {
	Name         string            `yaml:"name"`
	Enabled      bool              `yaml:"enabled"`
	Priority     int               `yaml:"priority"`
	Dependencies []string          `yaml:"dependencies"`
	Config       map[string]string `yaml:"config"`
	DiscoveryFn  func(context.Context, string, string) ([]models.Resource, error)
}

type DiscoveryQuality struct {
	Completeness float64            `json:"completeness"`
	Accuracy     float64            `json:"accuracy"`
	Freshness    time.Duration      `json:"freshness"`
	Coverage     map[string]float64 `json:"coverage"`
	Errors       []string           `json:"errors"`
}

type DiscoveryResult struct {
	NewResources     []interface{}
	UpdatedResources []interface{}
	DeletedResources []string
	UnchangedCount   int
	DiscoveryTime    time.Duration
	CacheHits        int
	CacheMisses      int
}

type DiscoveryStats struct {
	TotalResources       int
	ResourcesByType      map[string]int
	ResourcesByRegion    map[string]int
	ResourcesByProvider  map[string]int
	DiscoveryDuration    time.Duration
	ErrorCount           int
	WarningCount         int
	AverageDiscoveryTime time.Duration
}

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

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

type Event struct {
	Type      string                 `json:"type"`
	Timestamp time.Time              `json:"timestamp"`
	Provider  string                 `json:"provider"`
	Region    string                 `json:"region"`
	Data      map[string]interface{} `json:"data"`
}

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

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

type MonitoringMetrics struct {
	ResourcesDiscovered  int64
	ResourcesPerSecond   float64
	ErrorCount           int64
	WarningCount         int64
	LastUpdateTime       time.Time
	AverageDiscoveryTime time.Duration
	ActiveProviders      map[string]bool
	ActiveRegions        map[string]bool
	DiscoveryRate        map[string]float64 // provider -> rate
	ErrorRate            float64
	SuccessRate          float64
}

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

type ParallelDiscoveryConfig struct {
	MaxWorkers     int
	MaxConcurrency int
	Timeout        time.Duration
	RetryAttempts  int
	RetryDelay     time.Duration
	BatchSize      int
	EnableMetrics  bool
}

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

type ProviderProgress struct {
	Name                string
	TotalRegions        int
	CompletedRegions    int
	TotalResources      int64
	DiscoveredResources int64
	StartTime           time.Time
	EndTime             *time.Time
	Errors              []error
}

type QueryFilter struct {
	Field    string
	Operator string
	Value    interface{}
}

type QueryOptions struct {
	Filters   []QueryFilter
	SortBy    string
	SortOrder string // "asc" or "desc"
	Limit     int
	Offset    int
	GroupBy   string
	Aggregate string // "count", "sum", "avg", "min", "max"
}

type QueryResult struct {
	Query         string
	Resources     []models.Resource
	Count         int
	ExecutionTime time.Duration
	Timestamp     time.Time
	Cached        bool
}

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

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

type RegionProgress struct {
	Provider            string
	Region              string
	TotalServices       int
	CompletedServices   int
	TotalResources      int64
	DiscoveredResources int64
	StartTime           time.Time
	EndTime             *time.Time
	Errors              []error
}

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

type ResourceChange struct {
	ResourceID string
	ChangeType string
	Timestamp  time.Time
	Details    map[string]interface{}
}

type ResourceHierarchy struct {
	Parent       *models.Resource
	Children     []*ResourceHierarchy
	Dependencies []string
	Level        int
}

type RetryPolicy struct {
	MaxRetries      int
	InitialDelay    time.Duration
	MaxDelay        time.Duration
	BackoffFactor   float64
	RetryableErrors []string
}

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

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

type SDKMetrics struct {
	APICallsTotal     map[string]int64
	APICallsPerSecond map[string]float64
	ErrorCount        map[string]int64
	RetryCount        map[string]int64
	RateLimitHits     map[string]int64
	AverageLatency    map[string]time.Duration
	LastAPICall       map[string]time.Time
}

type ScanOptions struct {
	Path        string
	Recursive   bool
	Pattern     string
	MaxDepth    int
	Workers     int
	FilterTypes []string
}

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

type ServiceProgress struct {
	Provider            string
	Region              string
	Service             string
	TotalResources      int64
	DiscoveredResources int64
	StartTime           time.Time
	EndTime             *time.Time
	Errors              []error
	LastActivity        time.Time
}

type TimelineEvent struct {
	Timestamp   time.Time
	EventType   string
	Provider    string
	Region      string
	Service     string
	ResourceID  string
	Description string
}

type ValidationResult struct {
	Region            string   `json:"region"`
	DriftmgrCount     int      `json:"driftmgr_count"`
	CLICount          int      `json:"cli_count"`
	Match             bool     `json:"match"`
	MissingInCLI      []string `json:"missing_in_cli,omitempty"`
	MissingInDriftmgr []string `json:"missing_in_driftmgr,omitempty"`
}

type WebhookConfig struct {
	URL        string
	Events     []string
	Headers    map[string]string
	RetryCount int
	Timeout    time.Duration
}