openstack

Documentation

Index

• func NewCombinedSyncer(ctx context.Context, keystoneAPI keystone.KeystoneAPI, ...) sync.Datasource
• type CombinedSyncer
  • func (s CombinedSyncer) Init(ctx context.Context)
  • func (s CombinedSyncer) Sync(context context.Context)
• type Syncer

Functions

func NewCombinedSyncer

func NewCombinedSyncer(
	ctx context.Context,
	keystoneAPI keystone.KeystoneAPI,
	config conf.SyncOpenStackConfig,
	monitor sync.Monitor,
	db db.DB,
	mqttClient mqtt.Client,
) sync.Datasource

Create a new combined syncer that runs multiple syncers in parallel.

Types

type CombinedSyncer

type CombinedSyncer struct {
	// contains filtered or unexported fields
}

Combined syncer that combines multiple syncers.

func (CombinedSyncer) Init

func (s CombinedSyncer) Init(ctx context.Context)

Create all needed database tables if they do not exist.

func (CombinedSyncer) Sync

func (s CombinedSyncer) Sync(context context.Context)

Sync all objects from OpenStack to the database.

type Syncer

type Syncer interface {
	Init(context.Context)
	Sync(context.Context) error
}