dstore

Documentation

Overview

Package dstore contains implementations for different DStores used in Hoard

Index

• func NewFlatPersistedDStore(b persistence.PersistedStorage) storage.WritableDStore
• func NewPersistedDStore(b persistence.PersistedStorage, log logrus.FieldLogger) storage.DStore
• type FlatPersistedDStore
  • func (d FlatPersistedDStore) Store(file storage.DFile, content io.Reader) error
• type InMemoryDStore
  • func NewInMemoryDStore() *InMemoryDStore
  • func (dstore *InMemoryDStore) Count() int
  • func (dstore *InMemoryDStore) Delete(storage.DFile) error
  • func (dstore *InMemoryDStore) Get(dFile storage.DFile) (io.ReadCloser, error)
  • func (dstore *InMemoryDStore) ListInHour(hr hour.Hour) ([]storage.DFile, error)
  • func (dstore *InMemoryDStore) ListNonEmptyHours() ([]hour.Hour, error)
  • func (dstore *InMemoryDStore) Store(file storage.DFile, content io.Reader) error
• type PersistedDStore
  • func (d PersistedDStore) Delete(file storage.DFile) error
  • func (d PersistedDStore) Get(file storage.DFile) (io.ReadCloser, error)
  • func (d PersistedDStore) ListInHour(hour hour.Hour) ([]storage.DFile, error)
  • func (d PersistedDStore) ListNonEmptyHours() ([]hour.Hour, error)
  • func (d PersistedDStore) Store(file storage.DFile, content io.Reader) error

Functions

func NewFlatPersistedDStore

func NewFlatPersistedDStore(b persistence.PersistedStorage) storage.WritableDStore

func NewPersistedDStore

func NewPersistedDStore(b persistence.PersistedStorage, log logrus.FieldLogger) storage.DStore

Types

type FlatPersistedDStore

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

func (FlatPersistedDStore) Store

func (d FlatPersistedDStore) Store(file storage.DFile, content io.Reader) error

type InMemoryDStore

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

func NewInMemoryDStore

func NewInMemoryDStore() *InMemoryDStore

func (*InMemoryDStore) Count

func (dstore *InMemoryDStore) Count() int

func (*InMemoryDStore) Delete

func (dstore *InMemoryDStore) Delete(storage.DFile) error

func (*InMemoryDStore) Get

func (dstore *InMemoryDStore) Get(dFile storage.DFile) (io.ReadCloser, error)

func (*InMemoryDStore) ListInHour

func (dstore *InMemoryDStore) ListInHour(hr hour.Hour) ([]storage.DFile, error)

func (*InMemoryDStore) ListNonEmptyHours

func (dstore *InMemoryDStore) ListNonEmptyHours() ([]hour.Hour, error)

func (*InMemoryDStore) Store

func (dstore *InMemoryDStore) Store(file storage.DFile, content io.Reader) error

type PersistedDStore

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

func (PersistedDStore) Delete

func (d PersistedDStore) Delete(file storage.DFile) error

func (PersistedDStore) Get

func (d PersistedDStore) Get(file storage.DFile) (io.ReadCloser, error)

func (PersistedDStore) ListInHour

func (d PersistedDStore) ListInHour(hour hour.Hour) ([]storage.DFile, error)

func (PersistedDStore) ListNonEmptyHours

func (d PersistedDStore) ListNonEmptyHours() ([]hour.Hour, error)

func (PersistedDStore) Store

func (d PersistedDStore) Store(file storage.DFile, content io.Reader) error