cost

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

type CircuitState int

type ConsumedCapacity struct {
	TableName              string                      // Table that consumed the capacity
	ReadCapacityUnits      float64                     // Read capacity units consumed
	WriteCapacityUnits     float64                     // Write capacity units consumed
	GlobalSecondaryIndexes map[string]ConsumedCapacity // GSI capacity consumption
	LocalSecondaryIndexes  map[string]ConsumedCapacity // LSI capacity consumption
}

type Cost struct {
	Service                    string    // "DynamoDB", "S3", "Lambda", etc.
	ReadCostMicroCents         int64     // Cost for read operations
	WriteCostMicroCents        int64     // Cost for write operations
	RequestCostMicroCents      int64     // Cost for requests
	StorageCostMicroCents      int64     // Cost for storage
	InvocationCostMicroCents   int64     // Cost for Lambda invocations
	DurationCostMicroCents     int64     // Cost for Lambda duration
	DataTransferCostMicroCents int64     // Cost for data transfer
	TotalMicroCents            int64     // Total cost in microcents
	Timestamp                  time.Time // When the cost was calculated
}

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

type CostCircuitBreakerConfig struct {
	MaxCostPerHour    float64       // Maximum cost per hour in USD
	MaxCostPerRequest float64       // Maximum cost per request in USD
	WindowSize        time.Duration // Cost calculation window
	FailureThreshold  int           // Number of failures to open circuit
	RecoveryTimeout   time.Duration // Time before attempting recovery
}

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

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

type DailyCostAggregate struct {
	Date                string
	TotalCostMicrocents int64
	RequestCount        int64
	UniqueUsers         int64
	DynamoDBReads       int64
	DynamoDBWrites      int64
	LambdaInvocations   int64
	LambdaDurationMs    int64
	DataTransferBytes   int64
}

type Driver struct {
	Service           string  `json:"service"`
	Operation         string  `json:"operation"`
	CostMicroCents    int64   `json:"cost_microcents"`
	PercentageOfTotal float64 `json:"percentage_of_total"`
	OperationCount    int64   `json:"operation_count"`
	AverageCost       int64   `json:"average_cost"`
	Trend             string  `json:"trend"` // "INCREASING", "DECREASING", or "STABLE"
}

type DynamORMCostTracker struct {
	*Tracker // Embed existing cost tracker
	// contains filtered or unexported fields
}

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

type DynamoOperation struct {
	Type               string    // "Query", "Scan", "PutItem", "UpdateItem", "DeleteItem", "BatchWrite"
	TableName          string    // Name of the DynamoDB table
	ConsumedReadUnits  int64     // Read capacity units consumed
	ConsumedWriteUnits int64     // Write capacity units consumed
	ItemCount          int64     // Number of items affected
	IndexName          string    // GSI name if applicable
	OperationID        string    // Unique operation identifier
	UserID             string    // User associated with the operation
	Timestamp          time.Time // When the operation occurred
}

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

type HandlerFunc func(ctx context.Context, request events.APIGatewayV2HTTPRequest) (*events.APIGatewayV2HTTPResponse, error)

type JobExecution struct {
	// Job identification
	JobName     string
	Schedule    string
	CronPattern string
	Category    string
	Priority    string

	// Execution context
	Environment       string
	Region            string
	FunctionName      string
	RequestID         string
	ScheduledTime     time.Time
	NextScheduledTime time.Time

	// Execution timing
	StartTime time.Time
	EndTime   time.Time
	// contains filtered or unexported fields
}

type JobStepExecution struct {
	StepName  string
	StartTime time.Time
	EndTime   time.Time
	Status    string
	Error     string
	// contains filtered or unexported fields
}

type LambdaOperation struct {
	FunctionName string        // Name of the Lambda function
	Duration     time.Duration // Actual execution duration
	MemoryMB     int64         // Memory allocated in MB
	MemoryUsedMB int64         // Memory actually used (if available)
	ColdStart    bool          // Whether this was a cold start
	RequestID    string        // Lambda request ID
	UserID       string        // User associated with the invocation
	Timestamp    time.Time     // When the invocation occurred
}

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

type MetricData struct {
	Name       string             // Metric name
	Value      float64            // Metric value
	Unit       types.StandardUnit // CloudWatch unit
	Dimensions []types.Dimension  // CloudWatch dimensions
	Timestamp  time.Time          // Metric timestamp
}

