awsfs

Documentation

Index

• Variables
• func GetParentDirPath(path string) string
• type Entry
• type EntryType
• type FileInfo
  • func (f FileInfo) IsDir() bool
  • func (f FileInfo) ModTime() time.Time
  • func (f FileInfo) Mode() fs.FileMode
  • func (f FileInfo) Name() string
  • func (f FileInfo) Size() int64
  • func (f FileInfo) Sys() any
• type FileReader
  • func (f FileReader) Close() error
  • func (f FileReader) Read(p []byte) (n int, err error)
  • func (f FileReader) Readdir(count int) ([]fs.FileInfo, error)
  • func (f FileReader) Seek(offset int64, whence int) (int64, error)
  • func (f FileReader) Stat() (fs.FileInfo, error)
  • func (f FileReader) Write(p []byte) (n int, err error)
• type MetadataStore
  • func (m MetadataStore) AddEntry(ctx context.Context, entry Entry, path string) error
  • func (m MetadataStore) AddReference(ctx context.Context, ref Reference) error
  • func (m MetadataStore) DeleteEntries(ctx context.Context, ids []string, ref Reference) error
  • func (m MetadataStore) GetEntriesByParentID(ctx context.Context, id string) ([]Entry, error)
  • func (m MetadataStore) GetEntry(ctx context.Context, id string) (Entry, error)
  • func (m MetadataStore) GetReference(ctx context.Context, id string) (Reference, error)
  • func (m MetadataStore) Init(ctx context.Context) error
  • func (m MetadataStore) UpdateEntryName(ctx context.Context, entry Entry, ref Reference) error
• type PhysicalStore
  • func (s PhysicalStore) GetObject(ctx context.Context, objectKey string) (io.ReadCloser, error)
  • func (s PhysicalStore) PutObject(ctx context.Context, objectKey string, r io.Reader) error
  • func (s PhysicalStore) PutObjectLarge(ctx context.Context, objectKey string, r io.Reader) error
• type Reference
• type Server
  • func (s Server) Create(ctx context.Context, path string, flag int, perm os.FileMode, r io.Reader) (os.FileInfo, error)
  • func (s Server) Mkdir(ctx context.Context, path string, perm os.FileMode) error
  • func (s Server) OpenFile(ctx context.Context, path string, flag int, perm os.FileMode) (webdav.File, error)
  • func (s Server) RemoveAll(ctx context.Context, path string) error
  • func (s Server) Rename(ctx context.Context, oldPath, newPath string) error
  • func (s Server) Stat(ctx context.Context, path string) (os.FileInfo, error)
• type SizeReader
  • func (r *SizeReader) Read(p []byte) (n int, err error)

Variables

var (
	ErrNoSuchReference = errors.New("no such reference")
	ErrNoSuchEntry     = errors.New("no such entry")
)

var ErrNotSupported = errors.New("not supported")

Functions

func GetParentDirPath

func GetParentDirPath(path string) string

Types

type Entry

type Entry struct {
	ID       string    `dynamodbav:"id"`
	ParentID string    `dynamodbav:"parent_id"`
	Name     string    `dynamodbav:"name"`
	Type     EntryType `dynamodbav:"type"`
	Size     int64     `dynamodbav:"size"`
	Modify   time.Time `dynamodbav:"modify"`
	Version  int       `dynamodbav:"version"`
}

type EntryType

type EntryType string

const (
	EntryTypeFile EntryType = "file"
	EntryTypeDir  EntryType = "dir"
)

type FileInfo

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

func (FileInfo) IsDir

func (f FileInfo) IsDir() bool

func (FileInfo) ModTime

func (f FileInfo) ModTime() time.Time

func (FileInfo) Mode

func (f FileInfo) Mode() fs.FileMode

func (FileInfo) Name

func (f FileInfo) Name() string

func (FileInfo) Size

func (f FileInfo) Size() int64

func (FileInfo) Sys

func (f FileInfo) Sys() any

type FileReader

type FileReader struct {
	io.ReadCloser
	// contains filtered or unexported fields
}

func (FileReader) Close

func (f FileReader) Close() error

func (FileReader) Read

func (f FileReader) Read(p []byte) (n int, err error)

func (FileReader) Readdir

func (f FileReader) Readdir(count int) ([]fs.FileInfo, error)

func (FileReader) Seek

func (f FileReader) Seek(offset int64, whence int) (int64, error)

func (FileReader) Stat

func (f FileReader) Stat() (fs.FileInfo, error)

func (FileReader) Write

func (f FileReader) Write(p []byte) (n int, err error)

type MetadataStore

type MetadataStore struct {
	EntryTableName     string
	ReferenceTableName string
	DynamoDBClient     *dynamodb.Client
}

func (MetadataStore) AddEntry

func (m MetadataStore) AddEntry(ctx context.Context, entry Entry, path string) error

func (MetadataStore) AddReference

func (m MetadataStore) AddReference(ctx context.Context, ref Reference) error

func (MetadataStore) DeleteEntries

func (m MetadataStore) DeleteEntries(ctx context.Context, ids []string, ref Reference) error

func (MetadataStore) GetEntriesByParentID

func (m MetadataStore) GetEntriesByParentID(ctx context.Context, id string) ([]Entry, error)

func (MetadataStore) GetEntry

func (m MetadataStore) GetEntry(ctx context.Context, id string) (Entry, error)

func (MetadataStore) GetReference

func (m MetadataStore) GetReference(ctx context.Context, id string) (Reference, error)

func (MetadataStore) Init

func (m MetadataStore) Init(ctx context.Context) error

func (MetadataStore) UpdateEntryName

func (m MetadataStore) UpdateEntryName(ctx context.Context, entry Entry, ref Reference) error

type PhysicalStore

type PhysicalStore struct {
	BucketName string
	S3Client   *s3.Client
}

func (PhysicalStore) GetObject

func (s PhysicalStore) GetObject(ctx context.Context, objectKey string) (io.ReadCloser, error)

func (PhysicalStore) PutObject

func (s PhysicalStore) PutObject(ctx context.Context, objectKey string, r io.Reader) error

func (PhysicalStore) PutObjectLarge

func (s PhysicalStore) PutObjectLarge(ctx context.Context, objectKey string, r io.Reader) error

type Reference

type Reference struct {
	ID      string            `dynamodbav:"id"`
	Entries map[string]string `dynamodbav:"entries"`
	Version int               `dynamodbav:"version"`
}

type Server

type Server struct {
	MetadataStore MetadataStore
	PhysicalStore PhysicalStore
}

func (Server) Create

func (s Server) Create(ctx context.Context, path string, flag int, perm os.FileMode, r io.Reader) (os.FileInfo, error)

func (Server) Mkdir

func (s Server) Mkdir(ctx context.Context, path string, perm os.FileMode) error

func (Server) OpenFile

func (s Server) OpenFile(ctx context.Context, path string, flag int, perm os.FileMode) (webdav.File, error)

func (Server) RemoveAll

func (s Server) RemoveAll(ctx context.Context, path string) error

func (Server) Rename

func (s Server) Rename(ctx context.Context, oldPath, newPath string) error

func (Server) Stat

func (s Server) Stat(ctx context.Context, path string) (os.FileInfo, error)

type SizeReader

type SizeReader struct {
	io.Reader
	Size int64
}

func (*SizeReader) Read

func (r *SizeReader) Read(p []byte) (n int, err error)