util

Documentation

Index

• Constants
• func CheckNamespacedName(name string) bool
• func CountIP(r *allocator.Range) int64
• func Filter[T any](ss []T, test func(T) bool) (ret []T)
• func GetHarvesterClientFromSecret(secret *corev1.Secret) (*hvclientset.Clientset, error)
• func GetNamespacedName(name string, alternativeTargetNS string) (error, types.NamespacedName)
• func GetSecretForHarvesterConfig(ctx context.Context, cluster *infrav1.HarvesterCluster, cl client.Client) (*corev1.Secret, error)
• func Healthcheck(config *clientcmdapi.Config) (bool, error)
• func MakeRange(r *lbv1beta1.Range) (*allocator.Range, error)
• func MergeCloudInitData(cloudInits ...string) ([]byte, error)
• func NewTrue() *bool
• func RandomID() string
• type Store
  • func NewStore(pool *lbv1beta1.IPPool) *Store
  • func (s *Store) Close() error
  • func (s *Store) GetByID(id string, _ string) []net.IP
  • func (s *Store) LastReservedIP(rangeID string) (net.IP, error)
  • func (s *Store) Lock() error
  • func (s *Store) Release(ip net.IP) error
  • func (s *Store) ReleaseByID(id string, _ string) error
  • func (s *Store) Reserve(id, _ string, ip net.IP, _ string) (bool, error)
  • func (s *Store) Unlock() error

Constants

const (
	ConfigSecretDataKey = "kubeconfig"
)

Functions

func CheckNamespacedName

func CheckNamespacedName(name string) bool

CheckNamespacedName checks if the given string is in the format of "namespace/name".

func CountIP

func CountIP(r *allocator.Range) int64

func Filter

func Filter[T any](ss []T, test func(T) bool) (ret []T)

Filter is a generic filter function.

func GetHarvesterClientFromSecret

func GetHarvesterClientFromSecret(secret *corev1.Secret) (*hvclientset.Clientset, error)

func GetNamespacedName

func GetNamespacedName(name string, alternativeTargetNS string) (error, types.NamespacedName)

GetNamespacedName returns the namespace and name from the given string in the format of "namespace/name".

func GetSecretForHarvesterConfig

func GetSecretForHarvesterConfig(ctx context.Context, cluster *infrav1.HarvesterCluster, cl client.Client) (*corev1.Secret, error)

func Healthcheck

func Healthcheck(config *clientcmdapi.Config) (bool, error)

func MakeRange

func MakeRange(r *lbv1beta1.Range) (*allocator.Range, error)

func MergeCloudInitData

func MergeCloudInitData(cloudInits ...string) ([]byte, error)

func NewTrue

func NewTrue() *bool

NewTrue returns a pointer to true.

func RandomID

func RandomID() string

RandomID returns a random string used as an ID internally in Harvester.

Types

type Store

type Store struct {
	// IPPool is the pool of IP addresses.
	*lbv1beta1.IPPool
}

Store implements the backend.Store interface.

func NewStore

func NewStore(pool *lbv1beta1.IPPool) *Store

New creates a new store.

func (*Store) Close

func (s *Store) Close() error

func (*Store) GetByID

func (s *Store) GetByID(id string, _ string) []net.IP

func (*Store) LastReservedIP

func (s *Store) LastReservedIP(rangeID string) (net.IP, error)

func (*Store) Lock

func (s *Store) Lock() error

Lock locks the store.

func (*Store) Release

func (s *Store) Release(ip net.IP) error

func (*Store) ReleaseByID

func (s *Store) ReleaseByID(id string, _ string) error

func (*Store) Reserve

func (s *Store) Reserve(id, _ string, ip net.IP, _ string) (bool, error)

func (*Store) Unlock

func (s *Store) Unlock() error