middleware

package
v0.0.0-...-725261d Latest Latest
Warning

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

 Go to latest Published: Sep 29, 2025 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ImageRepoWithPrometheus 

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

ImageRepoWithPrometheus implements inventory.ImageRepo interface with all methods wrapped with Prometheus metrics.

func NewImageRepoWithPrometheus 

func NewImageRepoWithPrometheus(base inventory.ImageRepo, instanceName string) ImageRepoWithPrometheus

NewImageRepoWithPrometheus returns an instance of the inventory.ImageRepo decorated with prometheus summary metric.

func (ImageRepoWithPrometheus) Create 

func (_d ImageRepoWithPrometheus) Create(ctx context.Context, image inventory.Image) (image1 inventory.Image, err error)

Create implements inventory.ImageRepo.

func (ImageRepoWithPrometheus) DeleteByClusterName 

func (_d ImageRepoWithPrometheus) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.ImageRepo.

func (ImageRepoWithPrometheus) DeleteByUUID 

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

DeleteByUUID implements inventory.ImageRepo.

func (ImageRepoWithPrometheus) GetAllUUIDsWithFilter 

func (_d ImageRepoWithPrometheus) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.ImageFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.ImageRepo.

func (ImageRepoWithPrometheus) GetAllWithFilter 

func (_d ImageRepoWithPrometheus) GetAllWithFilter(ctx context.Context, filter inventory.ImageFilter) (images inventory.Images, err error)

GetAllWithFilter implements inventory.ImageRepo.

func (ImageRepoWithPrometheus) GetByUUID 

func (_d ImageRepoWithPrometheus) GetByUUID(ctx context.Context, id uuid.UUID) (image inventory.Image, err error)

GetByUUID implements inventory.ImageRepo.

func (ImageRepoWithPrometheus) UpdateByUUID 

func (_d ImageRepoWithPrometheus) UpdateByUUID(ctx context.Context, image inventory.Image) (image1 inventory.Image, err error)

UpdateByUUID implements inventory.ImageRepo.

type ImageRepoWithSlog 

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

ImageRepoWithSlog implements inventory.ImageRepo that is instrumented with slog logger.

func NewImageRepoWithSlog 

func NewImageRepoWithSlog(base inventory.ImageRepo, log *slog.Logger, opts ...ImageRepoWithSlogOption) ImageRepoWithSlog

NewImageRepoWithSlog instruments an implementation of the inventory.ImageRepo with simple logging.

func (ImageRepoWithSlog) Create 

func (_d ImageRepoWithSlog) Create(ctx context.Context, image inventory.Image) (image1 inventory.Image, err error)

Create implements inventory.ImageRepo.

func (ImageRepoWithSlog) DeleteByClusterName 

func (_d ImageRepoWithSlog) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.ImageRepo.

func (ImageRepoWithSlog) DeleteByUUID 

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

DeleteByUUID implements inventory.ImageRepo.

func (ImageRepoWithSlog) GetAllUUIDsWithFilter 

func (_d ImageRepoWithSlog) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.ImageFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.ImageRepo.

func (ImageRepoWithSlog) GetAllWithFilter 

func (_d ImageRepoWithSlog) GetAllWithFilter(ctx context.Context, filter inventory.ImageFilter) (images inventory.Images, err error)

GetAllWithFilter implements inventory.ImageRepo.

func (ImageRepoWithSlog) GetByUUID 

func (_d ImageRepoWithSlog) GetByUUID(ctx context.Context, id uuid.UUID) (image inventory.Image, err error)

GetByUUID implements inventory.ImageRepo.

func (ImageRepoWithSlog) UpdateByUUID 

func (_d ImageRepoWithSlog) UpdateByUUID(ctx context.Context, image inventory.Image) (image1 inventory.Image, err error)

UpdateByUUID implements inventory.ImageRepo.

type ImageRepoWithSlogOption 

type ImageRepoWithSlogOption func(s *ImageRepoWithSlog)

func ImageRepoWithSlogWithInformativeErrFunc 

func ImageRepoWithSlogWithInformativeErrFunc(isInformativeErrFunc func(error) bool) ImageRepoWithSlogOption

type InstanceRepoWithPrometheus 

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

InstanceRepoWithPrometheus implements inventory.InstanceRepo interface with all methods wrapped with Prometheus metrics.

func NewInstanceRepoWithPrometheus 

func NewInstanceRepoWithPrometheus(base inventory.InstanceRepo, instanceName string) InstanceRepoWithPrometheus

NewInstanceRepoWithPrometheus returns an instance of the inventory.InstanceRepo decorated with prometheus summary metric.

func (InstanceRepoWithPrometheus) Create 

func (_d InstanceRepoWithPrometheus) Create(ctx context.Context, instance inventory.Instance) (instance1 inventory.Instance, err error)

Create implements inventory.InstanceRepo.

func (InstanceRepoWithPrometheus) DeleteByClusterName 

func (_d InstanceRepoWithPrometheus) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.InstanceRepo.

func (InstanceRepoWithPrometheus) DeleteByUUID 

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

DeleteByUUID implements inventory.InstanceRepo.

func (InstanceRepoWithPrometheus) GetAllUUIDsWithFilter 

func (_d InstanceRepoWithPrometheus) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.InstanceFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.InstanceRepo.

func (InstanceRepoWithPrometheus) GetAllWithFilter 

func (_d InstanceRepoWithPrometheus) GetAllWithFilter(ctx context.Context, filter inventory.InstanceFilter) (instances inventory.Instances, err error)

GetAllWithFilter implements inventory.InstanceRepo.

func (InstanceRepoWithPrometheus) GetByUUID 

func (_d InstanceRepoWithPrometheus) GetByUUID(ctx context.Context, id uuid.UUID) (instance inventory.Instance, err error)

GetByUUID implements inventory.InstanceRepo.

func (InstanceRepoWithPrometheus) UpdateByUUID 

func (_d InstanceRepoWithPrometheus) UpdateByUUID(ctx context.Context, instance inventory.Instance) (instance1 inventory.Instance, err error)

UpdateByUUID implements inventory.InstanceRepo.

type InstanceRepoWithSlog 

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

InstanceRepoWithSlog implements inventory.InstanceRepo that is instrumented with slog logger.

func NewInstanceRepoWithSlog 

func NewInstanceRepoWithSlog(base inventory.InstanceRepo, log *slog.Logger, opts ...InstanceRepoWithSlogOption) InstanceRepoWithSlog

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

func (InstanceRepoWithSlog) Create 

func (_d InstanceRepoWithSlog) Create(ctx context.Context, instance inventory.Instance) (instance1 inventory.Instance, err error)

Create implements inventory.InstanceRepo.

func (InstanceRepoWithSlog) DeleteByClusterName 

func (_d InstanceRepoWithSlog) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.InstanceRepo.

func (InstanceRepoWithSlog) DeleteByUUID 

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

DeleteByUUID implements inventory.InstanceRepo.

func (InstanceRepoWithSlog) GetAllUUIDsWithFilter 

func (_d InstanceRepoWithSlog) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.InstanceFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.InstanceRepo.

func (InstanceRepoWithSlog) GetAllWithFilter 

func (_d InstanceRepoWithSlog) GetAllWithFilter(ctx context.Context, filter inventory.InstanceFilter) (instances inventory.Instances, err error)

GetAllWithFilter implements inventory.InstanceRepo.

func (InstanceRepoWithSlog) GetByUUID 

func (_d InstanceRepoWithSlog) GetByUUID(ctx context.Context, id uuid.UUID) (instance inventory.Instance, err error)

GetByUUID implements inventory.InstanceRepo.

func (InstanceRepoWithSlog) UpdateByUUID 

func (_d InstanceRepoWithSlog) UpdateByUUID(ctx context.Context, instance inventory.Instance) (instance1 inventory.Instance, err error)

UpdateByUUID implements inventory.InstanceRepo.

type InstanceRepoWithSlogOption 

type InstanceRepoWithSlogOption func(s *InstanceRepoWithSlog)

func InstanceRepoWithSlogWithInformativeErrFunc 

func InstanceRepoWithSlogWithInformativeErrFunc(isInformativeErrFunc func(error) bool) InstanceRepoWithSlogOption

type InventoryAggregateRepoWithPrometheus 

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

InventoryAggregateRepoWithPrometheus implements inventory.InventoryAggregateRepo interface with all methods wrapped with Prometheus metrics.

func NewInventoryAggregateRepoWithPrometheus 

func NewInventoryAggregateRepoWithPrometheus(base inventory.InventoryAggregateRepo, instanceName string) InventoryAggregateRepoWithPrometheus

NewInventoryAggregateRepoWithPrometheus returns an instance of the inventory.InventoryAggregateRepo decorated with prometheus summary metric.

func (InventoryAggregateRepoWithPrometheus) GetAllWithFilter 

func (_d InventoryAggregateRepoWithPrometheus) GetAllWithFilter(ctx context.Context, filter inventory.InventoryAggregateFilter) (inventoryAggregates inventory.InventoryAggregates, err error)

GetAllWithFilter implements inventory.InventoryAggregateRepo.

type InventoryAggregateRepoWithSlog 

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

