Documentation
¶
Index ¶
- Constants
- Variables
- func ClientNotFound(name string) error
- func HandleCollectAllTask(ctx context.Context, t *asynq.Task) error
- func HandleCollectFloatingIPsTask(ctx context.Context, t *asynq.Task) error
- func HandleCollectLoadBalancersTask(ctx context.Context, t *asynq.Task) error
- func HandleCollectNetworksTask(ctx context.Context, t *asynq.Task) error
- func HandleCollectServersTask(ctx context.Context, t *asynq.Task) error
- func HandleCollectSubnetsTask(ctx context.Context, t *asynq.Task) error
- func HandleLinkAllTask(ctx context.Context, t *asynq.Task) error
- func LinkLoadBalancersWithSubnets(ctx context.Context, db *bun.DB) error
- func LinkSubnetsWithNetworks(ctx context.Context, db *bun.DB) error
- func NewCollectFloatingIPsTask() *asynq.Task
- func NewCollectLoadBalancersTask() *asynq.Task
- func NewCollectNetworksTask() *asynq.Task
- func NewCollectServersTask() *asynq.Task
- func NewCollectSubnetsTask() *asynq.Task
- type CollectFloatingIPsPayload
- type CollectLoadBalancersPayload
- type CollectNetworksPayload
- type CollectServersPayload
- type CollectSubnetsPayload
Constants ¶
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" )
const ( // TaskCollectFloatingIPs is the name of the task for collecting OpenStack // Floating IPs. TaskCollectFloatingIPs = "openstack:task:collect-floating-ips" )
const ( // TaskCollectLoadBalancers is the name of the task for collecting OpenStack // LoadBalancers. TaskCollectLoadBalancers = "openstack:task:collect-loadbalancers" )
const ( // TaskCollectNetworks is the name of the task for collecting OpenStack // Networks. TaskCollectNetworks = "openstack:task:collect-networks" )
const ( // TaskCollectServers is the name of the task for collecting OpenStack // servers. TaskCollectServers = "openstack:task:collect-servers" )
const ( // TaskCollectSubnets is the name of the task for collecting OpenStack // Subnets. TaskCollectSubnets = "openstack:task:collect-subnets" )
Variables ¶
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.
var ErrNoProjectID = errors.New("no project ID specified")
ErrNoProjectID is an error which is returned when an project id was not specified in a task payload.
Functions ¶
func ClientNotFound ¶
ClientNotFound wraps ErrClientNotFound with the given name.
func HandleCollectAllTask ¶
HandleCollectAllTask is a handler, which enqueues tasks for collecting all OpenStack objects.
func HandleCollectFloatingIPsTask ¶
HandleCollectFloatingIPsTask handles the task for collecting OpenStack FloatingIPs.
func HandleCollectLoadBalancersTask ¶
HandleCollectLoadBalancersTask handles the task for collecting OpenStack LoadBalancers.
func HandleCollectNetworksTask ¶
HandleCollectNetworksTask handles the task for collecting OpenStack Networks.
func HandleCollectServersTask ¶
HandleCollectServersTask handles the task for collecting OpenStack Servers.
func HandleCollectSubnetsTask ¶
HandleCollectSubnetsTask handles the task for collecting OpenStack Subnets.
func HandleLinkAllTask ¶
HandleLinkAllTask is a handler, which establishes links between the various OpenStack models.
func LinkLoadBalancersWithSubnets ¶
LinkLoadBalancersWithSubnets creates links between the OpenStack LoadBalancers and Subnets
func LinkSubnetsWithNetworks ¶
LinkSubnetsWithNetworks creates links between the OpenStack Subnets and Networks
func NewCollectFloatingIPsTask ¶
NewCollectFloatingIPsTask creates a new asynq.Task for collecting OpenStack FloatingIPs, without specifying a payload.
func NewCollectLoadBalancersTask ¶
NewCollectLoadBalancersTask creates a new asynq.Task for collecting OpenStack LoadBalancers, without specifying a payload.
func NewCollectNetworksTask ¶
NewCollectNetworksTask creates a new asynq.Task for collecting OpenStack Networks, without specifying a payload.
func NewCollectServersTask ¶
NewCollectServersTask creates a new asynq.Task for collecting OpenStack servers, without specifying a payload.
func NewCollectSubnetsTask ¶
NewCollectSubnetsTask creates a new asynq.Task for collecting OpenStack Subnets, without specifying a payload.
Types ¶
type CollectFloatingIPsPayload ¶
type CollectFloatingIPsPayload struct {
// Project specifies the project from which to collect.
ProjectID string `json:"project_id" yaml:"project_id"`
}
CollectFloatingIPsPayload represents the payload, which specifies from which project to collect OpenStack Floating IPs.
type CollectLoadBalancersPayload ¶
type CollectLoadBalancersPayload struct {
// Project specifies the project from which to collect.
ProjectID string `json:"project_id" yaml:"project_id"`
}
CollectLoadBalancersPayload represents the payload, which specifies where to collect OpenStack LoadBalancers from.
type CollectNetworksPayload ¶
type CollectNetworksPayload struct {
// Project specifies the project from which to collect.
ProjectID string `json:"project_id" yaml:"project_id"`
}
CollectNetworksPayload represents the payload, which specifies where to collect OpenStack Networks from.
type CollectServersPayload ¶
type CollectServersPayload struct {
// Project specifies the project from which to collect.
ProjectID string `json:"project_id" yaml:"project_id"`
}
CollectServersPayload represents the payload, which specifies where to collect OpenStack Servers from.
type CollectSubnetsPayload ¶
type CollectSubnetsPayload struct {
// Project specifies the project from which to collect.
ProjectID string `json:"project_id" yaml:"project_id"`
}
CollectSubnetsPayload represents the payload, which specifies where to collect OpenStack Subnets from.
Source Files