middleware

package
v0.2.2 Latest Latest
Warning

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

 Go to latest Published: Jan 20, 2026 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ClusterServiceWithPrometheus 

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

ClusterServiceWithPrometheus implements provisioning.ClusterService interface with all methods wrapped with Prometheus metrics.

func NewClusterServiceWithPrometheus 

func NewClusterServiceWithPrometheus(base provisioning.ClusterService, instanceName string) ClusterServiceWithPrometheus

NewClusterServiceWithPrometheus returns an instance of the provisioning.ClusterService decorated with prometheus summary metric.

func (ClusterServiceWithPrometheus) Create 

func (_d ClusterServiceWithPrometheus) Create(ctx context.Context, cluster provisioning.Cluster) (cluster1 provisioning.Cluster, err error)

Create implements provisioning.ClusterService.

func (ClusterServiceWithPrometheus) DeleteAndFactoryResetByName added in v0.2.0 

func (_d ClusterServiceWithPrometheus) DeleteAndFactoryResetByName(ctx context.Context, name string, tokenID *uuid.UUID, tokenSeedName *string) (err error)

DeleteAndFactoryResetByName implements provisioning.ClusterService.

func (ClusterServiceWithPrometheus) DeleteByName 

func (_d ClusterServiceWithPrometheus) DeleteByName(ctx context.Context, name string, force bool) (err error)

DeleteByName implements provisioning.ClusterService.

func (ClusterServiceWithPrometheus) GetAll 

func (_d ClusterServiceWithPrometheus) GetAll(ctx context.Context) (clusters provisioning.Clusters, err error)

GetAll implements provisioning.ClusterService.

func (ClusterServiceWithPrometheus) GetAllNames 

func (_d ClusterServiceWithPrometheus) GetAllNames(ctx context.Context) (strings []string, err error)

GetAllNames implements provisioning.ClusterService.

func (ClusterServiceWithPrometheus) GetAllNamesWithFilter 

func (_d ClusterServiceWithPrometheus) GetAllNamesWithFilter(ctx context.Context, filter provisioning.ClusterFilter) (strings []string, err error)

GetAllNamesWithFilter implements provisioning.ClusterService.

func (ClusterServiceWithPrometheus) GetAllWithFilter 

func (_d ClusterServiceWithPrometheus) GetAllWithFilter(ctx context.Context, filter provisioning.ClusterFilter) (clusters provisioning.Clusters, err error)

GetAllWithFilter implements provisioning.ClusterService.

func (ClusterServiceWithPrometheus) GetByName 

func (_d ClusterServiceWithPrometheus) GetByName(ctx context.Context, name string) (cluster *provisioning.Cluster, err error)

GetByName implements provisioning.ClusterService.

func (ClusterServiceWithPrometheus) GetClusterArtifactAll 

func (_d ClusterServiceWithPrometheus) GetClusterArtifactAll(ctx context.Context, clusterName string) (clusterArtifacts provisioning.ClusterArtifacts, err error)

GetClusterArtifactAll implements provisioning.ClusterService.

func (ClusterServiceWithPrometheus) GetClusterArtifactAllNames 

func (_d ClusterServiceWithPrometheus) GetClusterArtifactAllNames(ctx context.Context, clusterName string) (strings []string, err error)

GetClusterArtifactAllNames implements provisioning.ClusterService.

func (ClusterServiceWithPrometheus) GetClusterArtifactArchiveByName 

func (_d ClusterServiceWithPrometheus) GetClusterArtifactArchiveByName(ctx context.Context, clusterName string, artifactName string, archiveType provisioning.ClusterArtifactArchiveType) (readCloser io.ReadCloser, size int, err error)

GetClusterArtifactArchiveByName implements provisioning.ClusterService.

func (ClusterServiceWithPrometheus) GetClusterArtifactByName 

func (_d ClusterServiceWithPrometheus) GetClusterArtifactByName(ctx context.Context, clusterName string, artifactName string) (clusterArtifact *provisioning.ClusterArtifact, err error)

GetClusterArtifactByName implements provisioning.ClusterService.

func (ClusterServiceWithPrometheus) GetClusterArtifactFileByName 

func (_d ClusterServiceWithPrometheus) GetClusterArtifactFileByName(ctx context.Context, clusterName string, artifactName string, filename string) (clusterArtifactFile *provisioning.ClusterArtifactFile, err error)

GetClusterArtifactFileByName implements provisioning.ClusterService.

func (ClusterServiceWithPrometheus) GetEndpoint 

func (_d ClusterServiceWithPrometheus) GetEndpoint(ctx context.Context, name string) (endpoint provisioning.Endpoint, err error)

GetEndpoint implements provisioning.ClusterService.

func (ClusterServiceWithPrometheus) Rename 

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

Rename implements provisioning.ClusterService.

func (ClusterServiceWithPrometheus) ResyncInventory 

func (_d ClusterServiceWithPrometheus) ResyncInventory(ctx context.Context) (err error)

ResyncInventory implements provisioning.ClusterService.

func (ClusterServiceWithPrometheus) ResyncInventoryByName 

func (_d ClusterServiceWithPrometheus) ResyncInventoryByName(ctx context.Context, name string) (err error)

ResyncInventoryByName implements provisioning.ClusterService.

func (ClusterServiceWithPrometheus) SetInventorySyncers 

func (_d ClusterServiceWithPrometheus) SetInventorySyncers(inventorySyncers map[domain.ResourceType]provisioning.InventorySyncer)

SetInventorySyncers implements provisioning.ClusterService.

func (ClusterServiceWithPrometheus) StartLifecycleEventsMonitor 

func (_d ClusterServiceWithPrometheus) StartLifecycleEventsMonitor(ctx context.Context) (err error)