type MonthlyCostAggregate struct {
	Year                    int
	Month                   int
	TotalCostMicrocents     int64
	ProjectedCostMicrocents int64
	RequestCount            int64
	UniqueUsers             int64
	DynamoDBReads           int64
	DynamoDBWrites          int64
	LambdaInvocations       int64
	LambdaDurationMs        int64
	DataTransferGB          float64
}

type MultiStepJobExecution struct {
	*JobExecution
	// contains filtered or unexported fields
}

type OperationCost struct {
	DynamoDBReads       int64     `json:"dynamodb_reads"`
	DynamoDBWrites      int64     `json:"dynamodb_writes"`
	DynamoDBStorage     int64     `json:"dynamodb_storage_bytes"`
	LambdaInvocations   int64     `json:"lambda_invocations"`
	LambdaDurationMs    int64     `json:"lambda_duration_ms"`
	LambdaMemoryMB      int64     `json:"lambda_memory_mb"`
	S3Gets              int64     `json:"s3_gets"`
	S3Puts              int64     `json:"s3_puts"`
	S3Storage           int64     `json:"s3_storage_bytes"`
	DataTransferBytes   int64     `json:"data_transfer_bytes"`
	TotalCostMicroCents int64     `json:"total_cost_microcents"`
	Timestamp           time.Time `json:"timestamp"`
	OperationType       string    `json:"operation_type"`
	RequestID           string    `json:"request_id"`
}

type OperationInfo struct {
	Type         string        // Operation type (e.g., "DynamoDB.Read", "S3.Put")
	ResourceName string        // Resource name (table name, bucket name, function name)
	Units        int64         // Capacity units (for DynamoDB)
	Bytes        int64         // Bytes transferred (for S3)
	Duration     time.Duration // Duration (for Lambda)
	MemoryMB     int64         // Memory allocation (for Lambda)
}

type OperationMetadata struct {
	OperationType     string            `json:"operation_type"`
	TableName         string            `json:"table_name"`
	IndexName         string            `json:"index_name,omitempty"`
	ItemCount         int               `json:"item_count"`
	FilterExpressions []string          `json:"filter_expressions,omitempty"`
	ProjectionFields  []string          `json:"projection_fields,omitempty"`
	ConsistentRead    bool              `json:"consistent_read"`
	BatchSize         int               `json:"batch_size,omitempty"`
	PaginationTokens  map[string]string `json:"pagination_tokens,omitempty"`
	Conditions        []QueryCondition  `json:"conditions,omitempty"`
}

type OptimizationSuggestion struct {
	Category         string `json:"category"`          // "DynamoDB", "S3", "Lambda", etc.
	Suggestion       string `json:"suggestion"`        // Human-readable suggestion
	EstimatedSavings int64  `json:"estimated_savings"` // Estimated savings in microcents
	Priority         string `json:"priority"`          // "High", "Medium", "Low"
	Effort           string `json:"effort"`            // "Low", "Medium", "High"
}

type QueryCondition struct {
	Field    string `json:"field"`
	Operator string `json:"operator"`
	Value    string `json:"value"` // Simplified for logging
}

type S3API interface {
	GetObject(ctx context.Context, params *s3.GetObjectInput, optFns ...func(*s3.Options)) (*s3.GetObjectOutput, error)
	PutObject(ctx context.Context, params *s3.PutObjectInput, optFns ...func(*s3.Options)) (*s3.PutObjectOutput, error)
	DeleteObject(ctx context.Context, params *s3.DeleteObjectInput, optFns ...func(*s3.Options)) (*s3.DeleteObjectOutput, error)
	HeadObject(ctx context.Context, params *s3.HeadObjectInput, optFns ...func(*s3.Options)) (*s3.HeadObjectOutput, error)
	ListObjectsV2(ctx context.Context, params *s3.ListObjectsV2Input, optFns ...func(*s3.Options)) (*s3.ListObjectsV2Output, error)
}

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

type S3Operation struct {
	Type             string    // "PutObject", "GetObject", "DeleteObject", "ListObjects"
	BucketName       string    // Name of the S3 bucket
	ObjectKey        string    // S3 object key
	RequestCount     int64     // Number of requests
	BytesTransferred int64     // Bytes uploaded/downloaded
	StorageClass     string    // Standard, IA, Glacier, etc.
	OperationID      string    // Unique operation identifier
	UserID           string    // User associated with the operation
	Timestamp        time.Time // When the operation occurred
}

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