InventoryAggregateRepoWithSlog implements inventory.InventoryAggregateRepo that is instrumented with slog logger.

func NewInventoryAggregateRepoWithSlog 

func NewInventoryAggregateRepoWithSlog(base inventory.InventoryAggregateRepo, log *slog.Logger, opts ...InventoryAggregateRepoWithSlogOption) InventoryAggregateRepoWithSlog

NewInventoryAggregateRepoWithSlog instruments an implementation of the inventory.InventoryAggregateRepo with simple logging.

func (InventoryAggregateRepoWithSlog) GetAllWithFilter 

func (_d InventoryAggregateRepoWithSlog) GetAllWithFilter(ctx context.Context, filter inventory.InventoryAggregateFilter) (inventoryAggregates inventory.InventoryAggregates, err error)

GetAllWithFilter implements inventory.InventoryAggregateRepo.

type InventoryAggregateRepoWithSlogOption 

type InventoryAggregateRepoWithSlogOption func(s *InventoryAggregateRepoWithSlog)

func InventoryAggregateRepoWithSlogWithInformativeErrFunc 

func InventoryAggregateRepoWithSlogWithInformativeErrFunc(isInformativeErrFunc func(error) bool) InventoryAggregateRepoWithSlogOption

type NetworkACLRepoWithPrometheus 

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

NetworkACLRepoWithPrometheus implements inventory.NetworkACLRepo interface with all methods wrapped with Prometheus metrics.

func NewNetworkACLRepoWithPrometheus 

func NewNetworkACLRepoWithPrometheus(base inventory.NetworkACLRepo, instanceName string) NetworkACLRepoWithPrometheus

NewNetworkACLRepoWithPrometheus returns an instance of the inventory.NetworkACLRepo decorated with prometheus summary metric.

func (NetworkACLRepoWithPrometheus) Create 

func (_d NetworkACLRepoWithPrometheus) Create(ctx context.Context, networkACL inventory.NetworkACL) (networkACL1 inventory.NetworkACL, err error)

Create implements inventory.NetworkACLRepo.

func (NetworkACLRepoWithPrometheus) DeleteByClusterName 

func (_d NetworkACLRepoWithPrometheus) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.NetworkACLRepo.

func (NetworkACLRepoWithPrometheus) DeleteByUUID 

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

DeleteByUUID implements inventory.NetworkACLRepo.

func (NetworkACLRepoWithPrometheus) GetAllUUIDsWithFilter 

func (_d NetworkACLRepoWithPrometheus) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.NetworkACLFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.NetworkACLRepo.

func (NetworkACLRepoWithPrometheus) GetAllWithFilter 

func (_d NetworkACLRepoWithPrometheus) GetAllWithFilter(ctx context.Context, filter inventory.NetworkACLFilter) (networkACLs inventory.NetworkACLs, err error)

GetAllWithFilter implements inventory.NetworkACLRepo.

func (NetworkACLRepoWithPrometheus) GetByUUID 

func (_d NetworkACLRepoWithPrometheus) GetByUUID(ctx context.Context, id uuid.UUID) (networkACL inventory.NetworkACL, err error)

GetByUUID implements inventory.NetworkACLRepo.

func (NetworkACLRepoWithPrometheus) UpdateByUUID 

func (_d NetworkACLRepoWithPrometheus) UpdateByUUID(ctx context.Context, networkACL inventory.NetworkACL) (networkACL1 inventory.NetworkACL, err error)

UpdateByUUID implements inventory.NetworkACLRepo.

type NetworkACLRepoWithSlog 

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

NetworkACLRepoWithSlog implements inventory.NetworkACLRepo that is instrumented with slog logger.

func NewNetworkACLRepoWithSlog 

func NewNetworkACLRepoWithSlog(base inventory.NetworkACLRepo, log *slog.Logger, opts ...NetworkACLRepoWithSlogOption) NetworkACLRepoWithSlog

NewNetworkACLRepoWithSlog instruments an implementation of the inventory.NetworkACLRepo with simple logging.

func (NetworkACLRepoWithSlog) Create 

func (_d NetworkACLRepoWithSlog) Create(ctx context.Context, networkACL inventory.NetworkACL) (networkACL1 inventory.NetworkACL, err error)

Create implements inventory.NetworkACLRepo.

func (NetworkACLRepoWithSlog) DeleteByClusterName 

func (_d NetworkACLRepoWithSlog) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.NetworkACLRepo.

func (NetworkACLRepoWithSlog) DeleteByUUID 

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

DeleteByUUID implements inventory.NetworkACLRepo.

func (NetworkACLRepoWithSlog) GetAllUUIDsWithFilter 

func (_d NetworkACLRepoWithSlog) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.NetworkACLFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.NetworkACLRepo.

func (NetworkACLRepoWithSlog) GetAllWithFilter 

func (_d NetworkACLRepoWithSlog) GetAllWithFilter(ctx context.Context, filter inventory.NetworkACLFilter) (networkACLs inventory.NetworkACLs, err error)

GetAllWithFilter implements inventory.NetworkACLRepo.

func (NetworkACLRepoWithSlog) GetByUUID 

func (_d NetworkACLRepoWithSlog) GetByUUID(ctx context.Context, id uuid.UUID) (networkACL inventory.NetworkACL, err error)

GetByUUID implements inventory.NetworkACLRepo.

func (NetworkACLRepoWithSlog) UpdateByUUID 

func (_d NetworkACLRepoWithSlog) UpdateByUUID(ctx context.Context, networkACL inventory.NetworkACL) (networkACL1 inventory.NetworkACL, err error)

UpdateByUUID implements inventory.NetworkACLRepo.

type NetworkACLRepoWithSlogOption 

type NetworkACLRepoWithSlogOption func(s *NetworkACLRepoWithSlog)

func NetworkACLRepoWithSlogWithInformativeErrFunc 

func NetworkACLRepoWithSlogWithInformativeErrFunc(isInformativeErrFunc func(error) bool) NetworkACLRepoWithSlogOption

type NetworkAddressSetRepoWithPrometheus 

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

NetworkAddressSetRepoWithPrometheus implements inventory.NetworkAddressSetRepo interface with all methods wrapped with Prometheus metrics.

func NewNetworkAddressSetRepoWithPrometheus 

func NewNetworkAddressSetRepoWithPrometheus(base inventory.NetworkAddressSetRepo, instanceName string) NetworkAddressSetRepoWithPrometheus

NewNetworkAddressSetRepoWithPrometheus returns an instance of the inventory.NetworkAddressSetRepo decorated with prometheus summary metric.

func (NetworkAddressSetRepoWithPrometheus) Create 

func (_d NetworkAddressSetRepoWithPrometheus) Create(ctx context.Context, networkAddressSet inventory.NetworkAddressSet) (networkAddressSet1 inventory.NetworkAddressSet, err error)

Create implements inventory.NetworkAddressSetRepo.

func (NetworkAddressSetRepoWithPrometheus) DeleteByClusterName 

func (_d NetworkAddressSetRepoWithPrometheus) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.NetworkAddressSetRepo.

func (NetworkAddressSetRepoWithPrometheus) DeleteByUUID 

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

DeleteByUUID implements inventory.NetworkAddressSetRepo.

func (NetworkAddressSetRepoWithPrometheus) GetAllUUIDsWithFilter 

func (_d NetworkAddressSetRepoWithPrometheus) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.NetworkAddressSetFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.NetworkAddressSetRepo.

func (NetworkAddressSetRepoWithPrometheus) GetAllWithFilter 

func (_d NetworkAddressSetRepoWithPrometheus) GetAllWithFilter(ctx context.Context, filter inventory.NetworkAddressSetFilter) (networkAddressSets inventory.NetworkAddressSets, err error)

GetAllWithFilter implements inventory.NetworkAddressSetRepo.

func (NetworkAddressSetRepoWithPrometheus) GetByUUID 

func (_d NetworkAddressSetRepoWithPrometheus) GetByUUID(ctx context.Context, id uuid.UUID) (networkAddressSet inventory.NetworkAddressSet, err error)

GetByUUID implements inventory.NetworkAddressSetRepo.

func (NetworkAddressSetRepoWithPrometheus) UpdateByUUID 

func (_d NetworkAddressSetRepoWithPrometheus) UpdateByUUID(ctx context.Context, networkAddressSet inventory.NetworkAddressSet) (networkAddressSet1 inventory.NetworkAddressSet, err error)

UpdateByUUID implements inventory.NetworkAddressSetRepo.

type NetworkAddressSetRepoWithSlog 

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

NetworkAddressSetRepoWithSlog implements inventory.NetworkAddressSetRepo that is instrumented with slog logger.

func NewNetworkAddressSetRepoWithSlog 

func NewNetworkAddressSetRepoWithSlog(base inventory.NetworkAddressSetRepo, log *slog.Logger, opts ...NetworkAddressSetRepoWithSlogOption) NetworkAddressSetRepoWithSlog

NewNetworkAddressSetRepoWithSlog instruments an implementation of the inventory.NetworkAddressSetRepo with simple logging.

func (NetworkAddressSetRepoWithSlog) Create 

