tasks

package
v0.1.24 Latest Latest
Warning

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

Go to latest
Published: Jan 26, 2026 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// TaskCollectAll is a meta task, which enqueues all relevant Azure tasks.
	TaskCollectAll = "az:task:collect-all"

	// TaskLinkAll is a task, which establishes links between Azure models.
	TaskLinkAll = "az:task:link-all"
)
View Source
const TaskCollectBlobContainers = "az:task:collect-blob-containers"

TaskCollectBlobContainers is the name of the task for collecting Azure Blob containers.

View Source
const TaskCollectLoadBalancers = "az:task:collect-loadbalancers"

TaskCollectLoadBalancers is the name of the task for collecting Azure Load Balancers.

View Source
const TaskCollectNetworkInterfaces = "az:task:collect-network-interfaces"

TaskCollectNetworkInterfaces is the name of the task for collecting Azure Network Interfaces.

View Source
const TaskCollectPublicAddresses = "az:task:collect-public-addresses"

TaskCollectPublicAddresses is the name of the task for collecting Azure Public IP Addresses.

View Source
const TaskCollectResourceGroups = "az:task:collect-resource-groups"

TaskCollectResourceGroups is the name of the task for collecting Azure Resource Groups.

View Source
const TaskCollectStorageAccounts = "az:task:collect-storage-accounts"

TaskCollectStorageAccounts is the name of the task for collecting Azure Storage Accounts.

View Source
const TaskCollectSubnets = "az:task:collect-subnets"

TaskCollectSubnets is the name of the task for collecting Azure Subnets.

View Source
const TaskCollectSubscriptions = "az:task:collect-subscriptions"

TaskCollectSubscriptions is the name of the task for collecting Azure Subscriptions.

View Source
const TaskCollectUsers = "az:task:collect-users"

TaskCollectUsers is the name of the task for collecting Microsoft Entra user accounts.

View Source
const TaskCollectVPCs = "az:task:collect-vpcs"

TaskCollectVPCs is the name of the task for collecting Azure VPCs.

View Source
const TaskCollectVirtualMachines = "az:task:collect-vms"

TaskCollectVirtualMachines is the name of the task for collecting Azure Virtual Machines.

Variables

View Source
var ErrClientNotFound = errors.New("client not found")

ErrClientNotFound is an error, which is returned when an API client was not found in the clientset registries.

View Source
var ErrNoPayload = errors.New("no payload specified")

ErrNoPayload is an error, which is returned by task handlers, which expect a payload, but none was provided.

View Source
var ErrNoResourceGroup = errors.New("no resource group specified")

ErrNoResourceGroup is an error, which is returned when a task expects an Azure Resource Group name, but none was provided.

View Source
var ErrNoStorageAccount = errors.New("no storage account specified")

ErrNoStorageAccount is an error, which is returned when a task expects an Azure Storage Account name, but none was provided.

View Source
var ErrNoSubscriptionID = errors.New("no subscription id specified")

ErrNoSubscriptionID is an error, which is returned when a task expects an Azure Subscription ID, but none was provided.

View Source
var ErrNoTenantID = errors.New("no tenant id specified")

ErrNoTenantID is an error, which is returned when a task expects an Azure Tenant ID, but none was provided.

View Source
var ErrNoUserPrincipalName = errors.New("no user principal name specified")

ErrNoUserPrincipalName is an error, which is returned by task handlers, which expect a user principal name to be specified, but none was provided.

View Source
var ErrNoVPC = errors.New("no vpc specified")

ErrNoVPC is an error, which is returned when a task expects an Azure VPC name, but none was provided.

Functions

func ClientNotFound

func ClientNotFound(subscriptionID string) error

ClientNotFound wraps ErrClientNotFound with the given subscription id.

func HandleCollectAllTask

func HandleCollectAllTask(ctx context.Context, _ *asynq.Task) error

HandleCollectAllTask is a handler, which enqueues tasks for collecting all Azure objects.

func HandleCollectBlobContainersTask

func HandleCollectBlobContainersTask(ctx context.Context, t *asynq.Task) error

HandleCollectBlobContainersTask is the handler, which collects Azure Blob containers.

func HandleCollectLoadBalancersTask

func HandleCollectLoadBalancersTask(ctx context.Context, t *asynq.Task) error

HandleCollectLoadBalancersTask is the handler, which collects Azure Load Balancers.

func HandleCollectNetworkInterfacesTask added in v0.1.20

func HandleCollectNetworkInterfacesTask(ctx context.Context, t *asynq.Task) error

HandleCollectNetworkInterfacesTask is the handler, which collects Azure Network Interfaces.

func HandleCollectPublicAddressesTask

func HandleCollectPublicAddressesTask(ctx context.Context, t *asynq.Task) error

HandleCollectPublicAddressesTask is the handler, which collects Azure Public IP Addresses.

func HandleCollectResourceGroupsTask

func HandleCollectResourceGroupsTask(ctx context.Context, t *asynq.Task) error

HandleCollectResourceGroupsTask is the handler, which collects Azure Resource Groups.

