middleware

package
v0.0.0-pre.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 14, 2025 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BatchRepoWithSlog 

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

BatchRepoWithSlog implements _sourceMigration.BatchRepo that is instrumented with slog logger

func NewBatchRepoWithSlog 

func NewBatchRepoWithSlog(base _sourceMigration.BatchRepo, log *slog.Logger) BatchRepoWithSlog

NewBatchRepoWithSlog instruments an implementation of the _sourceMigration.BatchRepo with simple logging

func (BatchRepoWithSlog) AssignBatch 

func (_d BatchRepoWithSlog) AssignBatch(ctx context.Context, batchName string, instanceUUID uuid.UUID) (err error)

AssignBatch implements _sourceMigration.BatchRepo

func (BatchRepoWithSlog) AssignMigrationWindows 

func (_d BatchRepoWithSlog) AssignMigrationWindows(ctx context.Context, batch string, windows _sourceMigration.MigrationWindows) (err error)

AssignMigrationWindows implements _sourceMigration.BatchRepo

func (BatchRepoWithSlog) Create 

func (_d BatchRepoWithSlog) Create(ctx context.Context, batch _sourceMigration.Batch) (i1 int64, err error)

Create implements _sourceMigration.BatchRepo

func (BatchRepoWithSlog) DeleteByName 

func (_d BatchRepoWithSlog) DeleteByName(ctx context.Context, name string) (err error)

DeleteByName implements _sourceMigration.BatchRepo

func (BatchRepoWithSlog) GetAll 

func (_d BatchRepoWithSlog) GetAll(ctx context.Context) (b1 _sourceMigration.Batches, err error)

GetAll implements _sourceMigration.BatchRepo

func (BatchRepoWithSlog) GetAllByState 

func (_d BatchRepoWithSlog) GetAllByState(ctx context.Context, status api.BatchStatusType) (b1 _sourceMigration.Batches, err error)

GetAllByState implements _sourceMigration.BatchRepo

func (BatchRepoWithSlog) GetAllNames 

func (_d BatchRepoWithSlog) GetAllNames(ctx context.Context) (sa1 []string, err error)

GetAllNames implements _sourceMigration.BatchRepo

func (BatchRepoWithSlog) GetAllNamesByState 

func (_d BatchRepoWithSlog) GetAllNamesByState(ctx context.Context, status api.BatchStatusType) (sa1 []string, err error)

GetAllNamesByState implements _sourceMigration.BatchRepo

func (BatchRepoWithSlog) GetByName 

func (_d BatchRepoWithSlog) GetByName(ctx context.Context, name string) (bp1 *_sourceMigration.Batch, err error)

GetByName implements _sourceMigration.BatchRepo

func (BatchRepoWithSlog) GetMigrationWindowsByBatch 

func (_d BatchRepoWithSlog) GetMigrationWindowsByBatch(ctx context.Context, batch string) (m1 _sourceMigration.MigrationWindows, err error)

GetMigrationWindowsByBatch implements _sourceMigration.BatchRepo

func (BatchRepoWithSlog) Rename 

func (_d BatchRepoWithSlog) Rename(ctx context.Context, oldName string, newName string) (err error)

Rename implements _sourceMigration.BatchRepo

func (BatchRepoWithSlog) UnassignBatch 

func (_d BatchRepoWithSlog) UnassignBatch(ctx context.Context, batchName string, instanceUUID uuid.UUID) (err error)

UnassignBatch implements _sourceMigration.BatchRepo

func (BatchRepoWithSlog) UnassignMigrationWindows 

func (_d BatchRepoWithSlog) UnassignMigrationWindows(ctx context.Context, batch string) (err error)

UnassignMigrationWindows implements _sourceMigration.BatchRepo

func (BatchRepoWithSlog) Update 

func (_d BatchRepoWithSlog) Update(ctx context.Context, name string, batch _sourceMigration.Batch) (err error)

Update implements _sourceMigration.BatchRepo

type InstanceRepoWithSlog 

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

InstanceRepoWithSlog implements _sourceMigration.InstanceRepo that is instrumented with slog logger

func NewInstanceRepoWithSlog 

func NewInstanceRepoWithSlog(base _sourceMigration.InstanceRepo, log *slog.Logger) InstanceRepoWithSlog

