controller

package

v1.0.0 Latest Latest Go to latest Published: Oct 2, 2023 License: Apache-2.0 Imports: 29 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/piraeusdatastore/linstor-affinity-controller

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func AffinityMatchesTopology(affinity *corev1.VolumeNodeAffinity, topos []*csi.Topology) bool
func ApplyAffinity(topos []*csi.Topology) *applyv1core.VolumeNodeAffinityApplyConfiguration
func ApplyCSI(csi *corev1.CSIPersistentVolumeSource) *applyv1core.CSIPersistentVolumeSourceApplyConfiguration
func ApplyClaimRef(reference *corev1.ObjectReference) *applyv1core.ObjectReferenceApplyConfiguration
func ApplySecretRef(ref *corev1.SecretReference) *applyv1core.SecretReferenceApplyConfiguration
func EqualSelection(segments map[string]string, term corev1.NodeSelectorTerm) bool
func IndexByResourceDefinition(obj interface{}) ([]string, error)
func KLogV(level klog.Level) client.Logger
type AffinityReconciler
- func NewReconciler(cfg *Config) (*AffinityReconciler, error)
- func (a *AffinityReconciler) Run(ctx context.Context) error
type Config

Constants ¶

View Source

const (
	SavedPVPropKey = linstor.NamespcAuxiliary + "/affinity-updater-saved-pv"
)

Variables ¶

This section is empty.

Functions ¶

func AffinityMatchesTopology ¶

func AffinityMatchesTopology(affinity *corev1.VolumeNodeAffinity, topos []*csi.Topology) bool

func ApplyAffinity ¶

func ApplyAffinity(topos []*csi.Topology) *applyv1core.VolumeNodeAffinityApplyConfiguration

func ApplyCSI ¶

func ApplyCSI(csi *corev1.CSIPersistentVolumeSource) *applyv1core.CSIPersistentVolumeSourceApplyConfiguration

func ApplyClaimRef ¶

func ApplyClaimRef(reference *corev1.ObjectReference) *applyv1core.ObjectReferenceApplyConfiguration

func ApplySecretRef ¶

func ApplySecretRef(ref *corev1.SecretReference) *applyv1core.SecretReferenceApplyConfiguration

func EqualSelection ¶

func EqualSelection(segments map[string]string, term corev1.NodeSelectorTerm) bool

func IndexByResourceDefinition ¶

func IndexByResourceDefinition(obj interface{}) ([]string, error)

func KLogV ¶

func KLogV(level klog.Level) client.Logger

Types ¶

type AffinityReconciler ¶

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

func NewReconciler ¶

func NewReconciler(cfg *Config) (*AffinityReconciler, error)

func (*AffinityReconciler) Run ¶

func (a *AffinityReconciler) Run(ctx context.Context) error

type Config ¶

type Config struct {
	RestCfg           *rest.Config
	ReconcileRate     time.Duration
	ResyncRate        time.Duration
	Timeout           time.Duration
	LeaderElector     *leaderelection.LeaderElector
	BindAddress       string
	PropertyNamespace string
}

Source Files ¶

View all Source files

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