func (_d NetworkAddressSetRepoWithSlog) Create(ctx context.Context, networkAddressSet inventory.NetworkAddressSet) (networkAddressSet1 inventory.NetworkAddressSet, err error)

Create implements inventory.NetworkAddressSetRepo.

func (NetworkAddressSetRepoWithSlog) DeleteByClusterName 

func (_d NetworkAddressSetRepoWithSlog) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.NetworkAddressSetRepo.

func (NetworkAddressSetRepoWithSlog) DeleteByUUID 

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

DeleteByUUID implements inventory.NetworkAddressSetRepo.

func (NetworkAddressSetRepoWithSlog) GetAllUUIDsWithFilter 

func (_d NetworkAddressSetRepoWithSlog) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.NetworkAddressSetFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.NetworkAddressSetRepo.

func (NetworkAddressSetRepoWithSlog) GetAllWithFilter 

func (_d NetworkAddressSetRepoWithSlog) GetAllWithFilter(ctx context.Context, filter inventory.NetworkAddressSetFilter) (networkAddressSets inventory.NetworkAddressSets, err error)

GetAllWithFilter implements inventory.NetworkAddressSetRepo.

func (NetworkAddressSetRepoWithSlog) GetByUUID 

func (_d NetworkAddressSetRepoWithSlog) GetByUUID(ctx context.Context, id uuid.UUID) (networkAddressSet inventory.NetworkAddressSet, err error)

GetByUUID implements inventory.NetworkAddressSetRepo.

func (NetworkAddressSetRepoWithSlog) UpdateByUUID 

func (_d NetworkAddressSetRepoWithSlog) UpdateByUUID(ctx context.Context, networkAddressSet inventory.NetworkAddressSet) (networkAddressSet1 inventory.NetworkAddressSet, err error)

UpdateByUUID implements inventory.NetworkAddressSetRepo.

type NetworkAddressSetRepoWithSlogOption 

type NetworkAddressSetRepoWithSlogOption func(s *NetworkAddressSetRepoWithSlog)

func NetworkAddressSetRepoWithSlogWithInformativeErrFunc 

func NetworkAddressSetRepoWithSlogWithInformativeErrFunc(isInformativeErrFunc func(error) bool) NetworkAddressSetRepoWithSlogOption

type NetworkForwardRepoWithPrometheus 

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

NetworkForwardRepoWithPrometheus implements inventory.NetworkForwardRepo interface with all methods wrapped with Prometheus metrics.

func NewNetworkForwardRepoWithPrometheus 

func NewNetworkForwardRepoWithPrometheus(base inventory.NetworkForwardRepo, instanceName string) NetworkForwardRepoWithPrometheus

NewNetworkForwardRepoWithPrometheus returns an instance of the inventory.NetworkForwardRepo decorated with prometheus summary metric.

func (NetworkForwardRepoWithPrometheus) Create 

func (_d NetworkForwardRepoWithPrometheus) Create(ctx context.Context, networkForward inventory.NetworkForward) (networkForward1 inventory.NetworkForward, err error)

Create implements inventory.NetworkForwardRepo.

func (NetworkForwardRepoWithPrometheus) DeleteByClusterName 

func (_d NetworkForwardRepoWithPrometheus) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.NetworkForwardRepo.

func (NetworkForwardRepoWithPrometheus) DeleteByUUID 

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

DeleteByUUID implements inventory.NetworkForwardRepo.

func (NetworkForwardRepoWithPrometheus) GetAllUUIDsWithFilter 

func (_d NetworkForwardRepoWithPrometheus) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.NetworkForwardFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.NetworkForwardRepo.

func (NetworkForwardRepoWithPrometheus) GetAllWithFilter 

func (_d NetworkForwardRepoWithPrometheus) GetAllWithFilter(ctx context.Context, filter inventory.NetworkForwardFilter) (networkForwards inventory.NetworkForwards, err error)

GetAllWithFilter implements inventory.NetworkForwardRepo.

func (NetworkForwardRepoWithPrometheus) GetByUUID 

func (_d NetworkForwardRepoWithPrometheus) GetByUUID(ctx context.Context, id uuid.UUID) (networkForward inventory.NetworkForward, err error)

GetByUUID implements inventory.NetworkForwardRepo.

func (NetworkForwardRepoWithPrometheus) UpdateByUUID 

func (_d NetworkForwardRepoWithPrometheus) UpdateByUUID(ctx context.Context, networkForward inventory.NetworkForward) (networkForward1 inventory.NetworkForward, err error)

UpdateByUUID implements inventory.NetworkForwardRepo.

type NetworkForwardRepoWithSlog 

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

NetworkForwardRepoWithSlog implements inventory.NetworkForwardRepo that is instrumented with slog logger.

func NewNetworkForwardRepoWithSlog 

func NewNetworkForwardRepoWithSlog(base inventory.NetworkForwardRepo, log *slog.Logger, opts ...NetworkForwardRepoWithSlogOption) NetworkForwardRepoWithSlog

NewNetworkForwardRepoWithSlog instruments an implementation of the inventory.NetworkForwardRepo with simple logging.

func (NetworkForwardRepoWithSlog) Create 

func (_d NetworkForwardRepoWithSlog) Create(ctx context.Context, networkForward inventory.NetworkForward) (networkForward1 inventory.NetworkForward, err error)

Create implements inventory.NetworkForwardRepo.

func (NetworkForwardRepoWithSlog) DeleteByClusterName 

func (_d NetworkForwardRepoWithSlog) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.NetworkForwardRepo.

func (NetworkForwardRepoWithSlog) DeleteByUUID 

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

DeleteByUUID implements inventory.NetworkForwardRepo.

func (NetworkForwardRepoWithSlog) GetAllUUIDsWithFilter 

func (_d NetworkForwardRepoWithSlog) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.NetworkForwardFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.NetworkForwardRepo.

func (NetworkForwardRepoWithSlog) GetAllWithFilter 

func (_d NetworkForwardRepoWithSlog) GetAllWithFilter(ctx context.Context, filter inventory.NetworkForwardFilter) (networkForwards inventory.NetworkForwards, err error)

GetAllWithFilter implements inventory.NetworkForwardRepo.

func (NetworkForwardRepoWithSlog) GetByUUID 

func (_d NetworkForwardRepoWithSlog) GetByUUID(ctx context.Context, id uuid.UUID) (networkForward inventory.NetworkForward, err error)

GetByUUID implements inventory.NetworkForwardRepo.

func (NetworkForwardRepoWithSlog) UpdateByUUID 

func (_d NetworkForwardRepoWithSlog) UpdateByUUID(ctx context.Context, networkForward inventory.NetworkForward) (networkForward1 inventory.NetworkForward, err error)

UpdateByUUID implements inventory.NetworkForwardRepo.

type NetworkForwardRepoWithSlogOption 

type NetworkForwardRepoWithSlogOption func(s *NetworkForwardRepoWithSlog)

func NetworkForwardRepoWithSlogWithInformativeErrFunc 

func NetworkForwardRepoWithSlogWithInformativeErrFunc(isInformativeErrFunc func(error) bool) NetworkForwardRepoWithSlogOption

type NetworkIntegrationRepoWithPrometheus 

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

NetworkIntegrationRepoWithPrometheus implements inventory.NetworkIntegrationRepo interface with all methods wrapped with Prometheus metrics.

func NewNetworkIntegrationRepoWithPrometheus 

func NewNetworkIntegrationRepoWithPrometheus(base inventory.NetworkIntegrationRepo, instanceName string) NetworkIntegrationRepoWithPrometheus

NewNetworkIntegrationRepoWithPrometheus returns an instance of the inventory.NetworkIntegrationRepo decorated with prometheus summary metric.

func (NetworkIntegrationRepoWithPrometheus) Create 

func (_d NetworkIntegrationRepoWithPrometheus) Create(ctx context.Context, networkIntegration inventory.NetworkIntegration) (networkIntegration1 inventory.NetworkIntegration, err error)

Create implements inventory.NetworkIntegrationRepo.

func (NetworkIntegrationRepoWithPrometheus) DeleteByClusterName 

func (_d NetworkIntegrationRepoWithPrometheus) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.NetworkIntegrationRepo.

func (NetworkIntegrationRepoWithPrometheus) DeleteByUUID 

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

DeleteByUUID implements inventory.NetworkIntegrationRepo.

func (NetworkIntegrationRepoWithPrometheus) GetAllUUIDsWithFilter 

func (_d NetworkIntegrationRepoWithPrometheus) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.NetworkIntegrationFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.NetworkIntegrationRepo.

func (NetworkIntegrationRepoWithPrometheus) GetAllWithFilter 

func (_d NetworkIntegrationRepoWithPrometheus) GetAllWithFilter(ctx context.Context, filter inventory.NetworkIntegrationFilter) (networkIntegrations inventory.NetworkIntegrations, err error)

GetAllWithFilter implements inventory.NetworkIntegrationRepo.

func (NetworkIntegrationRepoWithPrometheus) GetByUUID 

func (_d NetworkIntegrationRepoWithPrometheus) GetByUUID(ctx context.Context, id uuid.UUID) (networkIntegration inventory.NetworkIntegration, err error)