NewInstanceRepoWithSlog instruments an implementation of the _sourceMigration.InstanceRepo with simple logging

func (InstanceRepoWithSlog) Create 

func (_d InstanceRepoWithSlog) Create(ctx context.Context, instance _sourceMigration.Instance) (i1 int64, err error)

Create implements _sourceMigration.InstanceRepo

func (InstanceRepoWithSlog) DeleteByUUID 

func (_d InstanceRepoWithSlog) DeleteByUUID(ctx context.Context, id uuid.UUID) (err error)

DeleteByUUID implements _sourceMigration.InstanceRepo

func (InstanceRepoWithSlog) GetAll 

func (_d InstanceRepoWithSlog) GetAll(ctx context.Context) (i1 _sourceMigration.Instances, err error)

GetAll implements _sourceMigration.InstanceRepo

func (InstanceRepoWithSlog) GetAllAssigned 

func (_d InstanceRepoWithSlog) GetAllAssigned(ctx context.Context) (i1 _sourceMigration.Instances, err error)

GetAllAssigned implements _sourceMigration.InstanceRepo

func (InstanceRepoWithSlog) GetAllByBatch 

func (_d InstanceRepoWithSlog) GetAllByBatch(ctx context.Context, batch string) (i1 _sourceMigration.Instances, err error)

GetAllByBatch implements _sourceMigration.InstanceRepo

func (InstanceRepoWithSlog) GetAllBySource 

func (_d InstanceRepoWithSlog) GetAllBySource(ctx context.Context, source string) (i1 _sourceMigration.Instances, err error)

GetAllBySource implements _sourceMigration.InstanceRepo

func (InstanceRepoWithSlog) GetAllByUUIDs 

func (_d InstanceRepoWithSlog) GetAllByUUIDs(ctx context.Context, id ...uuid.UUID) (i1 _sourceMigration.Instances, err error)

GetAllByUUIDs implements _sourceMigration.InstanceRepo

func (InstanceRepoWithSlog) GetAllUUIDs 

func (_d InstanceRepoWithSlog) GetAllUUIDs(ctx context.Context) (ua1 []uuid.UUID, err error)

GetAllUUIDs implements _sourceMigration.InstanceRepo

func (InstanceRepoWithSlog) GetAllUUIDsBySource 

func (_d InstanceRepoWithSlog) GetAllUUIDsBySource(ctx context.Context, source string) (ua1 []uuid.UUID, err error)

GetAllUUIDsBySource implements _sourceMigration.InstanceRepo

func (InstanceRepoWithSlog) GetAllUnassigned 

func (_d InstanceRepoWithSlog) GetAllUnassigned(ctx context.Context) (i1 _sourceMigration.Instances, err error)

GetAllUnassigned implements _sourceMigration.InstanceRepo

func (InstanceRepoWithSlog) GetBatchesByUUID 

func (_d InstanceRepoWithSlog) GetBatchesByUUID(ctx context.Context, instanceUUID uuid.UUID) (b1 _sourceMigration.Batches, err error)

GetBatchesByUUID implements _sourceMigration.InstanceRepo

func (InstanceRepoWithSlog) GetByUUID 

func (_d InstanceRepoWithSlog) GetByUUID(ctx context.Context, id uuid.UUID) (ip1 *_sourceMigration.Instance, err error)

GetByUUID implements _sourceMigration.InstanceRepo

func (InstanceRepoWithSlog) RemoveFromQueue 

func (_d InstanceRepoWithSlog) RemoveFromQueue(ctx context.Context, id uuid.UUID) (err error)

RemoveFromQueue implements _sourceMigration.InstanceRepo

func (InstanceRepoWithSlog) Update 

func (_d InstanceRepoWithSlog) Update(ctx context.Context, instance _sourceMigration.Instance) (err error)

Update implements _sourceMigration.InstanceRepo

type NetworkRepoWithSlog 

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

NetworkRepoWithSlog implements _sourceMigration.NetworkRepo that is instrumented with slog logger

func NewNetworkRepoWithSlog 

func NewNetworkRepoWithSlog(base _sourceMigration.NetworkRepo, log *slog.Logger) NetworkRepoWithSlog

NewNetworkRepoWithSlog instruments an implementation of the _sourceMigration.NetworkRepo with simple logging

