filesystem

Documentation

Index

• type Bucket
  • func NewBucket(rootDir string, middlewares ...func(objstore.Bucket) (objstore.Bucket, error)) (*Bucket, error)
  • func (b *Bucket) Iter(ctx context.Context, dir string, f func(string) error, ...) error
  • func (b *Bucket) ReaderAt(ctx context.Context, filename string) (phlareobjstore.ReaderAtCloser, error)
  • func (b *Bucket) ReaderWithExpectedErrs(fn phlareobjstore.IsOpFailureExpectedFunc) phlareobjstore.BucketReader
  • func (b *Bucket) WithExpectedErrs(fn phlareobjstore.IsOpFailureExpectedFunc) phlareobjstore.Bucket
• type Config
  • func (cfg *Config) RegisterFlags(f *flag.FlagSet)
  • func (cfg *Config) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)
  • func (cfg *Config) RegisterFlagsWithPrefixAndDefaultDirectory(prefix, dir string, f *flag.FlagSet)
• type FileReaderAt
  • func (b *FileReaderAt) ReadAt(p []byte, off int64) (n int, err error)

Types

type Bucket

type Bucket struct {
	objstore.Bucket
	// contains filtered or unexported fields
}

func NewBucket

func NewBucket(rootDir string, middlewares ...func(objstore.Bucket) (objstore.Bucket, error)) (*Bucket, error)

NewBucket returns a new filesystem.Bucket.

func (*Bucket) Iter

func (b *Bucket) Iter(ctx context.Context, dir string, f func(string) error, options ...objstore.IterOption) error

func (*Bucket) ReaderAt

func (b *Bucket) ReaderAt(ctx context.Context, filename string) (phlareobjstore.ReaderAtCloser, error)

func (*Bucket) ReaderWithExpectedErrs

func (b *Bucket) ReaderWithExpectedErrs(fn phlareobjstore.IsOpFailureExpectedFunc) phlareobjstore.BucketReader

ReaderWithExpectedErrs implements objstore.Bucket.

func (*Bucket) WithExpectedErrs

func (b *Bucket) WithExpectedErrs(fn phlareobjstore.IsOpFailureExpectedFunc) phlareobjstore.Bucket

WithExpectedErrs implements objstore.Bucket.

type Config

type Config struct {
	Directory string `yaml:"dir"`
}

Config stores the configuration for storing and accessing objects in the local filesystem.

func (*Config) RegisterFlags

func (cfg *Config) RegisterFlags(f *flag.FlagSet)

RegisterFlags registers the flags for filesystem storage

func (*Config) RegisterFlagsWithPrefix

func (cfg *Config) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)

RegisterFlagsWithPrefix registers the flags for filesystem storage with the provided prefix

func (*Config) RegisterFlagsWithPrefixAndDefaultDirectory

func (cfg *Config) RegisterFlagsWithPrefixAndDefaultDirectory(prefix, dir string, f *flag.FlagSet)

RegisterFlagsWithPrefixAndDefaultDirectory registers the flags for filesystem storage with the provided prefix and sets the default directory to dir.

type FileReaderAt

type FileReaderAt struct {
	*os.File
}

func (*FileReaderAt) ReadAt

func (b *FileReaderAt) ReadAt(p []byte, off int64) (n int, err error)