mqfs

Documentation

Overview

Package mqfs provides a filesystem implementation to back POSIX message queues.

Index

• Constants
• type FilesystemType
  • func (ft FilesystemType) GetFilesystem(ctx context.Context, vfsObj *vfs.VirtualFilesystem, creds *auth.Credentials, ...) (*vfs.Filesystem, *vfs.Dentry, error)
  • func (FilesystemType) Name() string
  • func (FilesystemType) Release(ctx context.Context)
• type RegistryImpl
  • func NewRegistryImpl(ctx context.Context, vfsObj *vfs.VirtualFilesystem, creds *auth.Credentials) (*RegistryImpl, error)
  • func (r *RegistryImpl) Destroy(ctx context.Context)
  • func (r *RegistryImpl) Get(ctx context.Context, name string, access mq.AccessType, block bool, ...) (*vfs.FileDescription, bool, error)
  • func (r *RegistryImpl) New(ctx context.Context, name string, q *mq.Queue, access mq.AccessType, ...) (*vfs.FileDescription, error)
  • func (r *RegistryImpl) Unlink(ctx context.Context, name string) error

Constants

const (
	// Name is the user-visible filesystem name.
	Name = "mqueue"
)

Types

type FilesystemType

type FilesystemType struct{}

FilesystemType implements vfs.FilesystemType.

+stateify savable

func (FilesystemType) GetFilesystem

func (ft FilesystemType) GetFilesystem(ctx context.Context, vfsObj *vfs.VirtualFilesystem, creds *auth.Credentials, source string, opts vfs.GetFilesystemOptions) (*vfs.Filesystem, *vfs.Dentry, error)

GetFilesystem implements vfs.FilesystemType.GetFilesystem.

func (FilesystemType) Name

func (FilesystemType) Name() string

Name implements vfs.FilesystemType.Name.

func (FilesystemType) Release

func (FilesystemType) Release(ctx context.Context)

Release implements vfs.FilesystemType.Release.

type RegistryImpl

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

RegistryImpl implements mq.RegistryImpl. It implements the interface using the message queue filesystem, and is provided to mq.Registry at initialization.

RegistryImpl is not thread-safe, so it is the responsibility of the user (the containing mq.Registry) to protect using a lock.

+stateify savable

func NewRegistryImpl

func NewRegistryImpl(ctx context.Context, vfsObj *vfs.VirtualFilesystem, creds *auth.Credentials) (*RegistryImpl, error)

NewRegistryImpl returns a new, initialized RegistryImpl, and takes a reference on root.

func (*RegistryImpl) Destroy

func (r *RegistryImpl) Destroy(ctx context.Context)

Destroy implements mq.RegistryImpl.Destroy.

func (*RegistryImpl) Get

func (r *RegistryImpl) Get(ctx context.Context, name string, access mq.AccessType, block bool, flags uint32) (*vfs.FileDescription, bool, error)

Get implements mq.RegistryImpl.Get.

func (*RegistryImpl) New

func (r *RegistryImpl) New(ctx context.Context, name string, q *mq.Queue, access mq.AccessType, block bool, perm linux.FileMode, flags uint32) (*vfs.FileDescription, error)

New implements mq.RegistryImpl.New.

func (*RegistryImpl) Unlink

func (r *RegistryImpl) Unlink(ctx context.Context, name string) error

Unlink implements mq.RegistryImpl.Unlink.