storage

Documentation

Index

• Constants
• func DeleteExpiredFile(pile, entry string) error
• func IsConfiguredBucket(buckets [][]byte, name []byte) bool
• func Startup(config Config, db *bbolt.DB) error
• func VoidExpired(config Config, db *bbolt.DB)
• type BoltDatabase
  • func MustOpenBoltDatabase(filename string) BoltDatabase
  • func (eh BoltDatabase) CreateEntry(pile string, filename string, create CreateWithFunc) (string, error)
  • func (eh BoltDatabase) GetEntry(pile string, entry string, get GetWithFunc) error
  • func (eh BoltDatabase) GetPileEntries(pile string) (map[string]EntryMeta, error)
  • func (eh BoltDatabase) Startup(config Config) error
• type Config
  • func LoadConfig(filename string) Config
  • func (c Config) BucketNames() [][]byte
  • func (c Config) Pile(pile string) (PileConfig, error)
• type CreateWithFunc
• type EntryCreator
• type EntryGetter
• type EntryHandler
• type EntryMeta
  • func EntryMetaFromBytes(data []byte) (EntryMeta, error)
  • func NewEntryMeta(filename string, created time.Time) EntryMeta
  • func (em EntryMeta) Bytes() ([]byte, error)
  • func (em EntryMeta) Filename() string
  • func (em EntryMeta) IsZero() bool
  • func (em EntryMeta) String() string
  • func (em EntryMeta) Time() time.Time
• type ErrDuringFileOperation
  • func (err ErrDuringFileOperation) Error() string
• type ErrFailedCreatingEntryFile
  • func (err ErrFailedCreatingEntryFile) Error() string
• type ErrFailedCreatingPileDirectory
  • func (err ErrFailedCreatingPileDirectory) Error() string
• type ErrFailedMakingId
  • func (err ErrFailedMakingId) Error() string
• type ErrFailedStoringEntryMetadata
  • func (err ErrFailedStoringEntryMetadata) Error() string
• type ErrNoSuchEntry
  • func (err ErrNoSuchEntry) Error() string
• type ErrNoSuchPile
  • func (err ErrNoSuchPile) Error() string
• type ErrUnparsableMeta
  • func (err ErrUnparsableMeta) Error() string
• type GetWithFunc
• type Lifetime
  • func (lt Lifetime) MarshalJSON() ([]byte, error)
  • func (lt *Lifetime) UnmarshalJSON(b []byte) error
• type PileConfig
• type PileGetter
• type QuitSignalChan
  • func StartExpireLoop(interval time.Duration, config Config, db *bbolt.DB) QuitSignalChan
• type Starter

Constants

const (
	TIME_FORMAT = time.RFC3339
)

Functions

func DeleteExpiredFile

func DeleteExpiredFile(pile, entry string) error

func IsConfiguredBucket

func IsConfiguredBucket(buckets [][]byte, name []byte) bool

func Startup

func Startup(config Config, db *bbolt.DB) error

func VoidExpired

func VoidExpired(config Config, db *bbolt.DB)

Types

type BoltDatabase

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

func MustOpenBoltDatabase

func MustOpenBoltDatabase(filename string) BoltDatabase

func (BoltDatabase) CreateEntry

func (eh BoltDatabase) CreateEntry(pile string, filename string, create CreateWithFunc) (string, error)

func (BoltDatabase) GetEntry

func (eh BoltDatabase) GetEntry(pile string, entry string, get GetWithFunc) error

func (BoltDatabase) GetPileEntries

func (eh BoltDatabase) GetPileEntries(pile string) (map[string]EntryMeta, error)

func (BoltDatabase) Startup

func (eh BoltDatabase) Startup(config Config) error

type Config

type Config struct {
	Piles         map[string]PileConfig `json:"piles"`
	ForwardHeader string                `json:"forward_header"`
}

func LoadConfig

func LoadConfig(filename string) Config

func (Config) BucketNames

func (c Config) BucketNames() [][]byte

func (Config) Pile

func (c Config) Pile(pile string) (PileConfig, error)