func (NetworkRepoWithSlog) Create 

func (_d NetworkRepoWithSlog) Create(ctx context.Context, network _sourceMigration.Network) (i1 int64, err error)

Create implements _sourceMigration.NetworkRepo

func (NetworkRepoWithSlog) DeleteByNameAndSource 

func (_d NetworkRepoWithSlog) DeleteByNameAndSource(ctx context.Context, name string, src string) (err error)

DeleteByNameAndSource implements _sourceMigration.NetworkRepo

func (NetworkRepoWithSlog) GetAll 

func (_d NetworkRepoWithSlog) GetAll(ctx context.Context) (n1 _sourceMigration.Networks, err error)

GetAll implements _sourceMigration.NetworkRepo

func (NetworkRepoWithSlog) GetAllBySource 

func (_d NetworkRepoWithSlog) GetAllBySource(ctx context.Context, src string) (n1 _sourceMigration.Networks, err error)

GetAllBySource implements _sourceMigration.NetworkRepo

func (NetworkRepoWithSlog) GetByNameAndSource 

func (_d NetworkRepoWithSlog) GetByNameAndSource(ctx context.Context, name string, src string) (np1 *_sourceMigration.Network, err error)

GetByNameAndSource implements _sourceMigration.NetworkRepo

func (NetworkRepoWithSlog) Update 

func (_d NetworkRepoWithSlog) Update(ctx context.Context, network _sourceMigration.Network) (err error)

Update implements _sourceMigration.NetworkRepo

type QueueRepoWithSlog 

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

QueueRepoWithSlog implements _sourceMigration.QueueRepo that is instrumented with slog logger

func NewQueueRepoWithSlog 

func NewQueueRepoWithSlog(base _sourceMigration.QueueRepo, log *slog.Logger) QueueRepoWithSlog

NewQueueRepoWithSlog instruments an implementation of the _sourceMigration.QueueRepo with simple logging

func (QueueRepoWithSlog) Create 

func (_d QueueRepoWithSlog) Create(ctx context.Context, queue _sourceMigration.QueueEntry) (i1 int64, err error)

Create implements _sourceMigration.QueueRepo

func (QueueRepoWithSlog) DeleteAllByBatch 

func (_d QueueRepoWithSlog) DeleteAllByBatch(ctx context.Context, batch string) (err error)

DeleteAllByBatch implements _sourceMigration.QueueRepo

func (QueueRepoWithSlog) DeleteByUUID 

func (_d QueueRepoWithSlog) DeleteByUUID(ctx context.Context, id uuid.UUID) (err error)

DeleteByUUID implements _sourceMigration.QueueRepo

func (QueueRepoWithSlog) GetAll 

func (_d QueueRepoWithSlog) GetAll(ctx context.Context) (q1 _sourceMigration.QueueEntries, err error)

GetAll implements _sourceMigration.QueueRepo

func (QueueRepoWithSlog) GetAllByBatch 

func (_d QueueRepoWithSlog) GetAllByBatch(ctx context.Context, batch string) (q1 _sourceMigration.QueueEntries, err error)

GetAllByBatch implements _sourceMigration.QueueRepo

func (QueueRepoWithSlog) GetAllByBatchAndState 

func (_d QueueRepoWithSlog) GetAllByBatchAndState(ctx context.Context, batch string, statuses ...api.MigrationStatusType) (q1 _sourceMigration.QueueEntries, err error)

GetAllByBatchAndState implements _sourceMigration.QueueRepo

func (QueueRepoWithSlog) GetAllByState 

func (_d QueueRepoWithSlog) GetAllByState(ctx context.Context, status ...api.MigrationStatusType) (q1 _sourceMigration.QueueEntries, err error)

GetAllByState implements _sourceMigration.QueueRepo

func (QueueRepoWithSlog) GetAllNeedingImport 

func (_d QueueRepoWithSlog) GetAllNeedingImport(ctx context.Context, batch string, needsDiskImport bool) (q1 _sourceMigration.QueueEntries, err error)

GetAllNeedingImport implements _sourceMigration.QueueRepo

func (QueueRepoWithSlog) GetByInstanceUUID 

func (_d QueueRepoWithSlog) GetByInstanceUUID(ctx context.Context, id uuid.UUID) (qp1 *_sourceMigration.QueueEntry, err error)

