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 HandleCollectProjectsTask(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 LinkLoadBalancersWithNetworks(ctx context.Context, db *bun.DB) error
- func LinkLoadBalancersWithProjects(ctx context.Context, db *bun.DB) error
- func LinkLoadBalancersWithSubnets(ctx context.Context, db *bun.DB) error
- func LinkNetworksWithProjects(ctx context.Context, db *bun.DB) error
- func LinkServersWithProjects(ctx context.Context, db *bun.DB) error
- func LinkSubnetsWithNetworks(ctx context.Context, db *bun.DB) error
- func LinkSubnetsWithProjects(ctx context.Context, db *bun.DB) error
- func NewCollectFloatingIPsTask() *asynq.Task
- func NewCollectLoadBalancersTask() *asynq.Task
- func NewCollectNetworksTask() *asynq.Task
- func NewCollectProjectsTask() *asynq.Task
- func NewCollectServersTask() *asynq.Task
- func NewCollectSubnetsTask() *asynq.Task
- type CollectFloatingIPsPayload
- type CollectLoadBalancersPayload
- type CollectNetworksPayload
- type CollectProjectsPayload
- 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 ( // TaskCollectProjects is the name of the task for collecting OpenStack // Projects. TaskCollectProjects = "openstack:task:collect-projects" )
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 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 ¶
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 HandleCollectProjectsTask ¶ added in v0.1.11
HandleCollectProjectsTask handles the task for collecting OpenStack Projects.
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 LinkLoadBalancersWithNetworks ¶ added in v0.1.11
LinkLoadBalancersWithNetworks creates links between the OpenStack LoadBalancers and Networks
func LinkLoadBalancersWithProjects ¶ added in v0.1.11
LinkLoadBalancersWithProjects creates links between the OpenStack LoadBalancers and Projects
func LinkLoadBalancersWithSubnets ¶
LinkLoadBalancersWithSubnets creates links between the OpenStack LoadBalancers and Subnets
func LinkNetworksWithProjects ¶ added in v0.1.11
LinkNetworksWithProjects creates links between the OpenStack Networks and Projects
func LinkServersWithProjects ¶ added in v0.1.11
LinkServersWithProjects creates links between the OpenStack Servers and Projects
func LinkSubnetsWithNetworks ¶
LinkSubnetsWithNetworks creates links between the OpenStack Subnets and Networks
func LinkSubnetsWithProjects ¶ added in v0.1.11
LinkSubnetsWithProjects creates links between the OpenStack Subnets and Projects
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 NewCollectProjectsTask ¶ added in v0.1.11
NewCollectProjectsTask creates a new asynq.Task for collecting OpenStack Projects, 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 {
// 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 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 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.
Source Files