attachment

Documentation

Overview

Package attachment to manage Kubernetes storage attach events.

Index

• Constants
• Variables
• type Attachment
  • func New(context *clusterd.Context) (Attachment, error)
• type MockAttachment
  • func (m *MockAttachment) Create(volumeAttachment *rookalpha.Volume) error
  • func (m *MockAttachment) Delete(namespace, name string) error
  • func (m *MockAttachment) Get(namespace, name string) (*rookalpha.Volume, error)
  • func (m *MockAttachment) List(namespace string) (*rookalpha.VolumeList, error)
  • func (m *MockAttachment) Update(volumeAttachment *rookalpha.Volume) error

Constants

const (
	CustomResourceName       = "volume"
	CustomResourceNamePlural = "volumes"
)

Variables

var VolumeResource = k8sutil.CustomResource{
	Name:    CustomResourceName,
	Plural:  CustomResourceNamePlural,
	Group:   rook.CustomResourceGroupName,
	Version: rookalpha.Version,
	Kind:    reflect.TypeOf(rookalpha.Volume{}).Name(),
}

VolumeResource represents the Volume custom resource object

Types

type Attachment

type Attachment interface {
	Create(volumeAttachment *rookalpha.Volume) error
	Get(namespace, name string) (*rookalpha.Volume, error)
	List(namespace string) (*rookalpha.VolumeList, error)
	Update(volumeAttachment *rookalpha.Volume) error
	Delete(namespace, name string) error
}

Attachment handles custom resource Volume storage operations.

func New

func New(context *clusterd.Context) (Attachment, error)

CreateController creates a new controller for volume attachment

type MockAttachment

type MockAttachment struct {
	MockCreate func(volumeAttachment *rookalpha.Volume) error
	MockGet    func(namespace, name string) (*rookalpha.Volume, error)
	MockList   func(namespace string) (*rookalpha.VolumeList, error)
	MockUpdate func(volumeAttachment *rookalpha.Volume) error
	MockDelete func(namespace, name string) error
}

func (*MockAttachment) Create

func (m *MockAttachment) Create(volumeAttachment *rookalpha.Volume) error

func (*MockAttachment) Delete

func (m *MockAttachment) Delete(namespace, name string) error

func (*MockAttachment) Get

func (m *MockAttachment) Get(namespace, name string) (*rookalpha.Volume, error)

func (*MockAttachment) List

func (m *MockAttachment) List(namespace string) (*rookalpha.VolumeList, error)

func (*MockAttachment) Update

func (m *MockAttachment) Update(volumeAttachment *rookalpha.Volume) error