agent

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Oct 31, 2025 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SharedNodeAgentName = "kubelet"
	SharedNodeMode      = "shared"
)
View Source 
const (
	VirtualNodeMode = "virtual"
)

Variables

This section is empty.

Functions

func WebhookSecretName added in v0.3.0 

func WebhookSecretName(clusterName string) string

Types

type Config added in v0.3.0 

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

func NewConfig added in v0.3.0 

func NewConfig(cluster *v1beta1.Cluster, client ctrlruntimeclient.Client, scheme *runtime.Scheme) *Config

type PortAllocator added in v0.3.4 

type PortAllocator struct {
	ctrlruntimeclient.Client

	KubeletCM *v1.ConfigMap
	WebhookCM *v1.ConfigMap
}

func NewPortAllocator added in v0.3.4 

func NewPortAllocator(ctx context.Context, client ctrlruntimeclient.Client) (*PortAllocator, error)

func (*PortAllocator) AllocateKubeletPort added in v0.3.4 

func (a *PortAllocator) AllocateKubeletPort(ctx context.Context, clusterName, clusterNamespace string) (int, error)

func (*PortAllocator) AllocateWebhookPort added in v0.3.4 

func (a *PortAllocator) AllocateWebhookPort(ctx context.Context, clusterName, clusterNamespace string) (int, error)

func (*PortAllocator) DeallocateKubeletPort added in v0.3.4 

func (a *PortAllocator) DeallocateKubeletPort(ctx context.Context, clusterName, clusterNamespace string, kubeletPort int) error

func (*PortAllocator) DeallocateWebhookPort added in v0.3.4 

func (a *PortAllocator) DeallocateWebhookPort(ctx context.Context, clusterName, clusterNamespace string, webhookPort int) error

func (*PortAllocator) InitPortAllocatorConfig added in v0.3.4 

func (a *PortAllocator) InitPortAllocatorConfig(ctx context.Context, client ctrlruntimeclient.Client, kubeletPortRange, webhookPortRange string) manager.Runnable

type ResourceEnsurer added in v0.3.0 

type ResourceEnsurer interface {
	EnsureResources(context.Context) error
}

type SharedAgent added in v0.3.0 

type SharedAgent struct {
	*Config
	// contains filtered or unexported fields
}

func NewSharedAgent added in v0.3.0 

func NewSharedAgent(config *Config, serviceIP, image, imagePullPolicy, token string, kubeletPort, webhookPort int, imagePullSecrets []string) *SharedAgent

func (*SharedAgent) EnsureResources added in v0.3.0 

func (s *SharedAgent) EnsureResources(ctx context.Context) error

func (*SharedAgent) Name added in v0.3.0 

func (s *SharedAgent) Name() string

type VirtualAgent added in v0.3.0 

type VirtualAgent struct {
	*Config

	Image           string
	ImagePullPolicy string
	ImageRegistry   string
	// contains filtered or unexported fields
}

func NewVirtualAgent added in v0.3.0 

func NewVirtualAgent(config *Config, serviceIP, token, Image, ImagePullPolicy string, imagePullSecrets []string) *VirtualAgent

func (*VirtualAgent) EnsureResources added in v0.3.0 

func (v *VirtualAgent) EnsureResources(ctx context.Context) error

func (*VirtualAgent) Name added in v0.3.0 

func (v *VirtualAgent) Name() string

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.