StartLifecycleEventsMonitor implements provisioning.ClusterService.

func (ClusterServiceWithPrometheus) Update 

func (_d ClusterServiceWithPrometheus) Update(ctx context.Context, cluster provisioning.Cluster) (err error)

Update implements provisioning.ClusterService.

func (ClusterServiceWithPrometheus) UpdateCertificate 

func (_d ClusterServiceWithPrometheus) UpdateCertificate(ctx context.Context, name string, certificatePEM string, keyPEM string) (err error)

UpdateCertificate implements provisioning.ClusterService.

type ClusterServiceWithSlog 

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

ClusterServiceWithSlog implements provisioning.ClusterService that is instrumented with slog logger.

func NewClusterServiceWithSlog 

func NewClusterServiceWithSlog(base provisioning.ClusterService, log *slog.Logger, opts ...ClusterServiceWithSlogOption) ClusterServiceWithSlog

NewClusterServiceWithSlog instruments an implementation of the provisioning.ClusterService with simple logging.

func (ClusterServiceWithSlog) Create 

func (_d ClusterServiceWithSlog) Create(ctx context.Context, cluster provisioning.Cluster) (cluster1 provisioning.Cluster, err error)

Create implements provisioning.ClusterService.

func (ClusterServiceWithSlog) DeleteAndFactoryResetByName added in v0.2.0 

func (_d ClusterServiceWithSlog) DeleteAndFactoryResetByName(ctx context.Context, name string, tokenID *uuid.UUID, tokenSeedName *string) (err error)

DeleteAndFactoryResetByName implements provisioning.ClusterService.

func (ClusterServiceWithSlog) DeleteByName 

func (_d ClusterServiceWithSlog) DeleteByName(ctx context.Context, name string, force bool) (err error)

DeleteByName implements provisioning.ClusterService.

func (ClusterServiceWithSlog) GetAll 

func (_d ClusterServiceWithSlog) GetAll(ctx context.Context) (clusters provisioning.Clusters, err error)

GetAll implements provisioning.ClusterService.

func (ClusterServiceWithSlog) GetAllNames 

func (_d ClusterServiceWithSlog) GetAllNames(ctx context.Context) (strings []string, err error)

GetAllNames implements provisioning.ClusterService.

func (ClusterServiceWithSlog) GetAllNamesWithFilter 

func (_d ClusterServiceWithSlog) GetAllNamesWithFilter(ctx context.Context, filter provisioning.ClusterFilter) (strings []string, err error)

GetAllNamesWithFilter implements provisioning.ClusterService.

func (ClusterServiceWithSlog) GetAllWithFilter 

func (_d ClusterServiceWithSlog) GetAllWithFilter(ctx context.Context, filter provisioning.ClusterFilter) (clusters provisioning.Clusters, err error)

GetAllWithFilter implements provisioning.ClusterService.

func (ClusterServiceWithSlog) GetByName 

func (_d ClusterServiceWithSlog) GetByName(ctx context.Context, name string) (cluster *provisioning.Cluster, err error)

GetByName implements provisioning.ClusterService.

func (ClusterServiceWithSlog) GetClusterArtifactAll 

func (_d ClusterServiceWithSlog) GetClusterArtifactAll(ctx context.Context, clusterName string) (clusterArtifacts provisioning.ClusterArtifacts, err error)

GetClusterArtifactAll implements provisioning.ClusterService.

func (ClusterServiceWithSlog) GetClusterArtifactAllNames 

func (_d ClusterServiceWithSlog) GetClusterArtifactAllNames(ctx context.Context, clusterName string) (strings []string, err error)

GetClusterArtifactAllNames implements provisioning.ClusterService.

func (ClusterServiceWithSlog) GetClusterArtifactArchiveByName 

func (_d ClusterServiceWithSlog) GetClusterArtifactArchiveByName(ctx context.Context, clusterName string, artifactName string, archiveType provisioning.ClusterArtifactArchiveType) (readCloser io.ReadCloser, size int, err error)

GetClusterArtifactArchiveByName implements provisioning.ClusterService.

func (ClusterServiceWithSlog) GetClusterArtifactByName 

func (_d ClusterServiceWithSlog) GetClusterArtifactByName(ctx context.Context, clusterName string, artifactName string) (clusterArtifact *provisioning.ClusterArtifact, err error)

GetClusterArtifactByName implements provisioning.ClusterService.

func (ClusterServiceWithSlog) GetClusterArtifactFileByName 

func (_d ClusterServiceWithSlog) GetClusterArtifactFileByName(ctx context.Context, clusterName string, artifactName string, filename string) (clusterArtifactFile *provisioning.ClusterArtifactFile, err error)

GetClusterArtifactFileByName implements provisioning.ClusterService.

func (ClusterServiceWithSlog) GetEndpoint 

func (_d ClusterServiceWithSlog) GetEndpoint(ctx context.Context, name string) (endpoint provisioning.Endpoint, err error)

GetEndpoint implements provisioning.ClusterService.

func (ClusterServiceWithSlog) Rename 

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

Rename implements provisioning.ClusterService.

func (ClusterServiceWithSlog) ResyncInventory 

func (_d ClusterServiceWithSlog) ResyncInventory(ctx context.Context) (err error)

ResyncInventory implements provisioning.ClusterService.

func (ClusterServiceWithSlog) ResyncInventoryByName 

func (_d ClusterServiceWithSlog) ResyncInventoryByName(ctx context.Context, name string) (err error)

ResyncInventoryByName implements provisioning.ClusterService.

func (ClusterServiceWithSlog) SetInventorySyncers 

