providers

Documentation

Index

• func CopySizeLabels(machineLabels, sizeLabels map[string]string) map[string]string
• func NetworkRedundancy(machineInterfaces []metalv1alpha4.Interface) string
• func NetworkStatus(domainMachine domain.Machine) metalv1alpha4.Network
• func UnknownPortCount(machineInterfaces []metalv1alpha4.Interface) int
• type FakeServerExecutor
  • func NewFakeServerExecutor(log logr.Logger) *FakeServerExecutor
  • func (f *FakeServerExecutor) Enable(serverInfo domain.Server) error
• type InventoryRepository
  • func NewInventoryRepository(client ctrlclient.Client, domainEventPublisher events.DomainEventPublisher) *InventoryRepository
  • func (r *InventoryRepository) ByID(id domain.InventoryID) (domain.Inventory, error)
  • func (r *InventoryRepository) ByUUID(uuid string) (domain.Inventory, error)
  • func (r *InventoryRepository) Save(inventory domain.Inventory) error
• type KubernetesInventoryIDGenerator
  • func NewKubernetesInventoryIDGenerator() *KubernetesInventoryIDGenerator
  • func (m *KubernetesInventoryIDGenerator) Generate() domain.InventoryID
• type KubernetesMachineIDGenerator
  • func NewKubernetesMachineIDGenerator() *KubernetesMachineIDGenerator
  • func (m *KubernetesMachineIDGenerator) Generate() domain.MachineID
• type LoopbackAddressRepository
  • func NewLoopbackAddressRepository(client ctrlclient.Client) *LoopbackAddressRepository
  • func (l *LoopbackAddressRepository) IPv4ByMachineUUID(uuid string) (domain.Address, error)
  • func (l *LoopbackAddressRepository) IPv6ByMachineUUID(uuid string) (domain.Address, error)
  • func (l *LoopbackAddressRepository) Save(address domain.Address) error
  • func (l *LoopbackAddressRepository) Try(times int) providers.LoopbackAddressExtractor
• type LoopbackSubnetRepository
  • func NewLoopbackSubnetRepository(client ctrlclient.Client, subnetLabelValue string) *LoopbackSubnetRepository
  • func (s *LoopbackSubnetRepository) ByType(ipType string) (dto.SubnetInfo, error)
  • func (s *LoopbackSubnetRepository) IPv6ByName(name string) (dto.SubnetInfo, error)
  • func (s *LoopbackSubnetRepository) Save(info dto.SubnetInfo) error
• type MachineRepository
  • func NewMachineRepository(client ctrlclient.Client, domainEventPublisher events.DomainEventPublisher) *MachineRepository
  • func (r *MachineRepository) ByID(id domain.MachineID) (domain.Machine, error)
  • func (r *MachineRepository) ByUUID(uuid string) (domain.Machine, error)
  • func (r *MachineRepository) Create(machine domain.Machine) error
  • func (r *MachineRepository) Save(machine domain.Machine) error
  • func (r *MachineRepository) Update(machine domain.Machine) error
• type ServerRepository
  • func NewServerRepository(client ctrlclient.Client) *ServerRepository
  • func (s *ServerRepository) ByUUID(uuid string) (domain.Server, error)
  • func (s *ServerRepository) Get(request dto.Request) (domain.Server, error)
• type SwitchRepository
  • func NewSwitchRepository(client ctrlclient.Client) *SwitchRepository
  • func (s *SwitchRepository) ByChassisID(chassisID string) (dto.SwitchInfo, error)

Functions

func CopySizeLabels

func CopySizeLabels(
	machineLabels, sizeLabels map[string]string,
) map[string]string

func NetworkRedundancy

func NetworkRedundancy(
	machineInterfaces []metalv1alpha4.Interface,
) string

func NetworkStatus

func NetworkStatus(
	domainMachine domain.Machine,
) metalv1alpha4.Network

func UnknownPortCount

func UnknownPortCount(machineInterfaces []metalv1alpha4.Interface) int

Types

type FakeServerExecutor

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

func NewFakeServerExecutor

func NewFakeServerExecutor(log logr.Logger) *FakeServerExecutor

func (*FakeServerExecutor) Enable

func (f *FakeServerExecutor) Enable(serverInfo domain.Server) error

