Documentation
¶
Index ¶
- type Handler
- func (s *Handler) GetMigrationState(ctx context.Context, batchStatus api.BatchStatusType, ...) (map[string]MigrationState, error)
- func (s *Handler) InitWorkerCache(initial map[uuid.UUID]time.Time) error
- func (s *Handler) LastWorkerUpdate(instanceUUID uuid.UUID) time.Time
- func (s *Handler) RecordWorkerUpdate(instanceUUID uuid.UUID)
- func (s *Handler) RemoveFromCache(instanceUUID uuid.UUID)
- type MigrationState
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Handler ¶
type Handler struct {
// contains filtered or unexported fields
}
Handler handles interaction between services for the queue.
func NewMigrationHandler ¶
func NewMigrationHandler(b migration.BatchService, i migration.InstanceService, n migration.NetworkService, s migration.SourceService, t migration.TargetService, q migration.QueueService) *Handler
NewMigrationHandler creates a new handler for queued migrations.
func (*Handler) GetMigrationState ¶
func (s *Handler) GetMigrationState(ctx context.Context, batchStatus api.BatchStatusType, migrationStatuses ...api.MigrationStatusType) (map[string]MigrationState, error)
GetMigrationState fetches all migration state information corresponding to the given batch status and migration status.
func (*Handler) InitWorkerCache ¶
func (*Handler) LastWorkerUpdate ¶
func (*Handler) RecordWorkerUpdate ¶
RecordWorkerUpdate caches the last worker update that the corresponding instance has received.
func (*Handler) RemoveFromCache ¶
RemoveFromCache removes the given instanceUUID from the worker cache.
type MigrationState ¶
type MigrationState struct {
Batch migration.Batch
Target migration.Target
MigrationWindows migration.MigrationWindows
QueueEntries map[uuid.UUID]migration.QueueEntry
Instances map[uuid.UUID]migration.Instance
Sources map[uuid.UUID]migration.Source
}
MigrationState is a cache of all migration data for a batch, queued by instance.
Source Files
Click to show internal directories.
Click to hide internal directories.