func HandleCollectStorageAccountsTask

func HandleCollectStorageAccountsTask(ctx context.Context, t *asynq.Task) error

HandleCollectStorageAccountsTask is the handler, which collects Azure Storage Accounts.

func HandleCollectSubnetsTask

func HandleCollectSubnetsTask(ctx context.Context, t *asynq.Task) error

HandleCollectSubnetsTask is the handler, which collects Azure Subnets.

func HandleCollectSubscriptionsTask

func HandleCollectSubscriptionsTask(ctx context.Context, _ *asynq.Task) error

HandleCollectSubscriptionsTask is the handler, which collects Azure Subscriptions.

func HandleCollectUsersTask added in v0.1.14

func HandleCollectUsersTask(ctx context.Context, t *asynq.Task) error

HandleCollectUsersTask is the handler, which collects Microsoft Entra user accounts.

func HandleCollectVPCsTask

func HandleCollectVPCsTask(ctx context.Context, t *asynq.Task) error

HandleCollectVPCsTask is the handler, which collects Azure VPCs.

func HandleCollectVirtualMachinesTask

func HandleCollectVirtualMachinesTask(ctx context.Context, t *asynq.Task) error

HandleCollectVirtualMachinesTask is the handler, which collects Azure Virtual Machines.

func HandleLinkAllTask

func HandleLinkAllTask(ctx context.Context, _ *asynq.Task) error

HandleLinkAllTask is a handler, which establishes links between the various Azure models.

func LinkBlobContainerWithResourceGroup

func LinkBlobContainerWithResourceGroup(ctx context.Context, db *bun.DB) error

LinkBlobContainerWithResourceGroup establishes relationships between the models.BlobContainer and models.ResourceGroup models.

func LinkLoadBalancerWithResourceGroup

func LinkLoadBalancerWithResourceGroup(ctx context.Context, db *bun.DB) error

LinkLoadBalancerWithResourceGroup establishes relationships between the models.LoadBalancer and models.ResourceGroup models.

func LinkPublicAddressWithResourceGroup

func LinkPublicAddressWithResourceGroup(ctx context.Context, db *bun.DB) error

LinkPublicAddressWithResourceGroup establishes relationships between the models.PublicAddress and models.ResourceGroup models.

func LinkResourceGroupWithSubscription

func LinkResourceGroupWithSubscription(ctx context.Context, db *bun.DB) error

LinkResourceGroupWithSubscription creates links between the models.ResourceGroup and models.Subscription models.

func LinkSubnetWithVPC

func LinkSubnetWithVPC(ctx context.Context, db *bun.DB) error

LinkSubnetWithVPC establishes relationships between the models.Subnet and models.VPC models.

func LinkVPCWithResourceGroup

func LinkVPCWithResourceGroup(ctx context.Context, db *bun.DB) error

LinkVPCWithResourceGroup establishes relationships between the models.VPC and models.ResourceGroup models.

func LinkVirtualMachineWithResourceGroup

func LinkVirtualMachineWithResourceGroup(ctx context.Context, db *bun.DB) error

LinkVirtualMachineWithResourceGroup creates links between the models.VirtualMachine and models.ResourceGroup models.

func NewCollectBlobContainersTask

func NewCollectBlobContainersTask() *asynq.Task

NewCollectBlobContainersTask creates a new asynq.Task for collecting Azure Blob containers without specifying a payload.

func NewCollectLoadBalancersTask

func NewCollectLoadBalancersTask() *asynq.Task

NewCollectLoadBalancersTask creates a new asynq.Task for collecting Azure Load Balancers, without specifying a payload.

func NewCollectNetworkInterfacesTask added in v0.1.20

func NewCollectNetworkInterfacesTask() *asynq.Task

NewCollectNetworkInterfacesTask creates a new asynq.Task for collecting Azure Network Interfaces, without specifying a payload.

func NewCollectPublicAddressesTask

func NewCollectPublicAddressesTask() *asynq.Task

NewCollectPublicAddressesTask creates a new asynq.Task for collecting Azure Public IP Addresses, without specifying a payload.

func NewCollectResourceGroupsTask

func NewCollectResourceGroupsTask() *asynq.Task

NewCollectResourceGroupsTask creates a new asynq.Task for collecting Azure Resource Groups, without specifying a payload.

func NewCollectStorageAccountsTask

func NewCollectStorageAccountsTask() *asynq.Task

NewCollectStorageAccountsTask creates a new asynq.Task for collecting Azure Storage Accounts without specifying a payload.

func NewCollectSubnetsTask

func NewCollectSubnetsTask() *asynq.Task

NewCollectSubnetsTask creates a new asynq.Task for collecting Azure Subnets, without specifying a payload.

func NewCollectSubscriptionsTask added in v0.1.14

func NewCollectSubscriptionsTask() *asynq.Task

NewCollectSubscriptionsTask creates a new asynq.Task for collecting Azure Subscriptions, without specifying a payload.

func NewCollectVPCsTask

func NewCollectVPCsTask() *asynq.Task

NewCollectVPCsTask creates a new asynq.Task for collecting Azure VPCs without specifying a payload.

