Documentation
¶
Overview ¶
Package mqfs provides a filesystem implementation to back POSIX message queues.
Index ¶
- Constants
- type FilesystemType
- type RegistryImpl
- 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"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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.
Source Files