nova

type NovaAPI interface {
	// Init the nova API.
	Init(ctx context.Context)
	// Get all nova servers that are NOT deleted. (Includes ERROR, SHUTOFF etc)
	GetAllServers(ctx context.Context) ([]nova.Server, error)
	// Get all deleted nova servers since the timestamp.
	GetDeletedServers(ctx context.Context, since time.Time) ([]nova.DeletedServer, error)
	// Get all nova hypervisors.
	GetAllHypervisors(ctx context.Context) ([]nova.Hypervisor, error)
	// Get all nova flavors.
	GetAllFlavors(ctx context.Context) ([]nova.Flavor, error)
	// Get all nova migrations.
	GetAllMigrations(ctx context.Context) ([]nova.Migration, error)
	// Get all aggregates.
	GetAllAggregates(ctx context.Context) ([]nova.Aggregate, error)
}

type NovaSyncer struct {
	// Database to store the nova objects in.
	DB db.DB
	// Monitor to track the syncer.
	Mon sync.Monitor
	// Configuration for the nova syncer.
	Conf conf.SyncOpenStackNovaConfig
	// Nova API client to fetch the data.
	API NovaAPI
	// MQTT client to publish mqtt data.
	MqttClient mqtt.Client
}