GetByUUID implements inventory.NetworkIntegrationRepo.

func (NetworkIntegrationRepoWithPrometheus) UpdateByUUID 

func (_d NetworkIntegrationRepoWithPrometheus) UpdateByUUID(ctx context.Context, networkIntegration inventory.NetworkIntegration) (networkIntegration1 inventory.NetworkIntegration, err error)

UpdateByUUID implements inventory.NetworkIntegrationRepo.

type NetworkIntegrationRepoWithSlog 

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

NetworkIntegrationRepoWithSlog implements inventory.NetworkIntegrationRepo that is instrumented with slog logger.

func NewNetworkIntegrationRepoWithSlog 

func NewNetworkIntegrationRepoWithSlog(base inventory.NetworkIntegrationRepo, log *slog.Logger, opts ...NetworkIntegrationRepoWithSlogOption) NetworkIntegrationRepoWithSlog

NewNetworkIntegrationRepoWithSlog instruments an implementation of the inventory.NetworkIntegrationRepo with simple logging.

func (NetworkIntegrationRepoWithSlog) Create 

func (_d NetworkIntegrationRepoWithSlog) Create(ctx context.Context, networkIntegration inventory.NetworkIntegration) (networkIntegration1 inventory.NetworkIntegration, err error)

Create implements inventory.NetworkIntegrationRepo.

func (NetworkIntegrationRepoWithSlog) DeleteByClusterName 

func (_d NetworkIntegrationRepoWithSlog) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.NetworkIntegrationRepo.

func (NetworkIntegrationRepoWithSlog) DeleteByUUID 

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

DeleteByUUID implements inventory.NetworkIntegrationRepo.

func (NetworkIntegrationRepoWithSlog) GetAllUUIDsWithFilter 

func (_d NetworkIntegrationRepoWithSlog) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.NetworkIntegrationFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.NetworkIntegrationRepo.

func (NetworkIntegrationRepoWithSlog) GetAllWithFilter 

func (_d NetworkIntegrationRepoWithSlog) GetAllWithFilter(ctx context.Context, filter inventory.NetworkIntegrationFilter) (networkIntegrations inventory.NetworkIntegrations, err error)

GetAllWithFilter implements inventory.NetworkIntegrationRepo.

func (NetworkIntegrationRepoWithSlog) GetByUUID 

func (_d NetworkIntegrationRepoWithSlog) GetByUUID(ctx context.Context, id uuid.UUID) (networkIntegration inventory.NetworkIntegration, err error)

GetByUUID implements inventory.NetworkIntegrationRepo.

func (NetworkIntegrationRepoWithSlog) UpdateByUUID 

func (_d NetworkIntegrationRepoWithSlog) UpdateByUUID(ctx context.Context, networkIntegration inventory.NetworkIntegration) (networkIntegration1 inventory.NetworkIntegration, err error)

UpdateByUUID implements inventory.NetworkIntegrationRepo.

type NetworkIntegrationRepoWithSlogOption 

type NetworkIntegrationRepoWithSlogOption func(s *NetworkIntegrationRepoWithSlog)

func NetworkIntegrationRepoWithSlogWithInformativeErrFunc 

func NetworkIntegrationRepoWithSlogWithInformativeErrFunc(isInformativeErrFunc func(error) bool) NetworkIntegrationRepoWithSlogOption

type NetworkLoadBalancerRepoWithPrometheus 

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

NetworkLoadBalancerRepoWithPrometheus implements inventory.NetworkLoadBalancerRepo interface with all methods wrapped with Prometheus metrics.

func NewNetworkLoadBalancerRepoWithPrometheus 

func NewNetworkLoadBalancerRepoWithPrometheus(base inventory.NetworkLoadBalancerRepo, instanceName string) NetworkLoadBalancerRepoWithPrometheus

NewNetworkLoadBalancerRepoWithPrometheus returns an instance of the inventory.NetworkLoadBalancerRepo decorated with prometheus summary metric.

func (NetworkLoadBalancerRepoWithPrometheus) Create 

func (_d NetworkLoadBalancerRepoWithPrometheus) Create(ctx context.Context, networkLoadBalancer inventory.NetworkLoadBalancer) (networkLoadBalancer1 inventory.NetworkLoadBalancer, err error)

Create implements inventory.NetworkLoadBalancerRepo.

func (NetworkLoadBalancerRepoWithPrometheus) DeleteByClusterName 

func (_d NetworkLoadBalancerRepoWithPrometheus) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.NetworkLoadBalancerRepo.

func (NetworkLoadBalancerRepoWithPrometheus) DeleteByUUID 

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

DeleteByUUID implements inventory.NetworkLoadBalancerRepo.

func (NetworkLoadBalancerRepoWithPrometheus) GetAllUUIDsWithFilter 

func (_d NetworkLoadBalancerRepoWithPrometheus) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.NetworkLoadBalancerFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.NetworkLoadBalancerRepo.

func (NetworkLoadBalancerRepoWithPrometheus) GetAllWithFilter 

func (_d NetworkLoadBalancerRepoWithPrometheus) GetAllWithFilter(ctx context.Context, filter inventory.NetworkLoadBalancerFilter) (networkLoadBalancers inventory.NetworkLoadBalancers, err error)

GetAllWithFilter implements inventory.NetworkLoadBalancerRepo.

func (NetworkLoadBalancerRepoWithPrometheus) GetByUUID 

func (_d NetworkLoadBalancerRepoWithPrometheus) GetByUUID(ctx context.Context, id uuid.UUID) (networkLoadBalancer inventory.NetworkLoadBalancer, err error)

GetByUUID implements inventory.NetworkLoadBalancerRepo.

func (NetworkLoadBalancerRepoWithPrometheus) UpdateByUUID 

func (_d NetworkLoadBalancerRepoWithPrometheus) UpdateByUUID(ctx context.Context, networkLoadBalancer inventory.NetworkLoadBalancer) (networkLoadBalancer1 inventory.NetworkLoadBalancer, err error)

UpdateByUUID implements inventory.NetworkLoadBalancerRepo.

type NetworkLoadBalancerRepoWithSlog 

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

NetworkLoadBalancerRepoWithSlog implements inventory.NetworkLoadBalancerRepo that is instrumented with slog logger.

func NewNetworkLoadBalancerRepoWithSlog 

func NewNetworkLoadBalancerRepoWithSlog(base inventory.NetworkLoadBalancerRepo, log *slog.Logger, opts ...NetworkLoadBalancerRepoWithSlogOption) NetworkLoadBalancerRepoWithSlog

NewNetworkLoadBalancerRepoWithSlog instruments an implementation of the inventory.NetworkLoadBalancerRepo with simple logging.

func (NetworkLoadBalancerRepoWithSlog) Create 

func (_d NetworkLoadBalancerRepoWithSlog) Create(ctx context.Context, networkLoadBalancer inventory.NetworkLoadBalancer) (networkLoadBalancer1 inventory.NetworkLoadBalancer, err error)

Create implements inventory.NetworkLoadBalancerRepo.

func (NetworkLoadBalancerRepoWithSlog) DeleteByClusterName 

func (_d NetworkLoadBalancerRepoWithSlog) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.NetworkLoadBalancerRepo.

func (NetworkLoadBalancerRepoWithSlog) DeleteByUUID 

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

DeleteByUUID implements inventory.NetworkLoadBalancerRepo.

func (NetworkLoadBalancerRepoWithSlog) GetAllUUIDsWithFilter 

func (_d NetworkLoadBalancerRepoWithSlog) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.NetworkLoadBalancerFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.NetworkLoadBalancerRepo.

func (NetworkLoadBalancerRepoWithSlog) GetAllWithFilter 

func (_d NetworkLoadBalancerRepoWithSlog) GetAllWithFilter(ctx context.Context, filter inventory.NetworkLoadBalancerFilter) (networkLoadBalancers inventory.NetworkLoadBalancers, err error)

GetAllWithFilter implements inventory.NetworkLoadBalancerRepo.

func (NetworkLoadBalancerRepoWithSlog) GetByUUID 

func (_d NetworkLoadBalancerRepoWithSlog) GetByUUID(ctx context.Context, id uuid.UUID) (networkLoadBalancer inventory.NetworkLoadBalancer, err error)

GetByUUID implements inventory.NetworkLoadBalancerRepo.

func (NetworkLoadBalancerRepoWithSlog) UpdateByUUID 

func (_d NetworkLoadBalancerRepoWithSlog) UpdateByUUID(ctx context.Context, networkLoadBalancer inventory.NetworkLoadBalancer) (networkLoadBalancer1 inventory.NetworkLoadBalancer, err error)

UpdateByUUID implements inventory.NetworkLoadBalancerRepo.

type NetworkLoadBalancerRepoWithSlogOption 

type NetworkLoadBalancerRepoWithSlogOption func(s *NetworkLoadBalancerRepoWithSlog)

func NetworkLoadBalancerRepoWithSlogWithInformativeErrFunc 

func NetworkLoadBalancerRepoWithSlogWithInformativeErrFunc(isInformativeErrFunc func(error) bool) NetworkLoadBalancerRepoWithSlogOption

type NetworkPeerRepoWithPrometheus 

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