GetByInstanceUUID implements _sourceMigration.QueueRepo

func (QueueRepoWithSlog) Update 

func (_d QueueRepoWithSlog) Update(ctx context.Context, entry _sourceMigration.QueueEntry) (err error)

Update implements _sourceMigration.QueueRepo

type SourceRepoWithSlog 

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

SourceRepoWithSlog implements _sourceMigration.SourceRepo that is instrumented with slog logger

func NewSourceRepoWithSlog 

func NewSourceRepoWithSlog(base _sourceMigration.SourceRepo, log *slog.Logger) SourceRepoWithSlog

NewSourceRepoWithSlog instruments an implementation of the _sourceMigration.SourceRepo with simple logging

func (SourceRepoWithSlog) Create 

func (_d SourceRepoWithSlog) Create(ctx context.Context, source _sourceMigration.Source) (i1 int64, err error)

Create implements _sourceMigration.SourceRepo

func (SourceRepoWithSlog) DeleteByName 

func (_d SourceRepoWithSlog) DeleteByName(ctx context.Context, name string) (err error)

DeleteByName implements _sourceMigration.SourceRepo

func (SourceRepoWithSlog) GetAll 

func (_d SourceRepoWithSlog) GetAll(ctx context.Context, sourceTypes ...api.SourceType) (s1 _sourceMigration.Sources, err error)

GetAll implements _sourceMigration.SourceRepo

func (SourceRepoWithSlog) GetAllNames 

func (_d SourceRepoWithSlog) GetAllNames(ctx context.Context, sourceTypes ...api.SourceType) (sa1 []string, err error)

GetAllNames implements _sourceMigration.SourceRepo

func (SourceRepoWithSlog) GetByName 

func (_d SourceRepoWithSlog) GetByName(ctx context.Context, name string) (sp1 *_sourceMigration.Source, err error)

GetByName implements _sourceMigration.SourceRepo

func (SourceRepoWithSlog) Rename 

func (_d SourceRepoWithSlog) Rename(ctx context.Context, oldName string, newName string) (err error)

Rename implements _sourceMigration.SourceRepo

func (SourceRepoWithSlog) Update 

func (_d SourceRepoWithSlog) Update(ctx context.Context, name string, source _sourceMigration.Source) (err error)

Update implements _sourceMigration.SourceRepo

type TargetRepoWithSlog 

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

TargetRepoWithSlog implements _sourceMigration.TargetRepo that is instrumented with slog logger

func NewTargetRepoWithSlog 

func NewTargetRepoWithSlog(base _sourceMigration.TargetRepo, log *slog.Logger) TargetRepoWithSlog

NewTargetRepoWithSlog instruments an implementation of the _sourceMigration.TargetRepo with simple logging

func (TargetRepoWithSlog) Create 

func (_d TargetRepoWithSlog) Create(ctx context.Context, target _sourceMigration.Target) (i1 int64, err error)

Create implements _sourceMigration.TargetRepo

func (TargetRepoWithSlog) DeleteByName 

func (_d TargetRepoWithSlog) DeleteByName(ctx context.Context, name string) (err error)

DeleteByName implements _sourceMigration.TargetRepo

func (TargetRepoWithSlog) GetAll 

func (_d TargetRepoWithSlog) GetAll(ctx context.Context) (t1 _sourceMigration.Targets, err error)

GetAll implements _sourceMigration.TargetRepo

func (TargetRepoWithSlog) GetAllNames 

func (_d TargetRepoWithSlog) GetAllNames(ctx context.Context) (sa1 []string, err error)

GetAllNames implements _sourceMigration.TargetRepo

func (TargetRepoWithSlog) GetByName 

func (_d TargetRepoWithSlog) GetByName(ctx context.Context, name string) (tp1 *_sourceMigration.Target, err error)

GetByName implements _sourceMigration.TargetRepo

func (TargetRepoWithSlog) Rename 

func (_d TargetRepoWithSlog) Rename(ctx context.Context, oldName string, newName string) (err error)

Rename implements _sourceMigration.TargetRepo

func (TargetRepoWithSlog) Update 

func (_d TargetRepoWithSlog) Update(ctx context.Context, name string, target _sourceMigration.Target) (err error)

Update implements _sourceMigration.TargetRepo

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.