type InventoryRepository

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

func NewInventoryRepository

func NewInventoryRepository(
	client ctrlclient.Client,
	domainEventPublisher events.DomainEventPublisher,
) *InventoryRepository

func (*InventoryRepository) ByID

func (r *InventoryRepository) ByID(id domain.InventoryID) (domain.Inventory, error)

func (*InventoryRepository) ByUUID

func (r *InventoryRepository) ByUUID(uuid string) (domain.Inventory, error)

func (*InventoryRepository) Save

func (r *InventoryRepository) Save(inventory domain.Inventory) error

type KubernetesInventoryIDGenerator

type KubernetesInventoryIDGenerator struct{}

func NewKubernetesInventoryIDGenerator

func NewKubernetesInventoryIDGenerator() *KubernetesInventoryIDGenerator

func (*KubernetesInventoryIDGenerator) Generate

func (m *KubernetesInventoryIDGenerator) Generate() domain.InventoryID

type KubernetesMachineIDGenerator

type KubernetesMachineIDGenerator struct{}

func NewKubernetesMachineIDGenerator

func NewKubernetesMachineIDGenerator() *KubernetesMachineIDGenerator

func (*KubernetesMachineIDGenerator) Generate

func (m *KubernetesMachineIDGenerator) Generate() domain.MachineID

type LoopbackAddressRepository

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

func NewLoopbackAddressRepository

func NewLoopbackAddressRepository(
	client ctrlclient.Client,
) *LoopbackAddressRepository

func (*LoopbackAddressRepository) IPv4ByMachineUUID

func (l *LoopbackAddressRepository) IPv4ByMachineUUID(
	uuid string,
) (domain.Address, error)

func (*LoopbackAddressRepository) IPv6ByMachineUUID

func (l *LoopbackAddressRepository) IPv6ByMachineUUID(
	uuid string,
) (domain.Address, error)

func (*LoopbackAddressRepository) Save

func (l *LoopbackAddressRepository) Save(address domain.Address) error

func (*LoopbackAddressRepository) Try

func (l *LoopbackAddressRepository) Try(times int) providers.LoopbackAddressExtractor

type LoopbackSubnetRepository

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

func NewLoopbackSubnetRepository

func NewLoopbackSubnetRepository(
	client ctrlclient.Client,
	subnetLabelValue string,
) *LoopbackSubnetRepository

func (*LoopbackSubnetRepository) ByType

func (s *LoopbackSubnetRepository) ByType(ipType string) (dto.SubnetInfo, error)

func (*LoopbackSubnetRepository) IPv6ByName

func (s *LoopbackSubnetRepository) IPv6ByName(name string) (dto.SubnetInfo, error)

func (*LoopbackSubnetRepository) Save

func (s *LoopbackSubnetRepository) Save(info dto.SubnetInfo) error

type MachineRepository

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

func NewMachineRepository

func NewMachineRepository(
	client ctrlclient.Client,
	domainEventPublisher events.DomainEventPublisher,
) *MachineRepository

func (*MachineRepository) ByID

func (r *MachineRepository) ByID(id domain.MachineID) (domain.Machine, error)

func (*MachineRepository) ByUUID

func (r *MachineRepository) ByUUID(uuid string) (domain.Machine, error)

func (*MachineRepository) Create

func (r *MachineRepository) Create(machine domain.Machine) error

func (*MachineRepository) Save

func (r *MachineRepository) Save(machine domain.Machine) error

func (*MachineRepository) Update

func (r *MachineRepository) Update(machine domain.Machine) error

type ServerRepository

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

func NewServerRepository

func NewServerRepository(
	client ctrlclient.Client,
) *ServerRepository

func (*ServerRepository) ByUUID

func (s *ServerRepository) ByUUID(
	uuid string,
) (domain.Server, error)

func (*ServerRepository) Get

func (s *ServerRepository) Get(
	request dto.Request,
) (domain.Server, error)

type SwitchRepository

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

func NewSwitchRepository

func NewSwitchRepository(
	client ctrlclient.Client,
) *SwitchRepository

func (*SwitchRepository) ByChassisID

func (s *SwitchRepository) ByChassisID(chassisID string) (dto.SwitchInfo, error)