func (_d ClusterServiceWithSlog) SetInventorySyncers(inventorySyncers map[domain.ResourceType]provisioning.InventorySyncer)

SetInventorySyncers implements provisioning.ClusterService.

func (ClusterServiceWithSlog) StartLifecycleEventsMonitor 

func (_d ClusterServiceWithSlog) StartLifecycleEventsMonitor(ctx context.Context) (err error)

StartLifecycleEventsMonitor implements provisioning.ClusterService.

func (ClusterServiceWithSlog) Update 

func (_d ClusterServiceWithSlog) Update(ctx context.Context, cluster provisioning.Cluster) (err error)

Update implements provisioning.ClusterService.

func (ClusterServiceWithSlog) UpdateCertificate 

func (_d ClusterServiceWithSlog) UpdateCertificate(ctx context.Context, name string, certificatePEM string, keyPEM string) (err error)

UpdateCertificate implements provisioning.ClusterService.

type ClusterServiceWithSlogOption 

type ClusterServiceWithSlogOption func(s *ClusterServiceWithSlog)

func ClusterServiceWithSlogWithInformativeErrFunc 

func ClusterServiceWithSlogWithInformativeErrFunc(isInformativeErrFunc func(error) bool) ClusterServiceWithSlogOption

type ClusterTemplateServiceWithPrometheus 

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

ClusterTemplateServiceWithPrometheus implements provisioning.ClusterTemplateService interface with all methods wrapped with Prometheus metrics.

func NewClusterTemplateServiceWithPrometheus 

func NewClusterTemplateServiceWithPrometheus(base provisioning.ClusterTemplateService, instanceName string) ClusterTemplateServiceWithPrometheus

NewClusterTemplateServiceWithPrometheus returns an instance of the provisioning.ClusterTemplateService decorated with prometheus summary metric.

func (ClusterTemplateServiceWithPrometheus) Apply 

func (_d ClusterTemplateServiceWithPrometheus) Apply(ctx context.Context, name string, templateVariables api.ConfigMap) (servicesConfig map[string]any, applicationSeedConfig map[string]any, err error)

Apply implements provisioning.ClusterTemplateService.

func (ClusterTemplateServiceWithPrometheus) Create 

func (_d ClusterTemplateServiceWithPrometheus) Create(ctx context.Context, clusterTemplate provisioning.ClusterTemplate) (clusterTemplate1 provisioning.ClusterTemplate, err error)

Create implements provisioning.ClusterTemplateService.

func (ClusterTemplateServiceWithPrometheus) DeleteByName 

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

DeleteByName implements provisioning.ClusterTemplateService.

func (ClusterTemplateServiceWithPrometheus) GetAll 

func (_d ClusterTemplateServiceWithPrometheus) GetAll(ctx context.Context) (clusterTemplates provisioning.ClusterTemplates, err error)

GetAll implements provisioning.ClusterTemplateService.

func (ClusterTemplateServiceWithPrometheus) GetAllNames 

func (_d ClusterTemplateServiceWithPrometheus) GetAllNames(ctx context.Context) (strings []string, err error)

GetAllNames implements provisioning.ClusterTemplateService.

func (ClusterTemplateServiceWithPrometheus) GetByName 

func (_d ClusterTemplateServiceWithPrometheus) GetByName(ctx context.Context, name string) (clusterTemplate *provisioning.ClusterTemplate, err error)

GetByName implements provisioning.ClusterTemplateService.

func (ClusterTemplateServiceWithPrometheus) Rename 

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

Rename implements provisioning.ClusterTemplateService.

func (ClusterTemplateServiceWithPrometheus) Update 

func (_d ClusterTemplateServiceWithPrometheus) Update(ctx context.Context, clusterTemplate provisioning.ClusterTemplate) (err error)

Update implements provisioning.ClusterTemplateService.

type ClusterTemplateServiceWithSlog 

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

ClusterTemplateServiceWithSlog implements provisioning.ClusterTemplateService that is instrumented with slog logger.

func NewClusterTemplateServiceWithSlog 

func NewClusterTemplateServiceWithSlog(base provisioning.ClusterTemplateService, log *slog.Logger, opts ...ClusterTemplateServiceWithSlogOption) ClusterTemplateServiceWithSlog

NewClusterTemplateServiceWithSlog instruments an implementation of the provisioning.ClusterTemplateService with simple logging.

func (ClusterTemplateServiceWithSlog) Apply 

func (_d ClusterTemplateServiceWithSlog) Apply(ctx context.Context, name string, templateVariables api.ConfigMap) (servicesConfig map[string]any, applicationSeedConfig map[string]any, err error)

Apply implements provisioning.ClusterTemplateService.

func (ClusterTemplateServiceWithSlog) Create 

func (_d ClusterTemplateServiceWithSlog) Create(ctx context.Context, clusterTemplate provisioning.ClusterTemplate) (clusterTemplate1 provisioning.ClusterTemplate, err error)

Create implements provisioning.ClusterTemplateService.

func (ClusterTemplateServiceWithSlog) DeleteByName 

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

DeleteByName implements provisioning.ClusterTemplateService.

func (ClusterTemplateServiceWithSlog) GetAll 

func (_d ClusterTemplateServiceWithSlog) GetAll(ctx context.Context) (clusterTemplates provisioning.ClusterTemplates, err error)

GetAll implements provisioning.ClusterTemplateService.

func (ClusterTemplateServiceWithSlog) GetAllNames 

func (_d ClusterTemplateServiceWithSlog) GetAllNames(ctx context.Context) (strings []string, err error)

GetAllNames implements provisioning.ClusterTemplateService.

func (ClusterTemplateServiceWithSlog) GetByName 

