flexcontroller

package

v0.1.4 Latest Latest Go to latest Published: Jul 14, 2026 License: MIT Imports: 21 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/Azure/AKSFlexNode

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func Run(ctx context.Context, opts Options, log *slog.Logger) error
type MachineNotFoundError
- func (e *MachineNotFoundError) Error() string
type MachineStore
- func NewConfigMapMachineStore(kubeClient kubernetes.Interface, namespace, name string) MachineStore
type Options
type Server
- func NewServer(log *slog.Logger, machines MachineStore) *Server
- func (s *Server) Handler() http.Handler

Constants ¶

View Source

const (
	DefaultListenAddress             = ":8080"
	DefaultShutdownTimeout           = 15 * time.Second
	DefaultBootstrapGroup            = "system:bootstrappers:aks-flex-node"
	DefaultDaemonGroup               = "aks-flex-node-daemons"
	DefaultMachineConfigMapNamespace = "kube-system"
	DefaultMachineConfigMapName      = "aks-flex-machines"
)

Variables ¶

This section is empty.

Functions ¶

func Run ¶

func Run(ctx context.Context, opts Options, log *slog.Logger) error

Types ¶

type MachineNotFoundError ¶

type MachineNotFoundError struct {
	Name string
}

func (*MachineNotFoundError) Error ¶

func (e *MachineNotFoundError) Error() string

type MachineStore ¶

type MachineStore interface {
	Get(ctx context.Context, machineName string) (armcontainerservice.Machine, error)
}

func NewConfigMapMachineStore ¶

func NewConfigMapMachineStore(kubeClient kubernetes.Interface, namespace, name string) MachineStore

type Options ¶

type Options struct {
	ListenAddress             string
	ShutdownTimeout           time.Duration
	Kubeconfig                string
	MachineConfigMapNamespace string
	MachineConfigMapName      string
	EnableCSRApprover         bool
	BootstrapGroup            string
	DaemonGroup               string
	MaxExpirationSeconds      int32
}

type Server ¶

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

func NewServer ¶

func NewServer(log *slog.Logger, machines MachineStore) *Server

func (*Server) Handler ¶

func (s *Server) Handler() http.Handler

Source Files ¶

View all Source files

server.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL