tasks

package
v0.1.16 Latest Latest
Warning

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

Go to latest
Published: Jul 30, 2025 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

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

	// TaskLinkAll is a task, which creates links between the OpenStack
	// models.
	TaskLinkAll = "openstack:task:link-all"
)
View Source
const (
	// TaskCollectContainers is the name of the task for collecting OpenStack
	// Containers.
	TaskCollectContainers = "openstack:task:collect-containers"
)
View Source
const (
	// TaskCollectFloatingIPs is the name of the task for collecting OpenStack
	// Floating IPs.
	TaskCollectFloatingIPs = "openstack:task:collect-floating-ips"
)
View Source
const (
	// TaskCollectLoadBalancers is the name of the task for collecting OpenStack
	// LoadBalancers.
	TaskCollectLoadBalancers = "openstack:task:collect-loadbalancers"
)
View Source
const (
	// TaskCollectNetworks is the name of the task for collecting OpenStack
	// Networks.
	TaskCollectNetworks = "openstack:task:collect-networks"
)
View Source
const (
	// TaskCollectObjects is the name of the task for collecting OpenStack
	// Objects.
	TaskCollectObjects = "openstack:task:collect-objects"
)
View Source
const (
	// TaskCollectPools is the name of the task for collecting OpenStack
	// Pools.
	TaskCollectPools = "openstack:task:collect-pools"
)
View Source
const (
	// TaskCollectPorts is the name of the task for collecting OpenStack Ports.
	TaskCollectPorts = "openstack:task:collect-ports"
)
View Source
const (
	// TaskCollectProjects is the name of the task for collecting OpenStack
	// Projects.
	TaskCollectProjects = "openstack:task:collect-projects"
)
View Source
const (
	// TaskCollectRouters is the name of the task for collecting
	// OpenStack Routers.
	TaskCollectRouters = "openstack:task:collect-routers"
)
View Source
const (
	// TaskCollectServers is the name of the task for collecting OpenStack
	// servers.
	TaskCollectServers = "openstack:task:collect-servers"
)
View Source
const (
	// TaskCollectSubnets is the name of the task for collecting OpenStack
	// Subnets.
	TaskCollectSubnets = "openstack:task:collect-subnets"
)
View Source
const (
	// TaskCollectVolumes is the name of the task for collecting OpenStack
	// Volumes.
	TaskCollectVolumes = "openstack:task:collect-volumes"
)

Variables

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

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

View Source
var ErrInvalidScope = errors.New("invalid scope specified")

ErrInvalidScope is an error which is returned when a valid scope was not specified in a task payload.

Functions

func ClientNotFound

func ClientNotFound(name string) error

ClientNotFound wraps ErrClientNotFound with the given name.

func HandleCollectAllTask

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

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

func HandleCollectContainersTask added in v0.1.14

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

HandleCollectContainersTask handles the task for collecting OpenStack Containers.

func HandleCollectFloatingIPsTask

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

HandleCollectFloatingIPsTask handles the task for collecting OpenStack FloatingIPs.

func HandleCollectLoadBalancersTask

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

HandleCollectLoadBalancersTask handles the task for collecting OpenStack LoadBalancers.

func HandleCollectNetworksTask

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

HandleCollectNetworksTask handles the task for collecting OpenStack Networks.

func HandleCollectObjectsTask added in v0.1.13

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

HandleCollectObjectsTask handles the task for collecting OpenStack Objects.

func HandleCollectPoolsTask added in v0.1.14

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

HandleCollectPoolsTask handles the task for collecting OpenStack Pools.

func HandleCollectPortsTask added in v0.1.13

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

HandleCollectPortsTask handles the task for collecting OpenStack Ports.

func HandleCollectProjectsTask added in v0.1.11

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

HandleCollectProjectsTask handles the task for collecting OpenStack Projects.

func HandleCollectRoutersTask added in v0.1.13

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

HandleCollectRoutersTask handles the task for collecting OpenStack Routers.

