redipo

README

Redipo

Why only use Redis for caching? Let's store all of our data on it!

Documentation

Index

• type Manager
  • func (m *Manager) LoadDbRepo(name string) RepoInterface
  • func (m *Manager) LoadRepo(name string) RepoInterface
• type ManagerInterface
  • func New() ManagerInterface
• type Repo
  • func (r *Repo) AddToIndex(name string, id uuid.UUID) error
  • func (r *Repo) CleanupInvalidKeys(dryRun bool) ([]uuid.UUID, error)
  • func (r *Repo) ClearIndex(name string) error
  • func (r *Repo) Delete(id uuid.UUID) error
  • func (r *Repo) DeleteIndex(name string) error
  • func (r *Repo) Get(id uuid.UUID) (interface{}, error)
  • func (r *Repo) GetAll() ([]interface{}, error)
  • func (r *Repo) GetIndex(name string) ([]uuid.UUID, error)
  • func (r *Repo) List() ([]uuid.UUID, error)
  • func (r *Repo) RemoveFromIndex(name string, id uuid.UUID) error
  • func (r *Repo) Save(id uuid.UUID, value interface{}) error
  • func (r *Repo) SaveWithExpiration(id uuid.UUID, value interface{}, expiration time.Duration) error
  • func (r *Repo) SetCaching(cacheInstance cache.Cache) RepoInterface
  • func (r *Repo) SetFactory(factory func() interface{})
• type RepoInterface
  • func NewRepo(name string, client *redis.Client) RepoInterface

Types

type Manager

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

func (*Manager) LoadDbRepo

func (m *Manager) LoadDbRepo(name string) RepoInterface

func (*Manager) LoadRepo

func (m *Manager) LoadRepo(name string) RepoInterface

type ManagerInterface

type ManagerInterface interface {
	LoadRepo(name string) RepoInterface
	LoadDbRepo(name string) RepoInterface
	// contains filtered or unexported methods
}

func New

func New() ManagerInterface

type Repo

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

func (*Repo) AddToIndex

func (r *Repo) AddToIndex(name string, id uuid.UUID) error

func (*Repo) CleanupInvalidKeys

func (r *Repo) CleanupInvalidKeys(dryRun bool) ([]uuid.UUID, error)

func (*Repo) ClearIndex

func (r *Repo) ClearIndex(name string) error

func (*Repo) Delete

func (r *Repo) Delete(id uuid.UUID) error

func (*Repo) DeleteIndex

func (r *Repo) DeleteIndex(name string) error

func (*Repo) Get

func (r *Repo) Get(id uuid.UUID) (interface{}, error)

func (*Repo) GetAll

func (r *Repo) GetAll() ([]interface{}, error)

func (*Repo) GetIndex

func (r *Repo) GetIndex(name string) ([]uuid.UUID, error)

func (*Repo) List

func (r *Repo) List() ([]uuid.UUID, error)

func (*Repo) RemoveFromIndex

func (r *Repo) RemoveFromIndex(name string, id uuid.UUID) error

func (*Repo) Save

func (r *Repo) Save(id uuid.UUID, value interface{}) error

func (*Repo) SaveWithExpiration

func (r *Repo) SaveWithExpiration(id uuid.UUID, value interface{}, expiration time.Duration) error

func (*Repo) SetCaching

func (r *Repo) SetCaching(cacheInstance cache.Cache) RepoInterface

func (*Repo) SetFactory

func (r *Repo) SetFactory(factory func() interface{})

type RepoInterface

type RepoInterface interface {
	SetCaching(cacheInstance cache.Cache) RepoInterface
	SetFactory(func() interface{})
	List() ([]uuid.UUID, error)
	Get(id uuid.UUID) (interface{}, error)
	GetAll() ([]interface{}, error)
	GetIndex(name string) ([]uuid.UUID, error)
	AddToIndex(name string, id uuid.UUID) error
	RemoveFromIndex(name string, id uuid.UUID) error
	DeleteIndex(name string) error
	Save(id uuid.UUID, value interface{}) error
	SaveWithExpiration(id uuid.UUID, value interface{}, expiration time.Duration) error
	Delete(id uuid.UUID) error
	CleanupInvalidKeys(dryRun bool) ([]uuid.UUID, error)
}

func NewRepo

func NewRepo(name string, client *redis.Client) RepoInterface