func (_d ClusterTemplateServiceWithSlog) GetByName(ctx context.Context, name string) (clusterTemplate *provisioning.ClusterTemplate, err error)

GetByName implements provisioning.ClusterTemplateService.

func (ClusterTemplateServiceWithSlog) Rename 

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

Rename implements provisioning.ClusterTemplateService.

func (ClusterTemplateServiceWithSlog) Update 

func (_d ClusterTemplateServiceWithSlog) Update(ctx context.Context, clusterTemplate provisioning.ClusterTemplate) (err error)

Update implements provisioning.ClusterTemplateService.

type ClusterTemplateServiceWithSlogOption 

type ClusterTemplateServiceWithSlogOption func(s *ClusterTemplateServiceWithSlog)

func ClusterTemplateServiceWithSlogWithInformativeErrFunc 

func ClusterTemplateServiceWithSlogWithInformativeErrFunc(isInformativeErrFunc func(error) bool) ClusterTemplateServiceWithSlogOption

type ServerServiceWithPrometheus 

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

ServerServiceWithPrometheus implements provisioning.ServerService interface with all methods wrapped with Prometheus metrics.

func NewServerServiceWithPrometheus 

func NewServerServiceWithPrometheus(base provisioning.ServerService, instanceName string) ServerServiceWithPrometheus

NewServerServiceWithPrometheus returns an instance of the provisioning.ServerService decorated with prometheus summary metric.

func (ServerServiceWithPrometheus) Create 

func (_d ServerServiceWithPrometheus) Create(ctx context.Context, token uuid.UUID, server provisioning.Server) (server1 provisioning.Server, err error)

Create implements provisioning.ServerService.

func (ServerServiceWithPrometheus) DeleteByName 

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

DeleteByName implements provisioning.ServerService.

func (ServerServiceWithPrometheus) GetAll 

func (_d ServerServiceWithPrometheus) GetAll(ctx context.Context) (servers provisioning.Servers, err error)

GetAll implements provisioning.ServerService.

func (ServerServiceWithPrometheus) GetAllNames 

func (_d ServerServiceWithPrometheus) GetAllNames(ctx context.Context) (strings []string, err error)

GetAllNames implements provisioning.ServerService.

func (ServerServiceWithPrometheus) GetAllNamesWithFilter 

func (_d ServerServiceWithPrometheus) GetAllNamesWithFilter(ctx context.Context, filter provisioning.ServerFilter) (strings []string, err error)

GetAllNamesWithFilter implements provisioning.ServerService.

func (ServerServiceWithPrometheus) GetAllWithFilter 

func (_d ServerServiceWithPrometheus) GetAllWithFilter(ctx context.Context, filter provisioning.ServerFilter) (servers provisioning.Servers, err error)

GetAllWithFilter implements provisioning.ServerService.

func (ServerServiceWithPrometheus) GetByName 

func (_d ServerServiceWithPrometheus) GetByName(ctx context.Context, name string) (server *provisioning.Server, err error)

GetByName implements provisioning.ServerService.

func (ServerServiceWithPrometheus) GetSystemProvider 

func (_d ServerServiceWithPrometheus) GetSystemProvider(ctx context.Context, name string) (v provisioning.ServerSystemProvider, err error)

GetSystemProvider implements provisioning.ServerService.

func (ServerServiceWithPrometheus) PollServers 

func (_d ServerServiceWithPrometheus) PollServers(ctx context.Context, serverStatus api.ServerStatus, updateServerConfiguration bool) (err error)

PollServers implements provisioning.ServerService.

func (ServerServiceWithPrometheus) PoweroffSystemByName added in v0.2.2 

func (_d ServerServiceWithPrometheus) PoweroffSystemByName(ctx context.Context, name string) (err error)

PoweroffSystemByName implements provisioning.ServerService.

func (ServerServiceWithPrometheus) RebootSystemByName added in v0.2.2 

func (_d ServerServiceWithPrometheus) RebootSystemByName(ctx context.Context, name string) (err error)

RebootSystemByName implements provisioning.ServerService.

func (ServerServiceWithPrometheus) Rename 

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

Rename implements provisioning.ServerService.

func (ServerServiceWithPrometheus) ResyncByName added in v0.2.0 

func (_d ServerServiceWithPrometheus) ResyncByName(ctx context.Context, name string) (err error)

ResyncByName implements provisioning.ServerService.

func (ServerServiceWithPrometheus) SelfRegisterOperationsCenter 

func (_d ServerServiceWithPrometheus) SelfRegisterOperationsCenter(ctx context.Context) (err error)

SelfRegisterOperationsCenter implements provisioning.ServerService.

func (ServerServiceWithPrometheus) SelfUpdate 

func (_d ServerServiceWithPrometheus) SelfUpdate(ctx context.Context, serverUpdate provisioning.ServerSelfUpdate) (err error)

SelfUpdate implements provisioning.ServerService.

func (ServerServiceWithPrometheus) SetClusterService 

func (_d ServerServiceWithPrometheus) SetClusterService(clusterSvc provisioning.ClusterService)

SetClusterService implements provisioning.ServerService.

func (ServerServiceWithPrometheus) Update 

func (_d ServerServiceWithPrometheus) Update(ctx context.Context, server provisioning.Server) (err error)

Update implements provisioning.ServerService.

func (ServerServiceWithPrometheus) UpdateSystemNetwork 

func (_d ServerServiceWithPrometheus) UpdateSystemNetwork(ctx context.Context, name string, networkConfig provisioning.ServerSystemNetwork) (err error)

UpdateSystemNetwork implements provisioning.ServerService.

func (ServerServiceWithPrometheus) UpdateSystemProvider 

