task

package
v0.66.11 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 1, 2025 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Integration

type Integration struct {
	IntegrationID   string
	ProviderID      string
	IntegrationType string
	Secret          string
	Labels          map[string]string
	Annotations     map[string]string
}

func GetIntegrationsFromQuery

func GetIntegrationsFromQuery(coreServiceClient coreClient.CoreServiceClient, params map[string]any) ([]Integration, error)

type IntegrationResult

type IntegrationResult struct {
	IntegrationID              string               `json:"integration_id"`
	AllResourceTypes           []string             `json:"all_resource_types"`
	AllResourceTypesCount      int                  `json:"all_resource_types_count"`
	ResourceTypeResults        []ResourceTypeResult `json:"resource_type_results"`
	FinishedResourceTypesCount int                  `json:"finished_resource_types_count"`
}

type ResourceType

type ResourceType struct {
	Name string
}

func GetResourceTypesFromQuery

func GetResourceTypesFromQuery(coreServiceClient coreClient.CoreServiceClient, params map[string]any) ([]ResourceType, error)

type ResourceTypeResult

type ResourceTypeResult struct {
	ResourceType  string `json:"resource_type"`
	Error         string `json:"error"`
	ResourceCount int    `json:"resource_count"`
}

type TaskResult

type TaskResult struct {
	AllIntegrations             []string                      `json:"all_integrations"`
	AllIntegrationsCount        int                           `json:"all_integrations_count"`
	ProgressedIntegrations      map[string]*IntegrationResult `json:"progressed_integrations"`
	ProgressedIntegrationsCount int                           `json:"progressed_integrations_count"`
}

type TaskRunner

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

func NewTaskRunner

func NewTaskRunner(ctx context.Context, jq *jq.JobQueue, coreServiceEndpoint string, describeToken string, esClient opengovernance.Client,
	logger *zap.Logger, request tasks.TaskRequest, response *scheduler.TaskResponse) (*TaskRunner, error)

func (*TaskRunner) RunTask

func (tr *TaskRunner) RunTask(ctx context.Context) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL