cache

Documentation

Index

• Constants
• Variables
• type Cache
  • func NewFileCache(dir string) Cache
  • func NewInMemoryCache() Cache
• type FileLocker
  • func (fl *FileLocker) Lock() (err error)
  • func (fl *FileLocker) Unlock() (err error)
• type HistoryCache
  • func NewHistoryFileCache(dir string) HistoryCache
• type HistoryLocker
  • func (fl *HistoryLocker) Lock() (err error)
  • func (fl *HistoryLocker) Unlock() (err error)
• type InMemoryLocker
  • func (fl *InMemoryLocker) Lock() (err error)
  • func (fl *InMemoryLocker) Unlock() (err error)
• type Locker

Constants

const STATE_FN = ".state-"

STATE_FN ...

Variables

var (
	ErrPrevStateNotFound   = errors.New("could not find previous state")
	ErrLocalStateCorrupted = errors.New("local state is corrupted")
)

Types

type Cache

type Cache interface {
	Get(serverUUID, db string) (*schema.ImmutableState, error)
	Set(serverUUID, db string, state *schema.ImmutableState) error
	GetLocker(serverUUID string) Locker
}

Cache the cache interface

func NewFileCache

func NewFileCache(dir string) Cache

NewFileCache returns a new file cache

func NewInMemoryCache

func NewInMemoryCache() Cache

NewInMemoryCache returns a new in-memory cache

type FileLocker

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

func (*FileLocker) Lock

func (fl *FileLocker) Lock() (err error)

func (*FileLocker) Unlock

func (fl *FileLocker) Unlock() (err error)

type HistoryCache

type HistoryCache interface {
	Cache
	Walk(serverUUID string, db string, f func(*schema.ImmutableState) interface{}) ([]interface{}, error)
}

HistoryCache the history cache interface

func NewHistoryFileCache

func NewHistoryFileCache(dir string) HistoryCache

NewHistoryFileCache returns a new history file cache

type HistoryLocker

type HistoryLocker struct{}

func (*HistoryLocker) Lock

func (fl *HistoryLocker) Lock() (err error)

func (*HistoryLocker) Unlock

func (fl *HistoryLocker) Unlock() (err error)

type InMemoryLocker

type InMemoryLocker struct{}

func (*InMemoryLocker) Lock

func (fl *InMemoryLocker) Lock() (err error)

func (*InMemoryLocker) Unlock

func (fl *InMemoryLocker) Unlock() (err error)

type Locker

type Locker interface {
	Lock() error
	Unlock() error
}