func (_d ServerServiceWithPrometheus) UpdateSystemProvider(ctx context.Context, name string, providerConfig provisioning.ServerSystemProvider) (err error)

UpdateSystemProvider implements provisioning.ServerService.

func (ServerServiceWithPrometheus) UpdateSystemStorage added in v0.2.0 

func (_d ServerServiceWithPrometheus) UpdateSystemStorage(ctx context.Context, name string, networkConfig provisioning.ServerSystemStorage) (err error)

UpdateSystemStorage implements provisioning.ServerService.

type ServerServiceWithSlog 

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

ServerServiceWithSlog implements provisioning.ServerService that is instrumented with slog logger.

func NewServerServiceWithSlog 

func NewServerServiceWithSlog(base provisioning.ServerService, log *slog.Logger, opts ...ServerServiceWithSlogOption) ServerServiceWithSlog

NewServerServiceWithSlog instruments an implementation of the provisioning.ServerService with simple logging.

func (ServerServiceWithSlog) Create 

func (_d ServerServiceWithSlog) Create(ctx context.Context, token uuid.UUID, server provisioning.Server) (server1 provisioning.Server, err error)

Create implements provisioning.ServerService.

func (ServerServiceWithSlog) DeleteByName 

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

DeleteByName implements provisioning.ServerService.

func (ServerServiceWithSlog) GetAll 

func (_d ServerServiceWithSlog) GetAll(ctx context.Context) (servers provisioning.Servers, err error)

GetAll implements provisioning.ServerService.

func (ServerServiceWithSlog) GetAllNames 

func (_d ServerServiceWithSlog) GetAllNames(ctx context.Context) (strings []string, err error)

GetAllNames implements provisioning.ServerService.

func (ServerServiceWithSlog) GetAllNamesWithFilter 

func (_d ServerServiceWithSlog) GetAllNamesWithFilter(ctx context.Context, filter provisioning.ServerFilter) (strings []string, err error)

GetAllNamesWithFilter implements provisioning.ServerService.

func (ServerServiceWithSlog) GetAllWithFilter 

func (_d ServerServiceWithSlog) GetAllWithFilter(ctx context.Context, filter provisioning.ServerFilter) (servers provisioning.Servers, err error)

GetAllWithFilter implements provisioning.ServerService.

func (ServerServiceWithSlog) GetByName 

func (_d ServerServiceWithSlog) GetByName(ctx context.Context, name string) (server *provisioning.Server, err error)

GetByName implements provisioning.ServerService.

func (ServerServiceWithSlog) GetSystemProvider 

func (_d ServerServiceWithSlog) GetSystemProvider(ctx context.Context, name string) (v provisioning.ServerSystemProvider, err error)

GetSystemProvider implements provisioning.ServerService.

func (ServerServiceWithSlog) PollServers 

func (_d ServerServiceWithSlog) PollServers(ctx context.Context, serverStatus api.ServerStatus, updateServerConfiguration bool) (err error)

PollServers implements provisioning.ServerService.

func (ServerServiceWithSlog) PoweroffSystemByName added in v0.2.2 

func (_d ServerServiceWithSlog) PoweroffSystemByName(ctx context.Context, name string) (err error)

PoweroffSystemByName implements provisioning.ServerService.

func (ServerServiceWithSlog) RebootSystemByName added in v0.2.2 

func (_d ServerServiceWithSlog) RebootSystemByName(ctx context.Context, name string) (err error)

RebootSystemByName implements provisioning.ServerService.

func (ServerServiceWithSlog) Rename 

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

Rename implements provisioning.ServerService.

func (ServerServiceWithSlog) ResyncByName added in v0.2.0 

func (_d ServerServiceWithSlog) ResyncByName(ctx context.Context, name string) (err error)

ResyncByName implements provisioning.ServerService.

func (ServerServiceWithSlog) SelfRegisterOperationsCenter 

func (_d ServerServiceWithSlog) SelfRegisterOperationsCenter(ctx context.Context) (err error)

SelfRegisterOperationsCenter implements provisioning.ServerService.

func (ServerServiceWithSlog) SelfUpdate 

func (_d ServerServiceWithSlog) SelfUpdate(ctx context.Context, serverUpdate provisioning.ServerSelfUpdate) (err error)

SelfUpdate implements provisioning.ServerService.

func (ServerServiceWithSlog) SetClusterService 

func (_d ServerServiceWithSlog) SetClusterService(clusterSvc provisioning.ClusterService)

SetClusterService implements provisioning.ServerService.

func (ServerServiceWithSlog) Update 

func (_d ServerServiceWithSlog) Update(ctx context.Context, server provisioning.Server) (err error)

Update implements provisioning.ServerService.

func (ServerServiceWithSlog) UpdateSystemNetwork 

func (_d ServerServiceWithSlog) UpdateSystemNetwork(ctx context.Context, name string, networkConfig provisioning.ServerSystemNetwork) (err error)

UpdateSystemNetwork implements provisioning.ServerService.

func (ServerServiceWithSlog) UpdateSystemProvider 

func (_d ServerServiceWithSlog) UpdateSystemProvider(ctx context.Context, name string, providerConfig provisioning.ServerSystemProvider) (err error)

UpdateSystemProvider implements provisioning.ServerService.

func (ServerServiceWithSlog) UpdateSystemStorage added in v0.2.0 

func (_d ServerServiceWithSlog) UpdateSystemStorage(ctx context.Context, name string, networkConfig provisioning.ServerSystemStorage) (err error)

UpdateSystemStorage implements provisioning.ServerService.

type ServerServiceWithSlogOption 

type ServerServiceWithSlogOption func(s *ServerServiceWithSlog)

func ServerServiceWithSlogWithInformativeErrFunc 