NetworkPeerRepoWithPrometheus implements inventory.NetworkPeerRepo interface with all methods wrapped with Prometheus metrics.

func NewNetworkPeerRepoWithPrometheus 

func NewNetworkPeerRepoWithPrometheus(base inventory.NetworkPeerRepo, instanceName string) NetworkPeerRepoWithPrometheus

NewNetworkPeerRepoWithPrometheus returns an instance of the inventory.NetworkPeerRepo decorated with prometheus summary metric.

func (NetworkPeerRepoWithPrometheus) Create 

func (_d NetworkPeerRepoWithPrometheus) Create(ctx context.Context, networkPeer inventory.NetworkPeer) (networkPeer1 inventory.NetworkPeer, err error)

Create implements inventory.NetworkPeerRepo.

func (NetworkPeerRepoWithPrometheus) DeleteByClusterName 

func (_d NetworkPeerRepoWithPrometheus) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.NetworkPeerRepo.

func (NetworkPeerRepoWithPrometheus) DeleteByUUID 

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

DeleteByUUID implements inventory.NetworkPeerRepo.

func (NetworkPeerRepoWithPrometheus) GetAllUUIDsWithFilter 

func (_d NetworkPeerRepoWithPrometheus) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.NetworkPeerFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.NetworkPeerRepo.

func (NetworkPeerRepoWithPrometheus) GetAllWithFilter 

func (_d NetworkPeerRepoWithPrometheus) GetAllWithFilter(ctx context.Context, filter inventory.NetworkPeerFilter) (networkPeers inventory.NetworkPeers, err error)

GetAllWithFilter implements inventory.NetworkPeerRepo.

func (NetworkPeerRepoWithPrometheus) GetByUUID 

func (_d NetworkPeerRepoWithPrometheus) GetByUUID(ctx context.Context, id uuid.UUID) (networkPeer inventory.NetworkPeer, err error)

GetByUUID implements inventory.NetworkPeerRepo.

func (NetworkPeerRepoWithPrometheus) UpdateByUUID 

func (_d NetworkPeerRepoWithPrometheus) UpdateByUUID(ctx context.Context, networkPeer inventory.NetworkPeer) (networkPeer1 inventory.NetworkPeer, err error)

UpdateByUUID implements inventory.NetworkPeerRepo.

type NetworkPeerRepoWithSlog 

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

NetworkPeerRepoWithSlog implements inventory.NetworkPeerRepo that is instrumented with slog logger.

func NewNetworkPeerRepoWithSlog 

func NewNetworkPeerRepoWithSlog(base inventory.NetworkPeerRepo, log *slog.Logger, opts ...NetworkPeerRepoWithSlogOption) NetworkPeerRepoWithSlog

NewNetworkPeerRepoWithSlog instruments an implementation of the inventory.NetworkPeerRepo with simple logging.

func (NetworkPeerRepoWithSlog) Create 

func (_d NetworkPeerRepoWithSlog) Create(ctx context.Context, networkPeer inventory.NetworkPeer) (networkPeer1 inventory.NetworkPeer, err error)

Create implements inventory.NetworkPeerRepo.

func (NetworkPeerRepoWithSlog) DeleteByClusterName 

func (_d NetworkPeerRepoWithSlog) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.NetworkPeerRepo.

func (NetworkPeerRepoWithSlog) DeleteByUUID 

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

DeleteByUUID implements inventory.NetworkPeerRepo.

func (NetworkPeerRepoWithSlog) GetAllUUIDsWithFilter 

func (_d NetworkPeerRepoWithSlog) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.NetworkPeerFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.NetworkPeerRepo.

func (NetworkPeerRepoWithSlog) GetAllWithFilter 

func (_d NetworkPeerRepoWithSlog) GetAllWithFilter(ctx context.Context, filter inventory.NetworkPeerFilter) (networkPeers inventory.NetworkPeers, err error)

GetAllWithFilter implements inventory.NetworkPeerRepo.

func (NetworkPeerRepoWithSlog) GetByUUID 

func (_d NetworkPeerRepoWithSlog) GetByUUID(ctx context.Context, id uuid.UUID) (networkPeer inventory.NetworkPeer, err error)

GetByUUID implements inventory.NetworkPeerRepo.

func (NetworkPeerRepoWithSlog) UpdateByUUID 

func (_d NetworkPeerRepoWithSlog) UpdateByUUID(ctx context.Context, networkPeer inventory.NetworkPeer) (networkPeer1 inventory.NetworkPeer, err error)

UpdateByUUID implements inventory.NetworkPeerRepo.

type NetworkPeerRepoWithSlogOption 

type NetworkPeerRepoWithSlogOption func(s *NetworkPeerRepoWithSlog)

func NetworkPeerRepoWithSlogWithInformativeErrFunc 

func NetworkPeerRepoWithSlogWithInformativeErrFunc(isInformativeErrFunc func(error) bool) NetworkPeerRepoWithSlogOption

type NetworkRepoWithPrometheus 

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

NetworkRepoWithPrometheus implements inventory.NetworkRepo interface with all methods wrapped with Prometheus metrics.

func NewNetworkRepoWithPrometheus 

func NewNetworkRepoWithPrometheus(base inventory.NetworkRepo, instanceName string) NetworkRepoWithPrometheus

NewNetworkRepoWithPrometheus returns an instance of the inventory.NetworkRepo decorated with prometheus summary metric.

func (NetworkRepoWithPrometheus) Create 

func (_d NetworkRepoWithPrometheus) Create(ctx context.Context, network inventory.Network) (network1 inventory.Network, err error)

Create implements inventory.NetworkRepo.

func (NetworkRepoWithPrometheus) DeleteByClusterName 

func (_d NetworkRepoWithPrometheus) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.NetworkRepo.

func (NetworkRepoWithPrometheus) DeleteByUUID 

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

DeleteByUUID implements inventory.NetworkRepo.

func (NetworkRepoWithPrometheus) GetAllUUIDsWithFilter 

func (_d NetworkRepoWithPrometheus) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.NetworkFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.NetworkRepo.

func (NetworkRepoWithPrometheus) GetAllWithFilter 

func (_d NetworkRepoWithPrometheus) GetAllWithFilter(ctx context.Context, filter inventory.NetworkFilter) (networks inventory.Networks, err error)

GetAllWithFilter implements inventory.NetworkRepo.

func (NetworkRepoWithPrometheus) GetByUUID 

func (_d NetworkRepoWithPrometheus) GetByUUID(ctx context.Context, id uuid.UUID) (network inventory.Network, err error)

GetByUUID implements inventory.NetworkRepo.

func (NetworkRepoWithPrometheus) UpdateByUUID 

func (_d NetworkRepoWithPrometheus) UpdateByUUID(ctx context.Context, network inventory.Network) (network1 inventory.Network, err error)

UpdateByUUID implements inventory.NetworkRepo.

type NetworkRepoWithSlog 

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

NetworkRepoWithSlog implements inventory.NetworkRepo that is instrumented with slog logger.

func NewNetworkRepoWithSlog 

func NewNetworkRepoWithSlog(base inventory.NetworkRepo, log *slog.Logger, opts ...NetworkRepoWithSlogOption) NetworkRepoWithSlog

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

func (NetworkRepoWithSlog) Create 

func (_d NetworkRepoWithSlog) Create(ctx context.Context, network inventory.Network) (network1 inventory.Network, err error)

Create implements inventory.NetworkRepo.

func (NetworkRepoWithSlog) DeleteByClusterName 

func (_d NetworkRepoWithSlog) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.NetworkRepo.

func (NetworkRepoWithSlog) DeleteByUUID 

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

DeleteByUUID implements inventory.NetworkRepo.

func (NetworkRepoWithSlog) GetAllUUIDsWithFilter 

func (_d NetworkRepoWithSlog) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.NetworkFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.NetworkRepo.

func (NetworkRepoWithSlog) GetAllWithFilter 

func (_d NetworkRepoWithSlog) GetAllWithFilter(ctx context.Context, filter inventory.NetworkFilter) (networks inventory.Networks, err error)

GetAllWithFilter implements inventory.NetworkRepo.

func (NetworkRepoWithSlog) GetByUUID 

func (_d NetworkRepoWithSlog) GetByUUID(ctx context.Context, id uuid.UUID) (network inventory.Network, err error)

GetByUUID implements inventory.NetworkRepo.

func (NetworkRepoWithSlog) UpdateByUUID 

func (_d NetworkRepoWithSlog) UpdateByUUID(ctx context.Context, network inventory.Network) (network1 inventory.Network, err error)

UpdateByUUID implements inventory.NetworkRepo.

type NetworkRepoWithSlogOption 

type NetworkRepoWithSlogOption func(s *NetworkRepoWithSlog)

func NetworkRepoWithSlogWithInformativeErrFunc 

func NetworkRepoWithSlogWithInformativeErrFunc(isInformativeErrFunc func(error) bool) NetworkRepoWithSlogOption

type NetworkZoneRepoWithPrometheus 

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

NetworkZoneRepoWithPrometheus implements inventory.NetworkZoneRepo interface with all methods wrapped with Prometheus metrics.

func NewNetworkZoneRepoWithPrometheus 

