logestimator

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

type EstimateResult struct {
	// MetricCount is the base count obtained from Cloud Monitoring metric.
	MetricCount int64 `json:"metricCount"`

	// EstimatedCount is the estimated total count after applying custom filters.
	EstimatedCount int64 `json:"estimatedCount"`

	// CustomFilterRatio is the ratio r (0.0 to 1.0) applied to MetricCount.
	CustomFilterRatio float64 `json:"customFilterRatio"`

	// IsExact is true if no custom filter ratio estimation was required.
	IsExact bool `json:"isExact"`

	// Preset indicates a rough estimation tier if defined on the query.
	Preset EstimatedCountPreset `json:"preset,omitempty"`
}

type EstimatedCountPreset int

type EstimatorProvider func(ctx context.Context, container googlecloud.ResourceContainer) (*StructuredLogEstimator, error)

type LogProbeClient interface {
	FetchProbe(ctx context.Context, filter string, pageSize int32) ([]*loggingpb.LogEntry, error)
}

type LogSamplingProbeFetcher interface {
	// ProbeLogTimestamps returns timestamps of matching log entries (up to maxEntries, ordered by timestamp desc).
	ProbeLogTimestamps(ctx context.Context, container googlecloud.ResourceContainer, filter string, maxEntries int32) ([]time.Time, error)
}

type LoggingClientProbeFetcher struct {
	Client *logging.Client
}

type LoggingMonitoringMatcher interface {
	// SupportMetrics returns true if this filter condition can be natively represented in Cloud Monitoring.
	SupportMetrics() bool

	// ToLoggingQuery returns the filter fragment for Cloud Logging queries.
	ToLoggingQuery() string

	// ToMonitoringFilter returns the filter fragment for Cloud Monitoring metric filters.
	ToMonitoringFilter() string
}

type MetricLogCountFetcher interface {
	QueryMetricCount(ctx context.Context, container googlecloud.ResourceContainer, metricFilter string, startTime, endTime time.Time) (int64, error)
}

type MonitoringClientFetcher struct {
	Client *monitoring.MetricClient
}

type StructuredLogEstimator struct {
	MetricFetcher      MetricLogCountFetcher
	ProbeFetcher       LogSamplingProbeFetcher
	CallOptionInjector *googlecloud.CallOptionInjector
	TargetSamples      int32
}

type StructuredLogQuery struct {
	// ResourceTypes specifies the resource.type strings (e.g. ["k8s_container"] or ["gke_cluster", "gke_nodepool"]).
	ResourceTypes []string

	// IgnoreMetricsResourceType specifies the resource.type strings that should NOT be queried via Cloud Monitoring metrics
	// (e.g. resource types like "gke_nodepool" that are valid in Cloud Logging but do not exist as MonitoredResourceDescriptors in Cloud Monitoring).
	IgnoreMetricsResourceType []string

	// Filters are the individual filter matchers for this query.
	Filters []LoggingMonitoringMatcher

	// Incomplete indicates that the query is missing required parameters (e.g. ProjectID or ClusterName)
	// and should not trigger log volume estimation.
	Incomplete bool

	// Preset specifies a predefined rough estimation tier (e.g. EstimatedCountPresetFew)
	// that bypasses Cloud Monitoring and probe queries.
	Preset EstimatedCountPreset
}

type ValueMatcher interface {
	// ToLoggingFieldQuery returns the Cloud Logging query fragment for a named field.
	ToLoggingFieldQuery(fieldName string) string

	// ToMonitoringFieldFilter returns the Cloud Monitoring metric filter fragment for a named field.
	ToMonitoringFieldFilter(fieldName string) string

	// ToLoggingLogIDQuery returns the Cloud Logging query fragment for LOG_ID(...).
	ToLoggingLogIDQuery() string

	// ToMonitoringLogIDFilter returns the Cloud Monitoring metric filter fragment for metric.labels.log.
	ToMonitoringLogIDFilter() string
}