googlecloudcommon_contract

type DefaultResourceNamesGenerator interface {
	// GetDependentTasks returns the list of task references needed for generating resource names.
	GetDependentTasks() []taskid.UntypedTaskReference
	// GenerateResourceNames returns the list of resource names.
	GenerateResourceNames(ctx context.Context) ([]string, error)
}

type GCPAccessLogFieldSet struct {
	Method       string
	RequestURL   string
	RequestSize  int64
	Status       int
	ResponseSize int64
	UserAgent    string
	RemoteIP     string
	ServerIP     string
	Referer      string
	Latency      string
	Protocol     string
}

type GCPAccessLogFieldSetReader struct {
}

type GCPAuditLogFieldSet struct {
	OperationID    string
	OperationFirst bool
	OperationLast  bool
	MethodName     string
	ResourceName   string
	PrincipalEmail string
	Status         int
	Request        *structured.NodeReader
	Response       *structured.NodeReader
}

type GCPOperationAuditLogFieldSetReader struct {
}

type ListLogEntriesTaskDescription struct {
	DefaultLogType enum.LogType
	QueryName      string
	ExampleQuery   string
}

type ListLogEntriesTaskSetting interface {
	// TaskID returns the task ID for the Cloud Logging list log entries task.
	TaskID() taskid.TaskImplementationID[[]*log.Log]

	// Dependencies returns the list of dependencies for the Cloud Logging list log entries task.
	// Return the dependency task reference IDs when the result is used in DefaultResourceNames(), LogFilters() or TimePartitionCount().
	Dependencies() []taskid.UntypedTaskReference

	// DefaultResourceNames returns the list of resource names for the Cloud Logging list log entries task.
	// This is just a default value for the resource name. Users can override this value with the form field.
	// Return the list of resource names. ref: https://cloud.google.com/logging/docs/reference/v2/rest/v2/entries/list
	DefaultResourceNames(ctx context.Context) ([]string, error)

	// LogFilters returns the list of log filters for the Cloud Logging list log entries task.
	// When generated logging filter can exceed the 20,000 character maximum limit in Cloud Logging, return multiple subset query.
	// Result includes the logs for all log filters.
	LogFilters(ctx context.Context, taskMode inspectioncore_contract.InspectionTaskModeType) ([]string, error)

	// TimePartitionCount returns the number of time partitions for the Cloud Logging list log entries task.
	// ListLogEntriesTask split the duration into the number of partition count to gather logs in parallel.
	// Return 1 - 16 values depending on the expected log volume by the log filter.
	TimePartitionCount(ctx context.Context) (int, error)

	// Description returns the description for the Cloud Logging filter task.
	Description() *ListLogEntriesTaskDescription
}

type LocationFetcher interface {
	FetchRegions(ctx context.Context, projectId string) ([]string, error)
}

type LogFetchProgress struct {
	// LogCount is the total number of logs fetched so far.
	LogCount int
	// Progress indicates the completion status, ranging from 0.0 to 1.0.
	Progress float32
}

type LogFetcher interface {
	FetchLogs(dest chan<- *loggingpb.LogEntry, ctx context.Context, filter string, container googlecloud.ResourceContainer, resourceContainers []string) error
}

type ProgressReportableLogFetcher interface {
	// FetchLogsWithProgress fetches logs while periodically reporting its progress through a separate channel.
	// Implementations must close both the dest and progress channels upon completion.
	FetchLogsWithProgress(dest chan<- *loggingpb.LogEntry, progress chan<- LogFetchProgress, ctx context.Context, beginTime, endTime time.Time, filterWithoutTimeRange string, container googlecloud.ResourceContainer, resourceContainers []string) error
}

type ProjectIDDefaultResourceNamesGenerator struct{}

type QueryGeneratorFunc = func(context.Context, inspectioncore_contract.InspectionTaskModeType) ([]string, error)

type QueryResourceNames struct {
	QueryID              string
	DefaultResourceNames []string
	CurrentResourceNames []string
}

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

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

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