func NewNetworkZoneRepoWithPrometheus(base inventory.NetworkZoneRepo, instanceName string) NetworkZoneRepoWithPrometheus

NewNetworkZoneRepoWithPrometheus returns an instance of the inventory.NetworkZoneRepo decorated with prometheus summary metric.

func (NetworkZoneRepoWithPrometheus) Create 

func (_d NetworkZoneRepoWithPrometheus) Create(ctx context.Context, networkZone inventory.NetworkZone) (networkZone1 inventory.NetworkZone, err error)

Create implements inventory.NetworkZoneRepo.

func (NetworkZoneRepoWithPrometheus) DeleteByClusterName 

func (_d NetworkZoneRepoWithPrometheus) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.NetworkZoneRepo.

func (NetworkZoneRepoWithPrometheus) DeleteByUUID 

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

DeleteByUUID implements inventory.NetworkZoneRepo.

func (NetworkZoneRepoWithPrometheus) GetAllUUIDsWithFilter 

func (_d NetworkZoneRepoWithPrometheus) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.NetworkZoneFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.NetworkZoneRepo.

func (NetworkZoneRepoWithPrometheus) GetAllWithFilter 

func (_d NetworkZoneRepoWithPrometheus) GetAllWithFilter(ctx context.Context, filter inventory.NetworkZoneFilter) (networkZones inventory.NetworkZones, err error)

GetAllWithFilter implements inventory.NetworkZoneRepo.

func (NetworkZoneRepoWithPrometheus) GetByUUID 

func (_d NetworkZoneRepoWithPrometheus) GetByUUID(ctx context.Context, id uuid.UUID) (networkZone inventory.NetworkZone, err error)

GetByUUID implements inventory.NetworkZoneRepo.

func (NetworkZoneRepoWithPrometheus) UpdateByUUID 

func (_d NetworkZoneRepoWithPrometheus) UpdateByUUID(ctx context.Context, networkZone inventory.NetworkZone) (networkZone1 inventory.NetworkZone, err error)

UpdateByUUID implements inventory.NetworkZoneRepo.

type NetworkZoneRepoWithSlog 

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

NetworkZoneRepoWithSlog implements inventory.NetworkZoneRepo that is instrumented with slog logger.

func NewNetworkZoneRepoWithSlog 

func NewNetworkZoneRepoWithSlog(base inventory.NetworkZoneRepo, log *slog.Logger, opts ...NetworkZoneRepoWithSlogOption) NetworkZoneRepoWithSlog

NewNetworkZoneRepoWithSlog instruments an implementation of the inventory.NetworkZoneRepo with simple logging.

func (NetworkZoneRepoWithSlog) Create 

func (_d NetworkZoneRepoWithSlog) Create(ctx context.Context, networkZone inventory.NetworkZone) (networkZone1 inventory.NetworkZone, err error)

Create implements inventory.NetworkZoneRepo.

func (NetworkZoneRepoWithSlog) DeleteByClusterName 

func (_d NetworkZoneRepoWithSlog) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.NetworkZoneRepo.

func (NetworkZoneRepoWithSlog) DeleteByUUID 

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

DeleteByUUID implements inventory.NetworkZoneRepo.

func (NetworkZoneRepoWithSlog) GetAllUUIDsWithFilter 

func (_d NetworkZoneRepoWithSlog) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.NetworkZoneFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.NetworkZoneRepo.

func (NetworkZoneRepoWithSlog) GetAllWithFilter 

func (_d NetworkZoneRepoWithSlog) GetAllWithFilter(ctx context.Context, filter inventory.NetworkZoneFilter) (networkZones inventory.NetworkZones, err error)

GetAllWithFilter implements inventory.NetworkZoneRepo.

func (NetworkZoneRepoWithSlog) GetByUUID 

func (_d NetworkZoneRepoWithSlog) GetByUUID(ctx context.Context, id uuid.UUID) (networkZone inventory.NetworkZone, err error)

GetByUUID implements inventory.NetworkZoneRepo.

func (NetworkZoneRepoWithSlog) UpdateByUUID 

func (_d NetworkZoneRepoWithSlog) UpdateByUUID(ctx context.Context, networkZone inventory.NetworkZone) (networkZone1 inventory.NetworkZone, err error)

UpdateByUUID implements inventory.NetworkZoneRepo.

type NetworkZoneRepoWithSlogOption 

type NetworkZoneRepoWithSlogOption func(s *NetworkZoneRepoWithSlog)

func NetworkZoneRepoWithSlogWithInformativeErrFunc 

func NetworkZoneRepoWithSlogWithInformativeErrFunc(isInformativeErrFunc func(error) bool) NetworkZoneRepoWithSlogOption

type ProfileRepoWithPrometheus 

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

ProfileRepoWithPrometheus implements inventory.ProfileRepo interface with all methods wrapped with Prometheus metrics.

func NewProfileRepoWithPrometheus 

func NewProfileRepoWithPrometheus(base inventory.ProfileRepo, instanceName string) ProfileRepoWithPrometheus

NewProfileRepoWithPrometheus returns an instance of the inventory.ProfileRepo decorated with prometheus summary metric.

func (ProfileRepoWithPrometheus) Create 

func (_d ProfileRepoWithPrometheus) Create(ctx context.Context, profile inventory.Profile) (profile1 inventory.Profile, err error)

Create implements inventory.ProfileRepo.

func (ProfileRepoWithPrometheus) DeleteByClusterName 

func (_d ProfileRepoWithPrometheus) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.ProfileRepo.

func (ProfileRepoWithPrometheus) DeleteByUUID 

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

DeleteByUUID implements inventory.ProfileRepo.

func (ProfileRepoWithPrometheus) GetAllUUIDsWithFilter 

func (_d ProfileRepoWithPrometheus) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.ProfileFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.ProfileRepo.

func (ProfileRepoWithPrometheus) GetAllWithFilter 

func (_d ProfileRepoWithPrometheus) GetAllWithFilter(ctx context.Context, filter inventory.ProfileFilter) (profiles inventory.Profiles, err error)

GetAllWithFilter implements inventory.ProfileRepo.

func (ProfileRepoWithPrometheus) GetByUUID 

func (_d ProfileRepoWithPrometheus) GetByUUID(ctx context.Context, id uuid.UUID) (profile inventory.Profile, err error)

GetByUUID implements inventory.ProfileRepo.

func (ProfileRepoWithPrometheus) UpdateByUUID 

func (_d ProfileRepoWithPrometheus) UpdateByUUID(ctx context.Context, profile inventory.Profile) (profile1 inventory.Profile, err error)

UpdateByUUID implements inventory.ProfileRepo.

type ProfileRepoWithSlog 

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

ProfileRepoWithSlog implements inventory.ProfileRepo that is instrumented with slog logger.

func NewProfileRepoWithSlog 

func NewProfileRepoWithSlog(base inventory.ProfileRepo, log *slog.Logger, opts ...ProfileRepoWithSlogOption) ProfileRepoWithSlog

NewProfileRepoWithSlog instruments an implementation of the inventory.ProfileRepo with simple logging.

func (ProfileRepoWithSlog) Create 

func (_d ProfileRepoWithSlog) Create(ctx context.Context, profile inventory.Profile) (profile1 inventory.Profile, err error)

Create implements inventory.ProfileRepo.

func (ProfileRepoWithSlog) DeleteByClusterName 

func (_d ProfileRepoWithSlog) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.ProfileRepo.

func (ProfileRepoWithSlog) DeleteByUUID 

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

DeleteByUUID implements inventory.ProfileRepo.

func (ProfileRepoWithSlog) GetAllUUIDsWithFilter 

func (_d ProfileRepoWithSlog) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.ProfileFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.ProfileRepo.

func (ProfileRepoWithSlog) GetAllWithFilter 

func (_d ProfileRepoWithSlog) GetAllWithFilter(ctx context.Context, filter inventory.ProfileFilter) (profiles inventory.Profiles, err error)

GetAllWithFilter implements inventory.ProfileRepo.

func (ProfileRepoWithSlog) GetByUUID 

func (_d ProfileRepoWithSlog) GetByUUID(ctx context.Context, id uuid.UUID) (profile inventory.Profile, err error)

GetByUUID implements inventory.ProfileRepo.

func (ProfileRepoWithSlog) UpdateByUUID 

func (_d ProfileRepoWithSlog) UpdateByUUID(ctx context.Context, profile inventory.Profile) (profile1 inventory.Profile, err error)

UpdateByUUID implements inventory.ProfileRepo.

type ProfileRepoWithSlogOption 

type ProfileRepoWithSlogOption func(s *ProfileRepoWithSlog)

func ProfileRepoWithSlogWithInformativeErrFunc 

func ProfileRepoWithSlogWithInformativeErrFunc(isInformativeErrFunc func(error) bool) ProfileRepoWithSlogOption

type ProjectRepoWithPrometheus 

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

ProjectRepoWithPrometheus implements inventory.ProjectRepo interface with all methods wrapped with Prometheus metrics.

func NewProjectRepoWithPrometheus 

func NewProjectRepoWithPrometheus(base inventory.ProjectRepo, instanceName string) ProjectRepoWithPrometheus