type ScheduledJobCostRepository interface {
	Create(ctx context.Context, record *models.ScheduledJobCostRecord) error
	Update(ctx context.Context, record *models.ScheduledJobCostRecord) error
	GetByID(ctx context.Context, id string) (*models.ScheduledJobCostRecord, error)
	ListByJob(ctx context.Context, jobName, schedule string, startTime, endTime time.Time, limit int) ([]*models.ScheduledJobCostRecord, error)
	ListByStatus(ctx context.Context, status string, startTime, endTime time.Time, limit int) ([]*models.ScheduledJobCostRecord, error)
	ListByDateRange(ctx context.Context, startDate, endDate time.Time, limit int) ([]*models.ScheduledJobCostRecord, error)
	GetFailedJobs(ctx context.Context, startTime, endTime time.Time, limit int) ([]*models.ScheduledJobCostRecord, error)
	GetLongRunningJobs(ctx context.Context, thresholdMs int64, startTime, endTime time.Time, limit int) ([]*models.ScheduledJobCostRecord, error)
	GetHighCostJobs(ctx context.Context, thresholdDollars float64, startTime, endTime time.Time, limit int) ([]*models.ScheduledJobCostRecord, error)
	AggregateJobCosts(ctx context.Context, jobName, period string, windowStart, windowEnd time.Time) error
}

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

type ServiceMetric struct {
	Name  string
	Value float64
	Unit  types.StandardUnit
}

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

type Summary struct {
	TotalCostMicroCents      int64                    `json:"total_cost_microcents"`
	ServiceBreakdown         map[string]int64         `json:"service_breakdown"`
	OperationBreakdown       map[string]int64         `json:"operation_breakdown"`
	HourlyBreakdown          map[string]int64         `json:"hourly_breakdown"`
	TopDrivers               []Driver                 `json:"top_drivers"`
	CostTrends               []TrendPoint             `json:"cost_trends"`
	BudgetUtilization        float64                  `json:"budget_utilization"`
	ProjectedMonthlyCost     int64                    `json:"projected_monthly_cost"`
	RecommendedOptimizations []OptimizationSuggestion `json:"optimizations"`
}

type Thresholds struct {
	DynamoDBReadWarning     float64 // dollars
	DynamoDBWriteWarning    float64 // dollars
	S3OperationWarning      float64 // dollars
	LambdaInvocationWarning float64 // dollars
	DailyBudgetLimit        float64 // dollars
}

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

type TrackingDB struct {
	core.DB
	// contains filtered or unexported fields
}

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

type TrackingRepository interface {
	// Store cost records
	StoreCost(ctx context.Context, cost *Cost) error
	StoreCostBatch(ctx context.Context, costs []*Cost) error

	// Retrieve cost information
	GetCostSummary(ctx context.Context, startTime, endTime time.Time) (*Summary, error)
	GetServiceCosts(ctx context.Context, service string, startTime, endTime time.Time) ([]*Cost, error)
	GetUserCosts(ctx context.Context, userID string, startTime, endTime time.Time) ([]*Cost, error)

	// Cost analysis
	GetTopDrivers(ctx context.Context, startTime, endTime time.Time, limit int) ([]Driver, error)
	GetCostTrends(ctx context.Context, startTime, endTime time.Time, granularity string) ([]TrendPoint, error)
	GetOptimizationSuggestions(ctx context.Context, lookbackDays int) ([]OptimizationSuggestion, error)
}

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

type TrackingServiceConfig struct {
	CloudWatchNamespace   string
	MetricsBatchSize      int
	MetricsFlushInterval  time.Duration
	EnableDetailedMetrics bool
	CostThresholds        Thresholds
}

type TrendPoint struct {
	Timestamp      time.Time `json:"timestamp"`
	CostMicroCents int64     `json:"cost_microcents"`
	OperationCount int64     `json:"operation_count"`
}

type UnifiedCostTracker interface {
	// DynamoDB operations
	TrackDynamoRead(ctx context.Context, tableName string, units int64) error
	TrackDynamoWrite(ctx context.Context, tableName string, units int64) error
	TrackDynamoQuery(ctx context.Context, tableName string, units int64) error
	TrackDynamoScan(ctx context.Context, tableName string, units int64) error

	// S3 operations
	TrackS3Get(ctx context.Context, bucketName string, bytes int64) error
	TrackS3Put(ctx context.Context, bucketName string, bytes int64) error
	TrackS3Delete(ctx context.Context, bucketName string) error

	// Lambda operations
	TrackLambdaInvocation(ctx context.Context, functionName string, duration time.Duration, memoryMB int64) error

	// Metrics and reporting
	GetCurrentCostMicroCents() int64
	GetCostBreakdown() map[string]int64
	Reset()
}

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