seqfile

Documentation

Index

• func NewSeqFileInode(ctx context.Context, source SeqSource, msrc *fs.MountSource) *fs.Inode
• type SeqData
• type SeqFile
  • func NewSeqFile(ctx context.Context, source SeqSource) *SeqFile
  • func (s *SeqFile) DeprecatedPreadv(ctx context.Context, dst usermem.IOSequence, offset int64) (int64, error)
  • func (*SeqFile) DeprecatedPwritev(context.Context, usermem.IOSequence, int64) (int64, error)
  • func (s *SeqFile) UnstableAttr(ctx context.Context, inode *fs.Inode) (fs.UnstableAttr, error)
• type SeqGenerationCounter
  • func (s *SeqGenerationCounter) Generation() int64
  • func (s *SeqGenerationCounter) IsCurrent(generation int64) bool
  • func (s *SeqGenerationCounter) SetGeneration(generation int64)
  • func (s *SeqGenerationCounter) Update()
• type SeqHandle
• type SeqSource

Functions

func NewSeqFileInode

func NewSeqFileInode(ctx context.Context, source SeqSource, msrc *fs.MountSource) *fs.Inode

NewSeqFileInode returns an Inode with SeqFile InodeOperations.

Types

type SeqData

type SeqData struct {
	// The data to be returned to the user.
	Buf []byte

	// A seek handle used to find the next valid unit in ReadSeqFiledata.
	Handle SeqHandle
}

SeqData holds the data for one unit in the file.

type SeqFile

type SeqFile struct {
	ramfs.Entry

	SeqSource
	// contains filtered or unexported fields
}

SeqFile is used to provide dynamic files that can be ordered by record.

func NewSeqFile

func NewSeqFile(ctx context.Context, source SeqSource) *SeqFile

NewSeqFile returns a seqfile suitable for use by external consumers.

func (*SeqFile) DeprecatedPreadv

func (s *SeqFile) DeprecatedPreadv(ctx context.Context, dst usermem.IOSequence, offset int64) (int64, error)

DeprecatedPreadv reads from the file at the given offset.

func (*SeqFile) DeprecatedPwritev

func (*SeqFile) DeprecatedPwritev(context.Context, usermem.IOSequence, int64) (int64, error)

DeprecatedPwritev is always denied.

func (*SeqFile) UnstableAttr

func (s *SeqFile) UnstableAttr(ctx context.Context, inode *fs.Inode) (fs.UnstableAttr, error)

UnstableAttr returns unstable attributes of the SeqFile.

type SeqGenerationCounter

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

SeqGenerationCounter is a counter to keep track if the SeqSource should be updated. SeqGenerationCounter is not thread-safe and should be protected with a mutex.

func (*SeqGenerationCounter) Generation

func (s *SeqGenerationCounter) Generation() int64

Generation returns the current generation counter.

func (*SeqGenerationCounter) IsCurrent

func (s *SeqGenerationCounter) IsCurrent(generation int64) bool

IsCurrent returns whether the given generation is current or not.

func (*SeqGenerationCounter) SetGeneration

func (s *SeqGenerationCounter) SetGeneration(generation int64)

SetGeneration sets the generation to the new value, be careful to not set it to a value less than current.

func (*SeqGenerationCounter) Update

func (s *SeqGenerationCounter) Update()

Update increments the current generation.

type SeqHandle

type SeqHandle interface{}

SeqHandle is a helper handle to seek in the file.

type SeqSource

type SeqSource interface {
	// NeedsUpdate returns true if the consumer of SeqData should call
	// ReadSeqFileData again. Generation is the generation returned by
	// ReadSeqFile or 0.
	NeedsUpdate(generation int64) bool

	// Returns a slice of SeqData ordered by unit and the current
	// generation. The first entry in the slice is greater than the handle.
	// If handle is nil then all known records are returned. Generation
	// must always be greater than 0.
	ReadSeqFileData(handle SeqHandle) ([]SeqData, int64)
}

SeqSource is a data source for a SeqFile file.