func ServerServiceWithSlogWithInformativeErrFunc(isInformativeErrFunc func(error) bool) ServerServiceWithSlogOption

type TokenServiceWithPrometheus 

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

TokenServiceWithPrometheus implements provisioning.TokenService interface with all methods wrapped with Prometheus metrics.

func NewTokenServiceWithPrometheus 

func NewTokenServiceWithPrometheus(base provisioning.TokenService, instanceName string) TokenServiceWithPrometheus

NewTokenServiceWithPrometheus returns an instance of the provisioning.TokenService decorated with prometheus summary metric.

func (TokenServiceWithPrometheus) Consume 

func (_d TokenServiceWithPrometheus) Consume(ctx context.Context, id uuid.UUID) (err error)

Consume implements provisioning.TokenService.

func (TokenServiceWithPrometheus) Create 

func (_d TokenServiceWithPrometheus) Create(ctx context.Context, token provisioning.Token) (token1 provisioning.Token, err error)

Create implements provisioning.TokenService.

func (TokenServiceWithPrometheus) CreateTokenSeed 

func (_d TokenServiceWithPrometheus) CreateTokenSeed(ctx context.Context, tokenSeedConfig provisioning.TokenSeed) (tokenSeed provisioning.TokenSeed, err error)

CreateTokenSeed implements provisioning.TokenService.

func (TokenServiceWithPrometheus) DeleteByUUID 

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

DeleteByUUID implements provisioning.TokenService.

func (TokenServiceWithPrometheus) DeleteTokenSeedByName 

func (_d TokenServiceWithPrometheus) DeleteTokenSeedByName(ctx context.Context, id uuid.UUID, name string) (err error)

DeleteTokenSeedByName implements provisioning.TokenService.

func (TokenServiceWithPrometheus) GetAll 

func (_d TokenServiceWithPrometheus) GetAll(ctx context.Context) (tokens provisioning.Tokens, err error)

GetAll implements provisioning.TokenService.

func (TokenServiceWithPrometheus) GetAllUUIDs 

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

GetAllUUIDs implements provisioning.TokenService.

func (TokenServiceWithPrometheus) GetByUUID 

func (_d TokenServiceWithPrometheus) GetByUUID(ctx context.Context, id uuid.UUID) (token *provisioning.Token, err error)

GetByUUID implements provisioning.TokenService.

func (TokenServiceWithPrometheus) GetPreSeededImage added in v0.2.0 

func (_d TokenServiceWithPrometheus) GetPreSeededImage(ctx context.Context, id uuid.UUID, imageUUID uuid.UUID) (readCloser io.ReadCloser, filename string, err error)

GetPreSeededImage implements provisioning.TokenService.

func (TokenServiceWithPrometheus) GetTokenImageFromTokenSeed 

func (_d TokenServiceWithPrometheus) GetTokenImageFromTokenSeed(ctx context.Context, id uuid.UUID, name string, imageType api.ImageType, architecture images.UpdateFileArchitecture) (readCloser io.ReadCloser, err error)

GetTokenImageFromTokenSeed implements provisioning.TokenService.

func (TokenServiceWithPrometheus) GetTokenProviderConfig 

func (_d TokenServiceWithPrometheus) GetTokenProviderConfig(ctx context.Context, id uuid.UUID) (tokenProviderConfig *api.TokenProviderConfig, err error)

GetTokenProviderConfig implements provisioning.TokenService.

func (TokenServiceWithPrometheus) GetTokenSeedAll 

func (_d TokenServiceWithPrometheus) GetTokenSeedAll(ctx context.Context, id uuid.UUID) (tokenSeeds provisioning.TokenSeeds, err error)

GetTokenSeedAll implements provisioning.TokenService.

func (TokenServiceWithPrometheus) GetTokenSeedAllNames 

func (_d TokenServiceWithPrometheus) GetTokenSeedAllNames(ctx context.Context, id uuid.UUID) (strings []string, err error)

GetTokenSeedAllNames implements provisioning.TokenService.

func (TokenServiceWithPrometheus) GetTokenSeedByName 

func (_d TokenServiceWithPrometheus) GetTokenSeedByName(ctx context.Context, id uuid.UUID, name string) (tokenSeed *provisioning.TokenSeed, err error)

GetTokenSeedByName implements provisioning.TokenService.

func (TokenServiceWithPrometheus) PreparePreSeededImage added in v0.2.0 

func (_d TokenServiceWithPrometheus) PreparePreSeededImage(ctx context.Context, id uuid.UUID, imageType api.ImageType, architecture images.UpdateFileArchitecture, seedConfig provisioning.TokenImageSeedConfigs) (uUID uuid.UUID, err error)

PreparePreSeededImage implements provisioning.TokenService.

func (TokenServiceWithPrometheus) Update 

func (_d TokenServiceWithPrometheus) Update(ctx context.Context, token provisioning.Token) (err error)

Update implements provisioning.TokenService.

func (TokenServiceWithPrometheus) UpdateTokenSeed 

func (_d TokenServiceWithPrometheus) UpdateTokenSeed(ctx context.Context, tokenSeed provisioning.TokenSeed) (err error)

UpdateTokenSeed implements provisioning.TokenService.

type TokenServiceWithSlog 

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

TokenServiceWithSlog implements provisioning.TokenService that is instrumented with slog logger.

func NewTokenServiceWithSlog 

func NewTokenServiceWithSlog(base provisioning.TokenService, log *slog.Logger, opts ...TokenServiceWithSlogOption) TokenServiceWithSlog

NewTokenServiceWithSlog instruments an implementation of the provisioning.TokenService with simple logging.

func (TokenServiceWithSlog) Consume 

