storage

Documentation

Index

• type ColdStorageService
  • func NewColdStorageService(dataDir string) (*ColdStorageService, error)
  • func (svc *ColdStorageService) CollectionExists(id string) (bool, error)
  • func (svc *ColdStorageService) FlushToDisk(id string, data Collection) error
  • func (svc *ColdStorageService) ListCollections() ([]string, error)
  • func (svc *ColdStorageService) ReadFromDiskForId(id string) (Collection, error)
• type Collection
• type Engine
  • func NewEngine(dataDir string, autoCreate bool) (*Engine, error)
  • func (e *Engine) CollectionExists(id string) (bool, error)
  • func (e *Engine) FlushAllCollections() []error
  • func (e *Engine) FlushCollection(id string) error
  • func (e *Engine) IsHot(id string) (bool, error)
  • func (e *Engine) ListCollections() ([]string, error)
  • func (e *Engine) LoadCollection(id string) error
  • func (e *Engine) LoadCollectionIfNotPresent(id string) error
  • func (e *Engine) ReadKey(id, key string) (string, error)
  • func (e *Engine) WriteKey(id, key, value string) error
• type HotStorageService
  • func NewHotStorageService() (*HotStorageService, error)
  • func (svc *HotStorageService) CollectionExists(id string) bool
  • func (svc *HotStorageService) CreateCollection(id string) error
  • func (svc *HotStorageService) DropCollection(id string) error
  • func (svc *HotStorageService) ListCollections() []string
  • func (svc *HotStorageService) ReadKey(id, key string) (string, error)
  • func (svc *HotStorageService) WriteKey(id, key, value string) error

Types

type ColdStorageService

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

func NewColdStorageService

func NewColdStorageService(dataDir string) (*ColdStorageService, error)

func (*ColdStorageService) CollectionExists

func (svc *ColdStorageService) CollectionExists(id string) (bool, error)

func (*ColdStorageService) FlushToDisk

func (svc *ColdStorageService) FlushToDisk(id string, data Collection) error

func (*ColdStorageService) ListCollections

func (svc *ColdStorageService) ListCollections() ([]string, error)

func (*ColdStorageService) ReadFromDiskForId

func (svc *ColdStorageService) ReadFromDiskForId(id string) (Collection, error)

type Collection

type Collection map[string]string

type Engine

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

func NewEngine

func NewEngine(dataDir string, autoCreate bool) (*Engine, error)

func (*Engine) CollectionExists

func (e *Engine) CollectionExists(id string) (bool, error)

check if a collection exists across hot and cold storage for a given collection id

func (*Engine) FlushAllCollections

func (e *Engine) FlushAllCollections() []error

func (*Engine) FlushCollection

func (e *Engine) FlushCollection(id string) error

func (*Engine) IsHot

func (e *Engine) IsHot(id string) (bool, error)

check if a collection is hot for a given collection id

func (*Engine) ListCollections

func (e *Engine) ListCollections() ([]string, error)

list all distinct collections across both hot and cold storage

func (*Engine) LoadCollection

func (e *Engine) LoadCollection(id string) error

func (*Engine) LoadCollectionIfNotPresent

func (e *Engine) LoadCollectionIfNotPresent(id string) error

func (*Engine) ReadKey

func (e *Engine) ReadKey(id, key string) (string, error)

func (*Engine) WriteKey

func (e *Engine) WriteKey(id, key, value string) error

type HotStorageService

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

func NewHotStorageService

func NewHotStorageService() (*HotStorageService, error)

func (*HotStorageService) CollectionExists

func (svc *HotStorageService) CollectionExists(id string) bool

func (*HotStorageService) CreateCollection

func (svc *HotStorageService) CreateCollection(id string) error

func (*HotStorageService) DropCollection

func (svc *HotStorageService) DropCollection(id string) error

func (*HotStorageService) ListCollections

func (svc *HotStorageService) ListCollections() []string

func (*HotStorageService) ReadKey

func (svc *HotStorageService) ReadKey(id, key string) (string, error)

func (*HotStorageService) WriteKey

func (svc *HotStorageService) WriteKey(id, key, value string) error