listenercsi

package

v0.0.0-...-763f55e Latest Latest Go to latest Published: Apr 24, 2024 License: Apache-2.0 Imports: 14 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/zncdata-labs/listener-operator

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
type CSIDriver
- func NewCSIDriver(client client.Client, cr *listenersv1alpha1.ListenerCSI) *CSIDriver
- func (r *CSIDriver) Reconcile(ctx context.Context) (ctrl.Result, error)
type DaemonSet
- func NewDaemonSet(client client.Client, cr *listenersv1alpha1.ListenerCSI, serviceAccount string) *DaemonSet
- func (r *DaemonSet) Reconcile(ctx context.Context) (ctrl.Result, error)
- func (r *DaemonSet) Satisfied(ctx context.Context) (bool, error)
type ListenerCSIReconciler
- func (r *ListenerCSIReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
- func (r *ListenerCSIReconciler) SetupWithManager(mgr ctrl.Manager) error
type ListenerClassReconciler
- func NewListenerClassReconciler(client client.Client, cr *listenersv1alpha1.ListenerCSI, name string, ...) *ListenerClassReconciler
- func (r *ListenerClassReconciler) Reconcile(ctx context.Context) (ctrl.Result, error)
type PersetListenerClass
- func NewPersetListenerClass(client client.Client, cr *listenersv1alpha1.ListenerCSI) *PersetListenerClass
- func (p *PersetListenerClass) Reconcile(ctx context.Context) (ctrl.Result, error)
type RBAC
- func NewRBAC(client client.Client, cr *listenersv1alpha1.ListenerCSI) *RBAC
- func (r *RBAC) Reconcile(ctx context.Context) (ctrl.Result, error)
type StorageClass
- func NewStorageClass(client client.Client, cr *listenersv1alpha1.ListenerCSI) *StorageClass
- func (r *StorageClass) Reconcile(ctx context.Context) (ctrl.Result, error)

Constants ¶

View Source

const (
	CSIServiceAccountName     = "listeners-csi-zncdata-labs"
	CSIClusterRoleName        = "listeners-csi-zncdata-labs"
	CSIClusterRoleBindingName = "listeners-csi-zncdata-labs"

	VolumesMountpointDirName   = "mountpoint-dir"
	VolumesPluginDirName       = "plugin-dir"
	VolumesRegistrationDirName = "registration-dir"
)

Variables ¶

View Source

var (
	ProjectRootDir = filepath.Join(
		"..",
		"..",
		"..",
	)
	CRDDirectories = filepath.Join(
		ProjectRootDir,
		"config",
		"crd",
		"bases",
	)
	LocalBin = filepath.Join(
		ProjectRootDir,
		"bin",
	)
)

Functions ¶

This section is empty.

Types ¶

type CSIDriver ¶

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

func NewCSIDriver ¶

func NewCSIDriver(client client.Client, cr *listenersv1alpha1.ListenerCSI) *CSIDriver

func (*CSIDriver) Reconcile ¶

func (r *CSIDriver) Reconcile(ctx context.Context) (ctrl.Result, error)

type DaemonSet ¶

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

func NewDaemonSet ¶

func NewDaemonSet(client client.Client, cr *listenersv1alpha1.ListenerCSI, serviceAccount string) *DaemonSet

func (*DaemonSet) Reconcile ¶

func (r *DaemonSet) Reconcile(ctx context.Context) (ctrl.Result, error)

func (*DaemonSet) Satisfied ¶

func (r *DaemonSet) Satisfied(ctx context.Context) (bool, error)

type ListenerCSIReconciler ¶

type ListenerCSIReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

ListenerCSIReconciler reconciles a ListenerCSI object

func (*ListenerCSIReconciler) Reconcile ¶

func (r *ListenerCSIReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the ListenerCSI object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.15.0/pkg/reconcile

func (*ListenerCSIReconciler) SetupWithManager ¶

func (r *ListenerCSIReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type ListenerClassReconciler ¶

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

func NewListenerClassReconciler ¶

func NewListenerClassReconciler(
	client client.Client,
	cr *listenersv1alpha1.ListenerCSI,
	name string,
	serviceType listenersv1alpha1.ServiceType,
) *ListenerClassReconciler

func (*ListenerClassReconciler) Reconcile ¶

func (r *ListenerClassReconciler) Reconcile(ctx context.Context) (ctrl.Result, error)

type PersetListenerClass ¶

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

func NewPersetListenerClass ¶

func NewPersetListenerClass(client client.Client, cr *listenersv1alpha1.ListenerCSI) *PersetListenerClass

func (*PersetListenerClass) Reconcile ¶

func (p *PersetListenerClass) Reconcile(ctx context.Context) (ctrl.Result, error)

type RBAC ¶

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

func NewRBAC ¶

func NewRBAC(client client.Client, cr *listenersv1alpha1.ListenerCSI) *RBAC

func (*RBAC) Reconcile ¶

func (r *RBAC) Reconcile(ctx context.Context) (ctrl.Result, error)

type StorageClass ¶

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

func NewStorageClass ¶

func NewStorageClass(client client.Client, cr *listenersv1alpha1.ListenerCSI) *StorageClass

func (*StorageClass) Reconcile ¶

func (r *StorageClass) Reconcile(ctx context.Context) (ctrl.Result, error)

Source Files ¶

View all Source files

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