func (_d TokenServiceWithSlog) Consume(ctx context.Context, id uuid.UUID) (err error)

Consume implements provisioning.TokenService.

func (TokenServiceWithSlog) Create 

func (_d TokenServiceWithSlog) Create(ctx context.Context, token provisioning.Token) (token1 provisioning.Token, err error)

Create implements provisioning.TokenService.

func (TokenServiceWithSlog) CreateTokenSeed 

func (_d TokenServiceWithSlog) CreateTokenSeed(ctx context.Context, tokenSeedConfig provisioning.TokenSeed) (tokenSeed provisioning.TokenSeed, err error)

CreateTokenSeed implements provisioning.TokenService.

func (TokenServiceWithSlog) DeleteByUUID 

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

DeleteByUUID implements provisioning.TokenService.

func (TokenServiceWithSlog) DeleteTokenSeedByName 

func (_d TokenServiceWithSlog) DeleteTokenSeedByName(ctx context.Context, id uuid.UUID, name string) (err error)

DeleteTokenSeedByName implements provisioning.TokenService.

func (TokenServiceWithSlog) GetAll 

func (_d TokenServiceWithSlog) GetAll(ctx context.Context) (tokens provisioning.Tokens, err error)

GetAll implements provisioning.TokenService.

func (TokenServiceWithSlog) GetAllUUIDs 

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

GetAllUUIDs implements provisioning.TokenService.

func (TokenServiceWithSlog) GetByUUID 

func (_d TokenServiceWithSlog) GetByUUID(ctx context.Context, id uuid.UUID) (token *provisioning.Token, err error)

GetByUUID implements provisioning.TokenService.

func (TokenServiceWithSlog) GetPreSeededImage added in v0.2.0 

func (_d TokenServiceWithSlog) GetPreSeededImage(ctx context.Context, id uuid.UUID, imageUUID uuid.UUID) (readCloser io.ReadCloser, filename string, err error)

GetPreSeededImage implements provisioning.TokenService.

func (TokenServiceWithSlog) GetTokenImageFromTokenSeed 

func (_d TokenServiceWithSlog) GetTokenImageFromTokenSeed(ctx context.Context, id uuid.UUID, name string, imageType api.ImageType, architecture images.UpdateFileArchitecture) (readCloser io.ReadCloser, err error)

GetTokenImageFromTokenSeed implements provisioning.TokenService.

func (TokenServiceWithSlog) GetTokenProviderConfig 

func (_d TokenServiceWithSlog) GetTokenProviderConfig(ctx context.Context, id uuid.UUID) (tokenProviderConfig *api.TokenProviderConfig, err error)

GetTokenProviderConfig implements provisioning.TokenService.

func (TokenServiceWithSlog) GetTokenSeedAll 

func (_d TokenServiceWithSlog) GetTokenSeedAll(ctx context.Context, id uuid.UUID) (tokenSeeds provisioning.TokenSeeds, err error)

GetTokenSeedAll implements provisioning.TokenService.

func (TokenServiceWithSlog) GetTokenSeedAllNames 

func (_d TokenServiceWithSlog) GetTokenSeedAllNames(ctx context.Context, id uuid.UUID) (strings []string, err error)

GetTokenSeedAllNames implements provisioning.TokenService.

func (TokenServiceWithSlog) GetTokenSeedByName 

func (_d TokenServiceWithSlog) GetTokenSeedByName(ctx context.Context, id uuid.UUID, name string) (tokenSeed *provisioning.TokenSeed, err error)

GetTokenSeedByName implements provisioning.TokenService.

func (TokenServiceWithSlog) PreparePreSeededImage added in v0.2.0 

func (_d TokenServiceWithSlog) PreparePreSeededImage(ctx context.Context, id uuid.UUID, imageType api.ImageType, architecture images.UpdateFileArchitecture, seedConfig provisioning.TokenImageSeedConfigs) (uUID uuid.UUID, err error)

PreparePreSeededImage implements provisioning.TokenService.

func (TokenServiceWithSlog) Update 

func (_d TokenServiceWithSlog) Update(ctx context.Context, token provisioning.Token) (err error)

Update implements provisioning.TokenService.

func (TokenServiceWithSlog) UpdateTokenSeed 

func (_d TokenServiceWithSlog) UpdateTokenSeed(ctx context.Context, tokenSeed provisioning.TokenSeed) (err error)

UpdateTokenSeed implements provisioning.TokenService.

type TokenServiceWithSlogOption 

type TokenServiceWithSlogOption func(s *TokenServiceWithSlog)

func TokenServiceWithSlogWithInformativeErrFunc 

func TokenServiceWithSlogWithInformativeErrFunc(isInformativeErrFunc func(error) bool) TokenServiceWithSlogOption

type UpdateServiceWithPrometheus 

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

UpdateServiceWithPrometheus implements provisioning.UpdateService interface with all methods wrapped with Prometheus metrics.

func NewUpdateServiceWithPrometheus 

func NewUpdateServiceWithPrometheus(base provisioning.UpdateService, instanceName string) UpdateServiceWithPrometheus

NewUpdateServiceWithPrometheus returns an instance of the provisioning.UpdateService decorated with prometheus summary metric.

func (UpdateServiceWithPrometheus) CleanupAll 

func (_d UpdateServiceWithPrometheus) CleanupAll(ctx context.Context) (err error)

CleanupAll implements provisioning.UpdateService.

func (UpdateServiceWithPrometheus) CreateFromArchive 

func (_d UpdateServiceWithPrometheus) CreateFromArchive(ctx context.Context, tarReader *tar.Reader) (uUID uuid.UUID, err error)

CreateFromArchive implements provisioning.UpdateService.