func HandleCollectServersTask

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

HandleCollectServersTask handles the task for collecting OpenStack Servers.

func HandleCollectSubnetsTask

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

HandleCollectSubnetsTask handles the task for collecting OpenStack Subnets.

func HandleCollectVolumesTask added in v0.1.16

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

HandleCollectVolumesTask handles the task for collecting OpenStack Volumes.

func HandleLinkAllTask

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

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

func LinkLoadBalancersWithNetworks added in v0.1.11

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

LinkLoadBalancersWithNetworks creates links between the OpenStack LoadBalancers and Networks

func LinkLoadBalancersWithProjects added in v0.1.11

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

LinkLoadBalancersWithProjects creates links between the OpenStack LoadBalancers and Projects

func LinkLoadBalancersWithSubnets

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

LinkLoadBalancersWithSubnets creates links between the OpenStack LoadBalancers and Subnets

func LinkNetworksWithProjects added in v0.1.11

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

LinkNetworksWithProjects creates links between the OpenStack Networks and Projects

func LinkPortsWithServers added in v0.1.13

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

LinkPortsWithServers creates links between the OpenStack Ports and Servers

func LinkServersWithNetworks added in v0.1.13

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

LinkServersWithNetworks creates links between the OpenStack Servers and Networks

func LinkServersWithProjects added in v0.1.11

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

LinkServersWithProjects creates links between the OpenStack Servers and Projects

func LinkSubnetsWithNetworks

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

LinkSubnetsWithNetworks creates links between the OpenStack Subnets and Networks

func LinkSubnetsWithProjects added in v0.1.11

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

LinkSubnetsWithProjects creates links between the OpenStack Subnets and Projects

func NewCollectContainersTask added in v0.1.14

func NewCollectContainersTask() *asynq.Task

NewCollectContainersTask creates a new asynq.Task for collecting OpenStack Containers, without specifying a payload.

func NewCollectFloatingIPsTask

func NewCollectFloatingIPsTask() *asynq.Task

NewCollectFloatingIPsTask creates a new asynq.Task for collecting OpenStack FloatingIPs, without specifying a payload.

func NewCollectLoadBalancersTask

func NewCollectLoadBalancersTask() *asynq.Task

NewCollectLoadBalancersTask creates a new asynq.Task for collecting OpenStack LoadBalancers, without specifying a payload.

func NewCollectNetworksTask

func NewCollectNetworksTask() *asynq.Task

NewCollectNetworksTask creates a new asynq.Task for collecting OpenStack Networks, without specifying a payload.

func NewCollectObjectsTask added in v0.1.13

func NewCollectObjectsTask() *asynq.Task

NewCollectObjectsTask creates a new asynq.Task for collecting OpenStack Objects, without specifying a payload.

func NewCollectPoolsTask added in v0.1.14

func NewCollectPoolsTask() *asynq.Task

NewCollectPoolsTask creates a new asynq.Task for collecting OpenStack Pools, without specifying a payload.

func NewCollectPortsTask added in v0.1.13

func NewCollectPortsTask() *asynq.Task

NewCollectPortsTask creates a new asynq.Task for collecting OpenStack Ports, without specifying a payload.

func NewCollectProjectsTask added in v0.1.11

func NewCollectProjectsTask() *asynq.Task

NewCollectProjectsTask creates a new asynq.Task for collecting OpenStack Projects, without specifying a payload.

func NewCollectRoutersTask added in v0.1.13

func NewCollectRoutersTask() *asynq.Task

NewCollectRoutersTask creates a new asynq.Task for collecting OpenStack Routers, without specifying a payload.

func NewCollectServersTask

func NewCollectServersTask() *asynq.Task

NewCollectServersTask creates a new asynq.Task for collecting OpenStack servers, without specifying a payload.

func NewCollectSubnetsTask

func NewCollectSubnetsTask() *asynq.Task

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