NewProjectRepoWithPrometheus returns an instance of the inventory.ProjectRepo decorated with prometheus summary metric.

func (ProjectRepoWithPrometheus) Create 

func (_d ProjectRepoWithPrometheus) Create(ctx context.Context, project inventory.Project) (project1 inventory.Project, err error)

Create implements inventory.ProjectRepo.

func (ProjectRepoWithPrometheus) DeleteByClusterName 

func (_d ProjectRepoWithPrometheus) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.ProjectRepo.

func (ProjectRepoWithPrometheus) DeleteByUUID 

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

DeleteByUUID implements inventory.ProjectRepo.

func (ProjectRepoWithPrometheus) GetAllUUIDsWithFilter 

func (_d ProjectRepoWithPrometheus) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.ProjectFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.ProjectRepo.

func (ProjectRepoWithPrometheus) GetAllWithFilter 

func (_d ProjectRepoWithPrometheus) GetAllWithFilter(ctx context.Context, filter inventory.ProjectFilter) (projects inventory.Projects, err error)

GetAllWithFilter implements inventory.ProjectRepo.

func (ProjectRepoWithPrometheus) GetByUUID 

func (_d ProjectRepoWithPrometheus) GetByUUID(ctx context.Context, id uuid.UUID) (project inventory.Project, err error)

GetByUUID implements inventory.ProjectRepo.

func (ProjectRepoWithPrometheus) UpdateByUUID 

func (_d ProjectRepoWithPrometheus) UpdateByUUID(ctx context.Context, project inventory.Project) (project1 inventory.Project, err error)

UpdateByUUID implements inventory.ProjectRepo.

type ProjectRepoWithSlog 

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

ProjectRepoWithSlog implements inventory.ProjectRepo that is instrumented with slog logger.

func NewProjectRepoWithSlog 

func NewProjectRepoWithSlog(base inventory.ProjectRepo, log *slog.Logger, opts ...ProjectRepoWithSlogOption) ProjectRepoWithSlog

NewProjectRepoWithSlog instruments an implementation of the inventory.ProjectRepo with simple logging.

func (ProjectRepoWithSlog) Create 

func (_d ProjectRepoWithSlog) Create(ctx context.Context, project inventory.Project) (project1 inventory.Project, err error)

Create implements inventory.ProjectRepo.

func (ProjectRepoWithSlog) DeleteByClusterName 

func (_d ProjectRepoWithSlog) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.ProjectRepo.

func (ProjectRepoWithSlog) DeleteByUUID 

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

DeleteByUUID implements inventory.ProjectRepo.

func (ProjectRepoWithSlog) GetAllUUIDsWithFilter 

func (_d ProjectRepoWithSlog) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.ProjectFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.ProjectRepo.

func (ProjectRepoWithSlog) GetAllWithFilter 

func (_d ProjectRepoWithSlog) GetAllWithFilter(ctx context.Context, filter inventory.ProjectFilter) (projects inventory.Projects, err error)

GetAllWithFilter implements inventory.ProjectRepo.

func (ProjectRepoWithSlog) GetByUUID 

func (_d ProjectRepoWithSlog) GetByUUID(ctx context.Context, id uuid.UUID) (project inventory.Project, err error)

GetByUUID implements inventory.ProjectRepo.

func (ProjectRepoWithSlog) UpdateByUUID 

func (_d ProjectRepoWithSlog) UpdateByUUID(ctx context.Context, project inventory.Project) (project1 inventory.Project, err error)

UpdateByUUID implements inventory.ProjectRepo.

type ProjectRepoWithSlogOption 

type ProjectRepoWithSlogOption func(s *ProjectRepoWithSlog)

func ProjectRepoWithSlogWithInformativeErrFunc 

func ProjectRepoWithSlogWithInformativeErrFunc(isInformativeErrFunc func(error) bool) ProjectRepoWithSlogOption

type StorageBucketRepoWithPrometheus 

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

StorageBucketRepoWithPrometheus implements inventory.StorageBucketRepo interface with all methods wrapped with Prometheus metrics.

func NewStorageBucketRepoWithPrometheus 

func NewStorageBucketRepoWithPrometheus(base inventory.StorageBucketRepo, instanceName string) StorageBucketRepoWithPrometheus

NewStorageBucketRepoWithPrometheus returns an instance of the inventory.StorageBucketRepo decorated with prometheus summary metric.

func (StorageBucketRepoWithPrometheus) Create 

func (_d StorageBucketRepoWithPrometheus) Create(ctx context.Context, storageBucket inventory.StorageBucket) (storageBucket1 inventory.StorageBucket, err error)

Create implements inventory.StorageBucketRepo.

func (StorageBucketRepoWithPrometheus) DeleteByClusterName 

func (_d StorageBucketRepoWithPrometheus) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.StorageBucketRepo.

func (StorageBucketRepoWithPrometheus) DeleteByUUID 

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

DeleteByUUID implements inventory.StorageBucketRepo.

func (StorageBucketRepoWithPrometheus) GetAllUUIDsWithFilter 

func (_d StorageBucketRepoWithPrometheus) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.StorageBucketFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.StorageBucketRepo.

func (StorageBucketRepoWithPrometheus) GetAllWithFilter 

func (_d StorageBucketRepoWithPrometheus) GetAllWithFilter(ctx context.Context, filter inventory.StorageBucketFilter) (storageBuckets inventory.StorageBuckets, err error)

GetAllWithFilter implements inventory.StorageBucketRepo.

func (StorageBucketRepoWithPrometheus) GetByUUID 

func (_d StorageBucketRepoWithPrometheus) GetByUUID(ctx context.Context, id uuid.UUID) (storageBucket inventory.StorageBucket, err error)

GetByUUID implements inventory.StorageBucketRepo.

func (StorageBucketRepoWithPrometheus) UpdateByUUID 

func (_d StorageBucketRepoWithPrometheus) UpdateByUUID(ctx context.Context, storageBucket inventory.StorageBucket) (storageBucket1 inventory.StorageBucket, err error)

UpdateByUUID implements inventory.StorageBucketRepo.

type StorageBucketRepoWithSlog 

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

StorageBucketRepoWithSlog implements inventory.StorageBucketRepo that is instrumented with slog logger.

func NewStorageBucketRepoWithSlog 

func NewStorageBucketRepoWithSlog(base inventory.StorageBucketRepo, log *slog.Logger, opts ...StorageBucketRepoWithSlogOption) StorageBucketRepoWithSlog

NewStorageBucketRepoWithSlog instruments an implementation of the inventory.StorageBucketRepo with simple logging.

func (StorageBucketRepoWithSlog) Create 

func (_d StorageBucketRepoWithSlog) Create(ctx context.Context, storageBucket inventory.StorageBucket) (storageBucket1 inventory.StorageBucket, err error)

Create implements inventory.StorageBucketRepo.

func (StorageBucketRepoWithSlog) DeleteByClusterName 

func (_d StorageBucketRepoWithSlog) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.StorageBucketRepo.

func (StorageBucketRepoWithSlog) DeleteByUUID 

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

DeleteByUUID implements inventory.StorageBucketRepo.

func (StorageBucketRepoWithSlog) GetAllUUIDsWithFilter 

func (_d StorageBucketRepoWithSlog) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.StorageBucketFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.StorageBucketRepo.

func (StorageBucketRepoWithSlog) GetAllWithFilter 

func (_d StorageBucketRepoWithSlog) GetAllWithFilter(ctx context.Context, filter inventory.StorageBucketFilter) (storageBuckets inventory.StorageBuckets, err error)

GetAllWithFilter implements inventory.StorageBucketRepo.

func (StorageBucketRepoWithSlog) GetByUUID 

func (_d StorageBucketRepoWithSlog) GetByUUID(ctx context.Context, id uuid.UUID) (storageBucket inventory.StorageBucket, err error)

GetByUUID implements inventory.StorageBucketRepo.

func (StorageBucketRepoWithSlog) UpdateByUUID 

func (_d StorageBucketRepoWithSlog) UpdateByUUID(ctx context.Context, storageBucket inventory.StorageBucket) (storageBucket1 inventory.StorageBucket, err error)

UpdateByUUID implements inventory.StorageBucketRepo.

type StorageBucketRepoWithSlogOption 

type StorageBucketRepoWithSlogOption func(s *StorageBucketRepoWithSlog)

func StorageBucketRepoWithSlogWithInformativeErrFunc 

func StorageBucketRepoWithSlogWithInformativeErrFunc(isInformativeErrFunc func(error) bool) StorageBucketRepoWithSlogOption

type StoragePoolRepoWithPrometheus 

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

StoragePoolRepoWithPrometheus implements inventory.StoragePoolRepo interface with all methods wrapped with Prometheus metrics.

func NewStoragePoolRepoWithPrometheus 

func NewStoragePoolRepoWithPrometheus(base inventory.StoragePoolRepo, instanceName string) StoragePoolRepoWithPrometheus

NewStoragePoolRepoWithPrometheus returns an instance of the inventory.StoragePoolRepo decorated with prometheus summary metric.

func (StoragePoolRepoWithPrometheus) Create 