type CreateWithFunc

type CreateWithFunc func(id string, destination io.Writer) error

type EntryCreator

type EntryCreator interface {
	CreateEntry(pile string, entry string, creator CreateWithFunc) (entryID string, err error)
}

type EntryGetter

type EntryGetter interface {
	GetEntry(pile string, entry string, read GetWithFunc) (err error)
}

type EntryHandler

type EntryHandler interface {
	EntryGetter
	EntryCreator
}

type EntryMeta

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

func EntryMetaFromBytes

func EntryMetaFromBytes(data []byte) (EntryMeta, error)

func NewEntryMeta

func NewEntryMeta(filename string, created time.Time) EntryMeta

func (EntryMeta) Bytes

func (em EntryMeta) Bytes() ([]byte, error)

func (EntryMeta) Filename

func (em EntryMeta) Filename() string

func (EntryMeta) IsZero

func (em EntryMeta) IsZero() bool

func (EntryMeta) String

func (em EntryMeta) String() string

func (EntryMeta) Time

func (em EntryMeta) Time() time.Time

type ErrDuringFileOperation

type ErrDuringFileOperation struct {
	Pile          string
	Entry         string
	UpstreamError error
}

func (ErrDuringFileOperation) Error

func (err ErrDuringFileOperation) Error() string

type ErrFailedCreatingEntryFile

type ErrFailedCreatingEntryFile struct {
	Pile          string
	Entry         string
	UpstreamError error
}

func (ErrFailedCreatingEntryFile) Error

func (err ErrFailedCreatingEntryFile) Error() string

type ErrFailedCreatingPileDirectory

type ErrFailedCreatingPileDirectory struct {
	Pile          string
	UpstreamError error
}

func (ErrFailedCreatingPileDirectory) Error

func (err ErrFailedCreatingPileDirectory) Error() string

type ErrFailedMakingId

type ErrFailedMakingId struct {
	UpstreamError error
}

func (ErrFailedMakingId) Error

func (err ErrFailedMakingId) Error() string

type ErrFailedStoringEntryMetadata

type ErrFailedStoringEntryMetadata struct {
	Pile          string
	Entry         string
	UpstreamError error
}

func (ErrFailedStoringEntryMetadata) Error

func (err ErrFailedStoringEntryMetadata) Error() string

type ErrNoSuchEntry

type ErrNoSuchEntry struct {
	Pile  string
	Entry string
}

func (ErrNoSuchEntry) Error

func (err ErrNoSuchEntry) Error() string

type ErrNoSuchPile

type ErrNoSuchPile struct {
	Pile string
}

func (ErrNoSuchPile) Error

func (err ErrNoSuchPile) Error() string

type ErrUnparsableMeta

type ErrUnparsableMeta struct {
	Raw        []byte
	ParseError error
}

func (ErrUnparsableMeta) Error

func (err ErrUnparsableMeta) Error() string

type GetWithFunc

type GetWithFunc func(metaData EntryMeta, MIMEType string, file io.Reader) error

type Lifetime

type Lifetime struct {
	time.Duration
}

func (Lifetime) MarshalJSON

func (lt Lifetime) MarshalJSON() ([]byte, error)

func (*Lifetime) UnmarshalJSON

func (lt *Lifetime) UnmarshalJSON(b []byte) error

type PileConfig

type PileConfig struct {
	Lifetime Lifetime `json:"lifetime"`
	Origin   string   `json:"origin"`
	POSTKey  string   `json:"post_key"`
	GETKey   string   `json:"get_key"`
	ListKey  string   `json:"list_key"`
	MaxSize  int64    `json:"max_size"`
}

type PileGetter

type PileGetter interface {
	GetPileEntries(pile string) (map[string]EntryMeta, error)
}

type QuitSignalChan

type QuitSignalChan chan<- interface{}

func StartExpireLoop

func StartExpireLoop(interval time.Duration, config Config, db *bbolt.DB) QuitSignalChan

type Starter

type Starter interface {
	Startup(Config) error
}