func NewCollectVolumesTask added in v0.1.16

func NewCollectVolumesTask() *asynq.Task

NewCollectVolumesTask creates a new asynq.Task for collecting OpenStack Volumes, without specifying a payload.

Types

type CollectContainersPayload added in v0.1.14

type CollectContainersPayload struct {
	// Scope specifies the client scope for which to collect.
	Scope openstackclients.ClientScope `json:"scope" yaml:"scope"`
}

CollectContainersPayload represents the payload, which specifies where to collect OpenStack Containers from.

type CollectFloatingIPsPayload

type CollectFloatingIPsPayload struct {
	// Scope specifies the client scope to use for collection.
	Scope openstackclients.ClientScope `json:"scope" yaml:"scope"`
}

CollectFloatingIPsPayload represents the payload, which specifies the scope for collecting OpenStack Floating IPs.

type CollectLoadBalancersPayload

type CollectLoadBalancersPayload struct {
	// Scope specifies the project scope to use for collection.
	Scope openstackclients.ClientScope `json:"scope" yaml:"scope"`
}

CollectLoadBalancersPayload represents the payload, which specifies where to collect OpenStack LoadBalancers from.

type CollectNetworksPayload

type CollectNetworksPayload struct {
	// Scope specifies the client scope for which to collect.
	Scope openstackclients.ClientScope `json:"scope" yaml:"scope"`
}

CollectNetworksPayload represents the payload, which specifies which client to collect OpenStack Networks with.

type CollectObjectsPayload added in v0.1.13

type CollectObjectsPayload struct {
	// Scope specifies the client scope for which to collect.
	Scope openstackclients.ClientScope `json:"scope" yaml:"scope"`
}

CollectObjectsPayload represents the payload, which specifies where to collect OpenStack Objects from.

type CollectPoolsPayload added in v0.1.14

type CollectPoolsPayload struct {
	// Scope specifies the project scope to use for collection.
	Scope openstackclients.ClientScope `json:"scope" yaml:"scope"`
}

CollectPoolsPayload represents the payload, which specifies where to collect OpenStack Pools from.

type CollectPortsPayload added in v0.1.13

type CollectPortsPayload struct {
	// Scope specifies the client scope for which to collect.
	Scope openstackclients.ClientScope `json:"scope" yaml:"scope"`
}

CollectPortsPayload represents the payload, which specifies where to collect OpenStack Ports from.

type CollectProjectsPayload added in v0.1.11

type CollectProjectsPayload struct {
	// Scope specifies the scope of the client to be used.
	Scope openstackclients.ClientScope `json:"scope" yaml:"scope"`
}

CollectProjectsPayload represents the payload, which specifies where to collect OpenStack Projects from.

type CollectRoutersPayload added in v0.1.13

type CollectRoutersPayload struct {
	// Scope specifies the client scope for which to collect.
	Scope openstackclients.ClientScope `json:"scope" yaml:"scope"`
}

CollectRoutersPayload represents the payload, which specifies where to collect OpenStack Routers from.

type CollectServersPayload

type CollectServersPayload struct {
	// Scope specifies the client scope for which to collect.
	Scope openstackclients.ClientScope `json:"scope" yaml:"scope"`
}

CollectServersPayload represents the payload, which specifies where to collect OpenStack Servers from.

type CollectSubnetsPayload

type CollectSubnetsPayload struct {
	// Scope specifies the client scope from which to collect.
	Scope openstackclients.ClientScope `json:"scope" yaml:"scope"`
}

CollectSubnetsPayload represents the payload, which specifies where to collect OpenStack Subnets from.

type CollectVolumesPayload added in v0.1.16

type CollectVolumesPayload struct {
	// Scope specifies the client scope for which to collect.
	Scope openstackclients.ClientScope `json:"scope" yaml:"scope"`
}

CollectVolumesPayload represents the payload, which specifies where to collect OpenStack Volumes from.

Jump to

Keyboard shortcuts

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