Help us shape the future of Go! Take the 2026 Go Developer Survey

tasks

package
v0.1.23 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source
const (
	// TaskCollectPools is the name of the task for collecting OpenStack
	// Pools.
	TaskCollectPools = "openstack:task:collect-pools"
	// TaskCollectPoolMembers is the name of the task for collecting OpenStack
	// Pool Members for a specific pool.
	TaskCollectPoolMembers = "openstack:task:collect-pool-members"
)
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 (
	// 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 HandleCollectPoolMembersTask added in v0.1.19

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

HandleCollectPoolMembersTask handles the task for collecting OpenStack Pool Members for a specific pool.

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 NewCollectPoolMembersTask added in v0.1.19

func NewCollectPoolMembersTask(payload CollectPoolMembersPayload) (*asynq.Task, error)

NewCollectPoolMembersTask creates a new asynq.Task for collecting OpenStack Pool Members for a specific pool.

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 CollectPoolMembersPayload added in v0.1.19

type CollectPoolMembersPayload struct {
	// Scope specifies the project scope to use for collection.
	Scope openstackclients.ClientScope `json:"scope" yaml:"scope"`
	// PoolID is the ID of the pool to collect members for.
	PoolID string `json:"pool_id" yaml:"pool_id"`
}

CollectPoolMembersPayload represents the payload for collecting pool members for a specific pool.

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