server

Documentation

Index

• Constants
• type ShareManager
  • func NewShareManager(logger logrus.FieldLogger, volume volume.Volume) (*ShareManager, error)
  • func (m *ShareManager) GetVolume() volume.Volume
  • func (m *ShareManager) MountVolume(vol volume.Volume, devicePath, mountPath string) error
  • func (m *ShareManager) NewKubeClient() (*kubernetes.Clientset, error)
  • func (m *ShareManager) Run() error
  • func (m *ShareManager) SetShareExported(val bool)
  • func (m *ShareManager) ShareIsExported() bool
  • func (m *ShareManager) Shutdown()

Constants

const (
	UnhealthyErr = "UNHEALTHY: volume with mount path %v is unhealthy"
	ReadOnlyErr  = "READONLY: volume with mount path %v is read only"
)

const EnvKeyFastFailover = "FAST_FAILOVER"

const EnvKeyGracePeriod = "GRACE_PERIOD"

const EnvKeyLeaseLifetime = "LEASE_LIFETIME"

Types

type ShareManager

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

func NewShareManager

func NewShareManager(logger logrus.FieldLogger, volume volume.Volume) (*ShareManager, error)

func (*ShareManager) GetVolume

func (m *ShareManager) GetVolume() volume.Volume

func (*ShareManager) MountVolume

func (m *ShareManager) MountVolume(vol volume.Volume, devicePath, mountPath string) error

func (*ShareManager) NewKubeClient

func (m *ShareManager) NewKubeClient() (*kubernetes.Clientset, error)

func (*ShareManager) Run

func (m *ShareManager) Run() error

func (*ShareManager) SetShareExported

func (m *ShareManager) SetShareExported(val bool)

func (*ShareManager) ShareIsExported

func (m *ShareManager) ShareIsExported() bool

func (*ShareManager) Shutdown

func (m *ShareManager) Shutdown()