kvstore

Documentation

Index

• func NewKVStoreTemplateFuncMap(storage Storage) template.FuncMap
• type InmemoryStorage
  • func NewInmemoryStorage() *InmemoryStorage
  • func (s *InmemoryStorage) Get(store, key string) (interface{}, error)
  • func (s *InmemoryStorage) GetAll(store string) (map[string]interface{}, error)
  • func (s *InmemoryStorage) Put(store, key string, val interface{}) error
  • func (s *InmemoryStorage) Shutdown() error
• type RequestHandler
  • func NewRequestHandler(pathPrefix string, storage Storage, logLevel string) *RequestHandler
  • func (r *RequestHandler) AddRoutes(router *mux.Router)
• type Storage

Functions

func NewKVStoreTemplateFuncMap

func NewKVStoreTemplateFuncMap(storage Storage) template.FuncMap

NewKVStoreTemplateFuncMap creates a template.FuncMap for accessing a Storage

Types

type InmemoryStorage

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

InmemoryStorage is an implementation of Storage using local in-memory storage

func NewInmemoryStorage

func NewInmemoryStorage() *InmemoryStorage

NewInmemoryStorage creates a new instance of InmemoryStorage

func (*InmemoryStorage) Get

func (s *InmemoryStorage) Get(store, key string) (interface{}, error)

Get returns a value for a given key

func (*InmemoryStorage) GetAll

func (s *InmemoryStorage) GetAll(store string) (map[string]interface{}, error)

GetAll returns all values for a given store

func (*InmemoryStorage) Put

func (s *InmemoryStorage) Put(store, key string, val interface{}) error

Put stores a value for a given key

func (*InmemoryStorage) Shutdown

func (s *InmemoryStorage) Shutdown() error

Shutdown does nothing for InmemoryStorage

type RequestHandler

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

RequestHandler implements an http API to access a Storage

func NewRequestHandler

func NewRequestHandler(pathPrefix string, storage Storage, logLevel string) *RequestHandler

NewRequestHandler creates an instance of RequestHandler

func (*RequestHandler) AddRoutes

func (r *RequestHandler) AddRoutes(router *mux.Router)

AddRoutes adds mux.Routes for the http API to a given mux.Router

type Storage

type Storage interface {
	GetAll(store string) (map[string]interface{}, error)
	Put(store, key string, val interface{}) error
	Get(store, key string) (interface{}, error)
	Shutdown() error
}

Storage is *the* interface for the key value store

There can be implementations using: - a local in-memory storage , - multiple servers for a distributed - a database like redis