middleware

package
v0.0.0-pre.3 Latest Latest
Warning

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

 Go to latest Published: Apr 11, 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) 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) Rename 

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

Rename 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) CreateOverrides 

func (_d InstanceRepoWithSlog) CreateOverrides(ctx context.Context, overrides _sourceMigration.InstanceOverride) (i1 int64, err error)

CreateOverrides implements _sourceMigration.InstanceRepo

func (InstanceRepoWithSlog) DeleteByUUID 

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

DeleteByUUID implements _sourceMigration.InstanceRepo

func (InstanceRepoWithSlog) DeleteOverridesByUUID 

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

DeleteOverridesByUUID implements _sourceMigration.InstanceRepo

func (InstanceRepoWithSlog) GetAll 

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

GetAll 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) GetAllByBatchAndState 

func (_d InstanceRepoWithSlog) GetAllByBatchAndState(ctx context.Context, batch string, status api.MigrationStatusType) (i1 _sourceMigration.Instances, err error)

GetAllByBatchAndState 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) GetAllByState 

func (_d InstanceRepoWithSlog) GetAllByState(ctx context.Context, status ...api.MigrationStatusType) (i1 _sourceMigration.Instances, err error)

GetAllByState implements _sourceMigration.InstanceRepo

func (InstanceRepoWithSlog) GetAllUUIDs 

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

GetAllUUIDs implements _sourceMigration.InstanceRepo

func (InstanceRepoWithSlog) GetAllUnassigned 

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

GetAllUnassigned 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) GetOverridesByUUID 

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

GetOverridesByUUID implements _sourceMigration.InstanceRepo

func (InstanceRepoWithSlog) Update 

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

Update implements _sourceMigration.InstanceRepo

func (InstanceRepoWithSlog) UpdateOverrides 

func (_d InstanceRepoWithSlog) UpdateOverrides(ctx context.Context, overrides _sourceMigration.InstanceOverride) (err error)

UpdateOverrides 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) DeleteByName 

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

DeleteByName implements _sourceMigration.NetworkRepo

func (NetworkRepoWithSlog) GetAll 

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

GetAll implements _sourceMigration.NetworkRepo

func (NetworkRepoWithSlog) GetAllNames 

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

GetAllNames implements _sourceMigration.NetworkRepo

func (NetworkRepoWithSlog) GetByName 

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

GetByName implements _sourceMigration.NetworkRepo

func (NetworkRepoWithSlog) Rename 

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

Rename implements _sourceMigration.NetworkRepo

func (NetworkRepoWithSlog) Update 

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

Update implements _sourceMigration.NetworkRepo

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) (s1 _sourceMigration.Sources, err error)

GetAll implements _sourceMigration.SourceRepo

func (SourceRepoWithSlog) GetAllNames 

func (_d SourceRepoWithSlog) GetAllNames(ctx context.Context) (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.