func (UpdateServiceWithPrometheus) GetAll 

func (_d UpdateServiceWithPrometheus) GetAll(ctx context.Context) (updates provisioning.Updates, err error)

GetAll implements provisioning.UpdateService.

func (UpdateServiceWithPrometheus) GetAllUUIDs 

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

GetAllUUIDs implements provisioning.UpdateService.

func (UpdateServiceWithPrometheus) GetAllUUIDsWithFilter 

func (_d UpdateServiceWithPrometheus) GetAllUUIDsWithFilter(ctx context.Context, filter provisioning.UpdateFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements provisioning.UpdateService.

func (UpdateServiceWithPrometheus) GetAllWithFilter 

func (_d UpdateServiceWithPrometheus) GetAllWithFilter(ctx context.Context, filter provisioning.UpdateFilter) (updates provisioning.Updates, err error)

GetAllWithFilter implements provisioning.UpdateService.

func (UpdateServiceWithPrometheus) GetByUUID 

func (_d UpdateServiceWithPrometheus) GetByUUID(ctx context.Context, id uuid.UUID) (update *provisioning.Update, err error)

GetByUUID implements provisioning.UpdateService.

func (UpdateServiceWithPrometheus) GetUpdateAllFiles 

func (_d UpdateServiceWithPrometheus) GetUpdateAllFiles(ctx context.Context, id uuid.UUID) (updateFiles provisioning.UpdateFiles, err error)

GetUpdateAllFiles implements provisioning.UpdateService.

func (UpdateServiceWithPrometheus) GetUpdateFileByFilename 

func (_d UpdateServiceWithPrometheus) GetUpdateFileByFilename(ctx context.Context, id uuid.UUID, filename string) (readCloser io.ReadCloser, n int, err error)

GetUpdateFileByFilename implements provisioning.UpdateService.

func (UpdateServiceWithPrometheus) Prune 

func (_d UpdateServiceWithPrometheus) Prune(ctx context.Context) (err error)

Prune implements provisioning.UpdateService.

func (UpdateServiceWithPrometheus) Refresh 

func (_d UpdateServiceWithPrometheus) Refresh(ctx context.Context) (err error)

Refresh implements provisioning.UpdateService.

type UpdateServiceWithSlog 

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

UpdateServiceWithSlog implements provisioning.UpdateService that is instrumented with slog logger.

func NewUpdateServiceWithSlog 

func NewUpdateServiceWithSlog(base provisioning.UpdateService, log *slog.Logger, opts ...UpdateServiceWithSlogOption) UpdateServiceWithSlog

NewUpdateServiceWithSlog instruments an implementation of the provisioning.UpdateService with simple logging.

func (UpdateServiceWithSlog) CleanupAll 

func (_d UpdateServiceWithSlog) CleanupAll(ctx context.Context) (err error)

CleanupAll implements provisioning.UpdateService.

func (UpdateServiceWithSlog) CreateFromArchive 

func (_d UpdateServiceWithSlog) CreateFromArchive(ctx context.Context, tarReader *tar.Reader) (uUID uuid.UUID, err error)

CreateFromArchive implements provisioning.UpdateService.

func (UpdateServiceWithSlog) GetAll 

func (_d UpdateServiceWithSlog) GetAll(ctx context.Context) (updates provisioning.Updates, err error)

GetAll implements provisioning.UpdateService.

func (UpdateServiceWithSlog) GetAllUUIDs 

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

GetAllUUIDs implements provisioning.UpdateService.

func (UpdateServiceWithSlog) GetAllUUIDsWithFilter 

func (_d UpdateServiceWithSlog) GetAllUUIDsWithFilter(ctx context.Context, filter provisioning.UpdateFilter) (uUIDs []uuid.UUID, err error)

GetAllUUIDsWithFilter implements provisioning.UpdateService.

func (UpdateServiceWithSlog) GetAllWithFilter 

func (_d UpdateServiceWithSlog) GetAllWithFilter(ctx context.Context, filter provisioning.UpdateFilter) (updates provisioning.Updates, err error)

GetAllWithFilter implements provisioning.UpdateService.

func (UpdateServiceWithSlog) GetByUUID 

func (_d UpdateServiceWithSlog) GetByUUID(ctx context.Context, id uuid.UUID) (update *provisioning.Update, err error)

GetByUUID implements provisioning.UpdateService.

func (UpdateServiceWithSlog) GetUpdateAllFiles 

func (_d UpdateServiceWithSlog) GetUpdateAllFiles(ctx context.Context, id uuid.UUID) (updateFiles provisioning.UpdateFiles, err error)

GetUpdateAllFiles implements provisioning.UpdateService.

func (UpdateServiceWithSlog) GetUpdateFileByFilename 

func (_d UpdateServiceWithSlog) GetUpdateFileByFilename(ctx context.Context, id uuid.UUID, filename string) (readCloser io.ReadCloser, n int, err error)

GetUpdateFileByFilename implements provisioning.UpdateService.

func (UpdateServiceWithSlog) Prune 

func (_d UpdateServiceWithSlog) Prune(ctx context.Context) (err error)

Prune implements provisioning.UpdateService.

func (UpdateServiceWithSlog) Refresh 

func (_d UpdateServiceWithSlog) Refresh(ctx context.Context) (err error)

Refresh implements provisioning.UpdateService.

type UpdateServiceWithSlogOption 

type UpdateServiceWithSlogOption func(s *UpdateServiceWithSlog)

func UpdateServiceWithSlogWithInformativeErrFunc 

func UpdateServiceWithSlogWithInformativeErrFunc(isInformativeErrFunc func(error) bool) UpdateServiceWithSlogOption

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.