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 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)
Click to show internal directories.
Click to hide internal directories.