cluster

package
v0.7.6 Latest Latest
Warning

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

 Go to latest Published: Jul 17, 2026 License: Apache-2.0 Imports: 37 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func New 

func New(
	repo provisioning.ClusterRepo,
	localartifact provisioning.ClusterArtifactRepo,
	client provisioning.ClusterClientPort,
	serverSvc provisioning.ServerService,
	tokenSvc provisioning.TokenService,
	inventorySyncers map[domain.ResourceType]provisioning.InventorySyncer,
	provisioner provisioning.ClusterProvisioningPort,
	inventorySvc interface {
		GetAllWithFilter(ctx context.Context, filter inventory.InventoryAggregateFilter) (inventory.InventoryAggregates, error)
	},
	opts ...Option,
) *clusterService

Types

type Option 

type Option func(s *clusterService)

func WithCreateClusterCertificateNotBeforeDelay 

func WithCreateClusterCertificateNotBeforeDelay(delay time.Duration) Option

func WithCreateRetryTimeout 

func WithCreateRetryTimeout(timeout time.Duration) Option

func WithNow 

func WithNow(nowFunc func() time.Time) Option

func WithPendingUpdateRecheckInterval 

func WithPendingUpdateRecheckInterval(d time.Duration) Option

func WithRemoveServerDeleteClusterMemberRetryDelay 

func WithRemoveServerDeleteClusterMemberRetryDelay(delay time.Duration) Option

func WithRemoveServerFactoryResetWaitDelay 

func WithRemoveServerFactoryResetWaitDelay(delay time.Duration) Option

func WithWarningEmitter 

func WithWarningEmitter(warn provisioning.WarningServicePort) Option

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.