astore

Documentation

Overview

Package astore contains implementations for different AStores used in Hoard

Index

• func NewFlatPersistedAStore(b persistence.PersistedStorage) storage.WritableAStore
• func NewPersistedAStore(b persistence.PersistedStorage, log logrus.FieldLogger) storage.AStore
• type FlatPersistedAStore
  • func (a FlatPersistedAStore) Store(file storage.AFile, reader io.Reader) error
• type InMemoryAStore
  • func NewInMemoryAStore() *InMemoryAStore
  • func (a *InMemoryAStore) Delete(file storage.AFile) error
  • func (a *InMemoryAStore) Get(aFile storage.AFile) (io.ReadCloser, error)
  • func (a *InMemoryAStore) Search(startOpt *hour.Hour, end hour.Hour) ([]storage.SearchResult, error)
  • func (a *InMemoryAStore) Store(aFile storage.AFile, reader io.Reader) error
  • func (a *InMemoryAStore) String() string
• type PersistedAStore
  • func (a PersistedAStore) Delete(file storage.AFile) error
  • func (a PersistedAStore) Get(file storage.AFile) (io.ReadCloser, error)
  • func (a PersistedAStore) Search(startOpt *hour.Hour, end hour.Hour) ([]storage.SearchResult, error)
  • func (a PersistedAStore) Store(aFile storage.AFile, reader io.Reader) error
  • func (a PersistedAStore) String() string
• type ReplicatedAStore
  • func NewReplicatedAStore(aStores ...storage.AStore) ReplicatedAStore
  • func (m ReplicatedAStore) Delete(aFile storage.AFile) error
  • func (m ReplicatedAStore) Get(aFile storage.AFile) (io.ReadCloser, error)
  • func (m ReplicatedAStore) Replicas() []storage.AStore
  • func (m ReplicatedAStore) Search(startOpt *hour.Hour, end hour.Hour) ([]storage.SearchResult, error)
  • func (m ReplicatedAStore) Store(aFile storage.AFile, reader io.Reader) error
  • func (m ReplicatedAStore) String() string

Functions

func NewFlatPersistedAStore

func NewFlatPersistedAStore(b persistence.PersistedStorage) storage.WritableAStore

func NewPersistedAStore

func NewPersistedAStore(b persistence.PersistedStorage, log logrus.FieldLogger) storage.AStore

Types

type FlatPersistedAStore

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

func (FlatPersistedAStore) Store

func (a FlatPersistedAStore) Store(file storage.AFile, reader io.Reader) error

type InMemoryAStore

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

func NewInMemoryAStore

func NewInMemoryAStore() *InMemoryAStore

func (*InMemoryAStore) Delete

func (a *InMemoryAStore) Delete(file storage.AFile) error

func (*InMemoryAStore) Get

func (a *InMemoryAStore) Get(aFile storage.AFile) (io.ReadCloser, error)

func (*InMemoryAStore) Search

func (a *InMemoryAStore) Search(startOpt *hour.Hour, end hour.Hour) ([]storage.SearchResult, error)

func (*InMemoryAStore) Store

func (a *InMemoryAStore) Store(aFile storage.AFile, reader io.Reader) error

func (*InMemoryAStore) String

func (a *InMemoryAStore) String() string

type PersistedAStore

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

func (PersistedAStore) Delete

func (a PersistedAStore) Delete(file storage.AFile) error

func (PersistedAStore) Get

func (a PersistedAStore) Get(file storage.AFile) (io.ReadCloser, error)

func (PersistedAStore) Search

func (a PersistedAStore) Search(startOpt *hour.Hour, end hour.Hour) ([]storage.SearchResult, error)

func (PersistedAStore) Store

func (a PersistedAStore) Store(aFile storage.AFile, reader io.Reader) error

func (PersistedAStore) String

func (a PersistedAStore) String() string

type ReplicatedAStore

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

TODO: write tests for this

func NewReplicatedAStore

func NewReplicatedAStore(aStores ...storage.AStore) ReplicatedAStore

func (ReplicatedAStore) Delete

func (m ReplicatedAStore) Delete(aFile storage.AFile) error

func (ReplicatedAStore) Get

func (m ReplicatedAStore) Get(aFile storage.AFile) (io.ReadCloser, error)

func (ReplicatedAStore) Replicas

func (m ReplicatedAStore) Replicas() []storage.AStore

func (ReplicatedAStore) Search

func (m ReplicatedAStore) Search(startOpt *hour.Hour, end hour.Hour) ([]storage.SearchResult, error)

func (ReplicatedAStore) Store

func (m ReplicatedAStore) Store(aFile storage.AFile, reader io.Reader) error

func (ReplicatedAStore) String

func (m ReplicatedAStore) String() string