metal

Documentation

Index

• type MetalService
  • func New(client metalgo.Client, k8sclient clientset.Interface, projectID string) *MetalService
  • func (ms *MetalService) AllocateIP(ctx context.Context, svc v1.Service, ...) (*models.V1IPResponse, error)
  • func (ms *MetalService) FindClusterIPs(ctx context.Context, projectID, clusterID string) ([]*models.V1IPResponse, error)
  • func (ms *MetalService) FindProjectIP(ctx context.Context, projectID, ip string) (*models.V1IPResponse, error)
  • func (ms *MetalService) FindProjectIPsWithTag(ctx context.Context, projectID, tag string) ([]*models.V1IPResponse, error)
  • func (ms *MetalService) FreeIP(ctx context.Context, ip string) error
  • func (ms *MetalService) GetMachineFromNode(ctx context.Context, node *v1.Node) (*models.V1MachineResponse, error)
  • func (ms *MetalService) GetMachineFromNodeName(ctx context.Context, nodeName types.NodeName) (*models.V1MachineResponse, error)
  • func (ms *MetalService) GetMachineFromProviderID(ctx context.Context, providerID string) (*models.V1MachineResponse, error)
  • func (ms *MetalService) GetMachinesFromNodes(ctx context.Context, nodes []v1.Node) ([]*models.V1MachineResponse, error)
  • func (ms *MetalService) UpdateIP(ctx context.Context, body *models.V1IPUpdateRequest) (*models.V1IPResponse, error)
  • func (ms *MetalService) UpdateMachineTags(m *string, tags []string) error

Types

type MetalService

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

func New

func New(client metalgo.Client, k8sclient clientset.Interface, projectID string) *MetalService

func (*MetalService) AllocateIP

func (ms *MetalService) AllocateIP(ctx context.Context, svc v1.Service, namePrefix, project, network, clusterID string) (*models.V1IPResponse, error)

AllocateIP acquires an IP within the given network for a given project.

func (*MetalService) FindClusterIPs

func (ms *MetalService) FindClusterIPs(ctx context.Context, projectID, clusterID string) ([]*models.V1IPResponse, error)

FindClusterIPs returns the allowed IPs of the given cluster.

func (*MetalService) FindProjectIP

func (ms *MetalService) FindProjectIP(ctx context.Context, projectID, ip string) (*models.V1IPResponse, error)

FindProjectIP returns the IP

func (*MetalService) FindProjectIPsWithTag

func (ms *MetalService) FindProjectIPsWithTag(ctx context.Context, projectID, tag string) ([]*models.V1IPResponse, error)

FindProjectIPsWithTag returns the IPs of the given project that also have the given tag.

func (*MetalService) FreeIP

func (ms *MetalService) FreeIP(ctx context.Context, ip string) error

FreeIP frees the given IP address.

func (*MetalService) GetMachineFromNode

func (ms *MetalService) GetMachineFromNode(ctx context.Context, node *v1.Node) (*models.V1MachineResponse, error)

GetMachineFromNode try providerID first, otherwise node.Name to fetch the machine.

func (*MetalService) GetMachineFromNodeName

func (ms *MetalService) GetMachineFromNodeName(ctx context.Context, nodeName types.NodeName) (*models.V1MachineResponse, error)

GetMachineFromNodeName returns a machine where hostname matches the kubernetes node.Name.

func (*MetalService) GetMachineFromProviderID

func (ms *MetalService) GetMachineFromProviderID(ctx context.Context, providerID string) (*models.V1MachineResponse, error)

GetMachineFromProviderID uses providerID to get the machine id and returns the machine.

func (*MetalService) GetMachinesFromNodes

func (ms *MetalService) GetMachinesFromNodes(ctx context.Context, nodes []v1.Node) ([]*models.V1MachineResponse, error)

GetMachinesFromNodes gets metal machines from K8s nodes.

func (*MetalService) UpdateIP

func (ms *MetalService) UpdateIP(ctx context.Context, body *models.V1IPUpdateRequest) (*models.V1IPResponse, error)

UpdateIP updates the given IP address.

func (*MetalService) UpdateMachineTags

func (ms *MetalService) UpdateMachineTags(m *string, tags []string) error

UpdateMachineTags sets the machine tags.