fuse

Documentation

Index

• Constants
• func CreateAllowedExecutablesDiffs(executablesDiffs map[string]*api.ExecutablesDiffs) map[string]*AllowedExecutablesDiffs
• func NewLoopbackDirStream(name string) (fs.DirStream, syscall.Errno)
• func NewVolumeControlFile(fd int, path string, rootData *volumeControlRoot) fs.FileHandle
• type AllowedExecutables
  • func CreateAllowedExecutables(lifetimeExecutables map[string]*api.Executable) AllowedExecutables
  • func CreateAllowedExecutablesForExternalAllowedExecutables(executables []*api.ExternalAllowedExecutable) AllowedExecutables
• type AllowedExecutablesDiffs
• type ContainerRoot
• type ContainerRootString
• type ContainerRoots
• type FuseOptions
  • func NewFuseOptions() *FuseOptions
  • func (fo *FuseOptions) AddFlags(flagSet *pflag.FlagSet)
• type FuseVolumeController
  • func NewFuseController(mountPoint string, sourcePath string, debug bool, disableUsageControl bool, ...) (*FuseVolumeController, error)
  • func (fvc *FuseVolumeController) AddAllowedExecutables(mountNamespace string, rootPath string, executables AllowedExecutables) error
  • func (fvc *FuseVolumeController) AddMessageQueueUpdatePublisher(messageQueue *api.MessageQueue, volumeRootPath string, ...) error
  • func (fvc *FuseVolumeController) DeleteAllowedExecutables(mountNamespace string, executablePaths []string) error
  • func (fvc *FuseVolumeController) DeleteMessageQueueUpdatePublisher(mountNamespaces []string) error
  • func (fvc *FuseVolumeController) GetContainerRootString(mountNamespace string) ContainerRootString
  • func (fvc *FuseVolumeController) GetContainerRootsNamespaces() map[string]struct{}
  • func (fvc *FuseVolumeController) Unmount() error
  • func (fvc *FuseVolumeController) UpdateAllowedExecutables(mountNamespace string, executables AllowedExecutables) error
  • func (fvc *FuseVolumeController) Wait()
• type PublishingContainers

Constants

const (
	AllowedExecutableChecksumKey = "checksum"
	AllowedExecutableWritableKey = "writable"
)

Functions

func CreateAllowedExecutablesDiffs

func CreateAllowedExecutablesDiffs(
	executablesDiffs map[string]*api.ExecutablesDiffs) map[string]*AllowedExecutablesDiffs

func NewLoopbackDirStream

func NewLoopbackDirStream(name string) (fs.DirStream, syscall.Errno)

NewLoopbackDirStream open a directory for reading as a DirStream

func NewVolumeControlFile

func NewVolumeControlFile(
	fd int, path string, rootData *volumeControlRoot) fs.FileHandle

Types

type AllowedExecutables

type AllowedExecutables map[string]*allowedExecutable

key: executable path

func CreateAllowedExecutables

func CreateAllowedExecutables(
	lifetimeExecutables map[string]*api.Executable) AllowedExecutables

func CreateAllowedExecutablesForExternalAllowedExecutables

func CreateAllowedExecutablesForExternalAllowedExecutables(
	executables []*api.ExternalAllowedExecutable) AllowedExecutables

type AllowedExecutablesDiffs

type AllowedExecutablesDiffs struct {
	AddedAndUpdated AllowedExecutables
	DeletedPaths    []string
}

type ContainerRoot

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

type ContainerRootString

type ContainerRootString struct {
	RootPath           string
	AllowedExecutables map[string]map[string]string
}

type ContainerRoots

type ContainerRoots map[string]*ContainerRoot

key: mount namespace, [TODO] update

type FuseOptions

type FuseOptions struct {
	MountPointsHostRootDirectory string
	Debug                        bool
	ChecksumCalculationAlways    bool
}

func NewFuseOptions

func NewFuseOptions() *FuseOptions

func (*FuseOptions) AddFlags

func (fo *FuseOptions) AddFlags(flagSet *pflag.FlagSet)

type FuseVolumeController

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

func NewFuseController

func NewFuseController(
	mountPoint string, sourcePath string, debug bool, disableUsageControl bool,
	checksumCalculationAlways bool, stopCh <-chan struct{}) (
	*FuseVolumeController, error)

func (*FuseVolumeController) AddAllowedExecutables

func (fvc *FuseVolumeController) AddAllowedExecutables(
	mountNamespace string, rootPath string,
	executables AllowedExecutables) error

func (*FuseVolumeController) AddMessageQueueUpdatePublisher

func (fvc *FuseVolumeController) AddMessageQueueUpdatePublisher(
	messageQueue *api.MessageQueue, volumeRootPath string,
	mountNamespaces []string) error

func (*FuseVolumeController) DeleteAllowedExecutables

func (fvc *FuseVolumeController) DeleteAllowedExecutables(
	mountNamespace string, executablePaths []string) error

func (*FuseVolumeController) DeleteMessageQueueUpdatePublisher

func (fvc *FuseVolumeController) DeleteMessageQueueUpdatePublisher(
	mountNamespaces []string) error

func (*FuseVolumeController) GetContainerRootString

func (fvc *FuseVolumeController) GetContainerRootString(
	mountNamespace string) ContainerRootString

used by only test cases in <pkg/controller/volumecontrol/volume_controller_test.go>

func (*FuseVolumeController) GetContainerRootsNamespaces

func (fvc *FuseVolumeController) GetContainerRootsNamespaces() map[string]struct{}

func (*FuseVolumeController) Unmount

func (fvc *FuseVolumeController) Unmount() error

func (*FuseVolumeController) UpdateAllowedExecutables

func (fvc *FuseVolumeController) UpdateAllowedExecutables(
	mountNamespace string, executables AllowedExecutables) error

func (*FuseVolumeController) Wait

func (fvc *FuseVolumeController) Wait()

type PublishingContainers

type PublishingContainers map[string]struct{}

key: mount namespace