nfs

Documentation

Overview

Package nfs operator to manage NFS Server.

Portion of this file is coming from https://github.com/kubernetes-incubator/external-storage/blob/master/nfs/pkg/server/server.go

Index

• func Run(ganeshaConfig string) error
• func Setup(ganeshaConfig string) error
• func Stop()
• type FakeQuota
  • func (q *FakeQuota) CreateProjectQuota(projectsFile, directory, limit string) (string, error)
  • func (q *FakeQuota) RemoveProjectQuota(projectID uint16, projectsFile, block string) error
  • func (q *FakeQuota) RestoreProjectQuota() error
• type NFSServerReconciler
  • func (r *NFSServerReconciler) Reconcile(req ctrl.Request) (_ ctrl.Result, reterr error)
• type Operator
  • func New(context *clusterd.Context) *Operator
  • func (o *Operator) Run() error
• type Provisioner
  • func NewNFSProvisioner(clientset kubernetes.Interface, rookClientset rookclient.Interface) (*Provisioner, error)
  • func (p *Provisioner) Delete(volume *v1.PersistentVolume) error
  • func (p *Provisioner) Provision(options controller.ProvisionOptions) (*v1.PersistentVolume, error)
• type Quota
  • func (q *Quota) CreateProjectQuota(projectsFile, directory, limit string) (string, error)
  • func (q *Quota) RemoveProjectQuota(projectID uint16, projectsFile, block string) error
  • func (q *Quota) RestoreProjectQuota() error
• type Quotaer
  • func NewFakeProjectQuota() (Quotaer, error)
  • func NewProjectQuota() (Quotaer, error)
• type Webhook
  • func NewWebhook(port int, certDir string) *Webhook
  • func (w *Webhook) Run() error

Functions

func Run

func Run(ganeshaConfig string) error

Run : run the NFS server in the foreground until it exits Ideally, it should never exit when run in foreground mode We force foreground to allow the provisioner process to restart the server if it crashes - daemonization prevents us from using Wait() for this purpose

func Setup

func Setup(ganeshaConfig string) error

Setup sets up various prerequisites and settings for the server. If an error is encountered at any point it returns it instantly

func Stop

func Stop()

Stop stops the NFS server.

Types

type FakeQuota

type FakeQuota struct{}

func (*FakeQuota) CreateProjectQuota

func (q *FakeQuota) CreateProjectQuota(projectsFile, directory, limit string) (string, error)

func (*FakeQuota) RemoveProjectQuota

func (q *FakeQuota) RemoveProjectQuota(projectID uint16, projectsFile, block string) error

func (*FakeQuota) RestoreProjectQuota

func (q *FakeQuota) RestoreProjectQuota() error

type NFSServerReconciler

type NFSServerReconciler struct {
	client.Client
	Context  *clusterd.Context
	Scheme   *runtime.Scheme
	Log      *capnslog.PackageLogger
	Recorder record.EventRecorder
}

func (*NFSServerReconciler) Reconcile

func (r *NFSServerReconciler) Reconcile(req ctrl.Request) (_ ctrl.Result, reterr error)

type Operator

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

Operator type for managing NFS Server.

func New

func New(context *clusterd.Context) *Operator

New creates an operator instance.

func (*Operator) Run

func (o *Operator) Run() error

Run the operator instance.

type Provisioner

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

func NewNFSProvisioner

func NewNFSProvisioner(clientset kubernetes.Interface, rookClientset rookclient.Interface) (*Provisioner, error)

NewNFSProvisioner returns an instance of nfsProvisioner

func (*Provisioner) Delete

func (p *Provisioner) Delete(volume *v1.PersistentVolume) error

func (*Provisioner) Provision

func (p *Provisioner) Provision(options controller.ProvisionOptions) (*v1.PersistentVolume, error)

type Quota

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

func (*Quota) CreateProjectQuota

func (q *Quota) CreateProjectQuota(projectsFile, directory, limit string) (string, error)

func (*Quota) RemoveProjectQuota

func (q *Quota) RemoveProjectQuota(projectID uint16, projectsFile, block string) error

func (*Quota) RestoreProjectQuota

func (q *Quota) RestoreProjectQuota() error

type Quotaer

type Quotaer interface {
	CreateProjectQuota(projectsFile, directory, limit string) (string, error)
	RemoveProjectQuota(projectID uint16, projectsFile, block string) error
	RestoreProjectQuota() error
}

func NewFakeProjectQuota

func NewFakeProjectQuota() (Quotaer, error)

func NewProjectQuota

func NewProjectQuota() (Quotaer, error)

type Webhook

type Webhook struct {
	Port    int
	CertDir string
}

func NewWebhook

func NewWebhook(port int, certDir string) *Webhook

func (*Webhook) Run

func (w *Webhook) Run() error