func (_d StoragePoolRepoWithPrometheus) Create(ctx context.Context, storagePool inventory.StoragePool) (storagePool1 inventory.StoragePool, err error)

Create implements inventory.StoragePoolRepo.

func (StoragePoolRepoWithPrometheus) DeleteByClusterName 

func (_d StoragePoolRepoWithPrometheus) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.StoragePoolRepo.

func (StoragePoolRepoWithPrometheus) DeleteByUUID 

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

DeleteByUUID implements inventory.StoragePoolRepo.

func (StoragePoolRepoWithPrometheus) GetAllUUIDsWithFilter 

func (_d StoragePoolRepoWithPrometheus) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.StoragePoolFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.StoragePoolRepo.

func (StoragePoolRepoWithPrometheus) GetAllWithFilter 

func (_d StoragePoolRepoWithPrometheus) GetAllWithFilter(ctx context.Context, filter inventory.StoragePoolFilter) (storagePools inventory.StoragePools, err error)

GetAllWithFilter implements inventory.StoragePoolRepo.

func (StoragePoolRepoWithPrometheus) GetByUUID 

func (_d StoragePoolRepoWithPrometheus) GetByUUID(ctx context.Context, id uuid.UUID) (storagePool inventory.StoragePool, err error)

GetByUUID implements inventory.StoragePoolRepo.

func (StoragePoolRepoWithPrometheus) UpdateByUUID 

func (_d StoragePoolRepoWithPrometheus) UpdateByUUID(ctx context.Context, storagePool inventory.StoragePool) (storagePool1 inventory.StoragePool, err error)

UpdateByUUID implements inventory.StoragePoolRepo.

type StoragePoolRepoWithSlog 

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

StoragePoolRepoWithSlog implements inventory.StoragePoolRepo that is instrumented with slog logger.

func NewStoragePoolRepoWithSlog 

func NewStoragePoolRepoWithSlog(base inventory.StoragePoolRepo, log *slog.Logger, opts ...StoragePoolRepoWithSlogOption) StoragePoolRepoWithSlog

NewStoragePoolRepoWithSlog instruments an implementation of the inventory.StoragePoolRepo with simple logging.

func (StoragePoolRepoWithSlog) Create 

func (_d StoragePoolRepoWithSlog) Create(ctx context.Context, storagePool inventory.StoragePool) (storagePool1 inventory.StoragePool, err error)

Create implements inventory.StoragePoolRepo.

func (StoragePoolRepoWithSlog) DeleteByClusterName 

func (_d StoragePoolRepoWithSlog) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.StoragePoolRepo.

func (StoragePoolRepoWithSlog) DeleteByUUID 

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

DeleteByUUID implements inventory.StoragePoolRepo.

func (StoragePoolRepoWithSlog) GetAllUUIDsWithFilter 

func (_d StoragePoolRepoWithSlog) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.StoragePoolFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.StoragePoolRepo.

func (StoragePoolRepoWithSlog) GetAllWithFilter 

func (_d StoragePoolRepoWithSlog) GetAllWithFilter(ctx context.Context, filter inventory.StoragePoolFilter) (storagePools inventory.StoragePools, err error)

GetAllWithFilter implements inventory.StoragePoolRepo.

func (StoragePoolRepoWithSlog) GetByUUID 

func (_d StoragePoolRepoWithSlog) GetByUUID(ctx context.Context, id uuid.UUID) (storagePool inventory.StoragePool, err error)

GetByUUID implements inventory.StoragePoolRepo.

func (StoragePoolRepoWithSlog) UpdateByUUID 

func (_d StoragePoolRepoWithSlog) UpdateByUUID(ctx context.Context, storagePool inventory.StoragePool) (storagePool1 inventory.StoragePool, err error)

UpdateByUUID implements inventory.StoragePoolRepo.

type StoragePoolRepoWithSlogOption 

type StoragePoolRepoWithSlogOption func(s *StoragePoolRepoWithSlog)

func StoragePoolRepoWithSlogWithInformativeErrFunc 

func StoragePoolRepoWithSlogWithInformativeErrFunc(isInformativeErrFunc func(error) bool) StoragePoolRepoWithSlogOption

type StorageVolumeRepoWithPrometheus 

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

StorageVolumeRepoWithPrometheus implements inventory.StorageVolumeRepo interface with all methods wrapped with Prometheus metrics.

func NewStorageVolumeRepoWithPrometheus 

func NewStorageVolumeRepoWithPrometheus(base inventory.StorageVolumeRepo, instanceName string) StorageVolumeRepoWithPrometheus

NewStorageVolumeRepoWithPrometheus returns an instance of the inventory.StorageVolumeRepo decorated with prometheus summary metric.

func (StorageVolumeRepoWithPrometheus) Create 

func (_d StorageVolumeRepoWithPrometheus) Create(ctx context.Context, storageVolume inventory.StorageVolume) (storageVolume1 inventory.StorageVolume, err error)

Create implements inventory.StorageVolumeRepo.

func (StorageVolumeRepoWithPrometheus) DeleteByClusterName 

func (_d StorageVolumeRepoWithPrometheus) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.StorageVolumeRepo.

func (StorageVolumeRepoWithPrometheus) DeleteByUUID 

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

DeleteByUUID implements inventory.StorageVolumeRepo.

func (StorageVolumeRepoWithPrometheus) GetAllUUIDsWithFilter 

func (_d StorageVolumeRepoWithPrometheus) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.StorageVolumeFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.StorageVolumeRepo.

func (StorageVolumeRepoWithPrometheus) GetAllWithFilter 

func (_d StorageVolumeRepoWithPrometheus) GetAllWithFilter(ctx context.Context, filter inventory.StorageVolumeFilter) (storageVolumes inventory.StorageVolumes, err error)

GetAllWithFilter implements inventory.StorageVolumeRepo.

func (StorageVolumeRepoWithPrometheus) GetByUUID 

func (_d StorageVolumeRepoWithPrometheus) GetByUUID(ctx context.Context, id uuid.UUID) (storageVolume inventory.StorageVolume, err error)

GetByUUID implements inventory.StorageVolumeRepo.

func (StorageVolumeRepoWithPrometheus) UpdateByUUID 

func (_d StorageVolumeRepoWithPrometheus) UpdateByUUID(ctx context.Context, storageVolume inventory.StorageVolume) (storageVolume1 inventory.StorageVolume, err error)

UpdateByUUID implements inventory.StorageVolumeRepo.

type StorageVolumeRepoWithSlog 

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

StorageVolumeRepoWithSlog implements inventory.StorageVolumeRepo that is instrumented with slog logger.

func NewStorageVolumeRepoWithSlog 

func NewStorageVolumeRepoWithSlog(base inventory.StorageVolumeRepo, log *slog.Logger, opts ...StorageVolumeRepoWithSlogOption) StorageVolumeRepoWithSlog

NewStorageVolumeRepoWithSlog instruments an implementation of the inventory.StorageVolumeRepo with simple logging.

func (StorageVolumeRepoWithSlog) Create 

func (_d StorageVolumeRepoWithSlog) Create(ctx context.Context, storageVolume inventory.StorageVolume) (storageVolume1 inventory.StorageVolume, err error)

Create implements inventory.StorageVolumeRepo.

func (StorageVolumeRepoWithSlog) DeleteByClusterName 

func (_d StorageVolumeRepoWithSlog) DeleteByClusterName(ctx context.Context, cluster string) (err error)

DeleteByClusterName implements inventory.StorageVolumeRepo.

func (StorageVolumeRepoWithSlog) DeleteByUUID 

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

DeleteByUUID implements inventory.StorageVolumeRepo.

func (StorageVolumeRepoWithSlog) GetAllUUIDsWithFilter 

func (_d StorageVolumeRepoWithSlog) GetAllUUIDsWithFilter(ctx context.Context, filter inventory.StorageVolumeFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements inventory.StorageVolumeRepo.

func (StorageVolumeRepoWithSlog) GetAllWithFilter 

func (_d StorageVolumeRepoWithSlog) GetAllWithFilter(ctx context.Context, filter inventory.StorageVolumeFilter) (storageVolumes inventory.StorageVolumes, err error)

GetAllWithFilter implements inventory.StorageVolumeRepo.

func (StorageVolumeRepoWithSlog) GetByUUID 

func (_d StorageVolumeRepoWithSlog) GetByUUID(ctx context.Context, id uuid.UUID) (storageVolume inventory.StorageVolume, err error)

GetByUUID implements inventory.StorageVolumeRepo.

func (StorageVolumeRepoWithSlog) UpdateByUUID 

func (_d StorageVolumeRepoWithSlog) UpdateByUUID(ctx context.Context, storageVolume inventory.StorageVolume) (storageVolume1 inventory.StorageVolume, err error)

UpdateByUUID implements inventory.StorageVolumeRepo.

type StorageVolumeRepoWithSlogOption 

type StorageVolumeRepoWithSlogOption func(s *StorageVolumeRepoWithSlog)

func StorageVolumeRepoWithSlogWithInformativeErrFunc 

func StorageVolumeRepoWithSlogWithInformativeErrFunc(isInformativeErrFunc func(error) bool) StorageVolumeRepoWithSlogOption

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.