func NewCollectVirtualMachinesTask

func NewCollectVirtualMachinesTask() *asynq.Task

NewCollectVirtualMachinesTask creates a new asynq.Task for collecting Azure Virtual Machines, without specifying a payload.

Types

type CollectBlobContainersPayload

type CollectBlobContainersPayload struct {
	// SubscriptionID specifies the Azure Subscription ID from which to
	// collect.
	SubscriptionID string `json:"subscription_id" yaml:"subscription_id"`

	// ResourceGroup specifies from which resource group to collect.
	ResourceGroup string `json:"resource_group" yaml:"resource_group"`

	// StorageAccount specifies from which storage account to collect.
	StorageAccount string `json:"storage_account" yaml:"storage_account"`
}

CollectBlobContainersPayload is the payload used for collecting Azure Blob containers.

type CollectLoadBalancersPayload

type CollectLoadBalancersPayload struct {
	// SubscriptionID specifies the Azure Subscription ID from which to
	// collect.
	SubscriptionID string `json:"subscription_id" yaml:"subscription_id"`

	// ResourceGroup specifies from which resource group to collect.
	ResourceGroup string `json:"resource_group" yaml:"resource_group"`
}

CollectLoadBalancersPayload is the payload used for collecting Azure Load Balancers.

type CollectNetworkInterfacesPayload added in v0.1.20

type CollectNetworkInterfacesPayload struct {
	// SubscriptionID specifies the Azure Subscription ID from which to
	// collect.
	SubscriptionID string `json:"subscription_id" yaml:"subscription_id"`

	// ResourceGroup specifies from which resource group to collect.
	ResourceGroup string `json:"resource_group" yaml:"resource_group"`
}

CollectNetworkInterfacesPayload is the payload used for collecting Azure Network Interfaces.

type CollectPublicAddressesPayload

type CollectPublicAddressesPayload struct {
	// SubscriptionID specifies the Azure Subscription ID from which to
	// collect.
	SubscriptionID string `json:"subscription_id" yaml:"subscription_id"`

	// ResourceGroup specifies from which resource group to collect.
	ResourceGroup string `json:"resource_group" yaml:"resource_group"`
}

CollectPublicAddressesPayload is the payload used for collecting Azure Public IP Addresses.

type CollectResourceGroupsPayload

type CollectResourceGroupsPayload struct {
	// SubscriptionID specifies the Azure Subscription ID from which to
	// collect.
	SubscriptionID string `json:"subscription_id" yaml:"subscription_id"`
}

CollectResourceGroupsPayload is the payload used for collecting Azure Resource Groups.

type CollectStorageAccountsPayload

type CollectStorageAccountsPayload struct {
	// SubscriptionID specifies the Azure Subscription ID from which to
	// collect.
	SubscriptionID string `json:"subscription_id" yaml:"subscription_id"`

	// ResourceGroup specifies from which resource group to collect.
	ResourceGroup string `json:"resource_group" yaml:"resource_group"`
}

CollectStorageAccountsPayload is the payload used for collecting Azure Storage Accounts.

type CollectSubnetsPayload

type CollectSubnetsPayload struct {
	// SubscriptionID specifies the Azure Subscription ID from which to
	// collect.
	SubscriptionID string `json:"subscription_id" yaml:"subscription_id"`

	// ResourceGroup specifies from which resource group to collect.
	ResourceGroup string `json:"resource_group" yaml:"resource_group"`

	// VPCName specifies from which VPC to collect.
	VPCName string `json:"vpc_name" yaml:"vpc_name"`
}

CollectSubnetsPayload is the payload used for collecting Azure Subnets.

type CollectUsersPayload added in v0.1.13

type CollectUsersPayload struct {
	// TenantID specifies the Azure Tenant ID from which to
	// collect.
	TenantID string `json:"tenant_id" yaml:"tenant_id"`

	// UserPrincipalName specifies the principal name of the user to be
	// collected.
	UserPrincipalName string `json:"user_principal_name" yaml:"user_principal_name"`
}

CollectUsersPayload is the payload used for collecting Microsoft Entra user accounts.

type CollectVPCsPayload

type CollectVPCsPayload struct {
	// SubscriptionID specifies the Azure Subscription ID from which to
	// collect.
	SubscriptionID string `json:"subscription_id" yaml:"subscription_id"`

	// ResourceGroup specifies from which resource group to collect.
	ResourceGroup string `json:"resource_group" yaml:"resource_group"`
}

CollectVPCsPayload is the payload used for collecting Azure VPCs.

type CollectVirtualMachinesPayload

type CollectVirtualMachinesPayload struct {
	// SubscriptionID specifies the Azure Subscription ID from which to
	// collect.
	SubscriptionID string `json:"subscription_id" yaml:"subscription_id"`

	// ResourceGroup specifies from which resource group to collect.
	ResourceGroup string `json:"resource_group" yaml:"resource_group"`
}

CollectVirtualMachinesPayload is the payload used for collecting Azure Virtual Machines.

Jump to

Keyboard shortcuts

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