shardlite

README

shardlite

Documentation

Index

• Variables
• type Config
• type ErrAlreadyActive
  • func (e *ErrAlreadyActive) Error() string
• type Locker
• type LockerMaker
• type Pile
  • func NewPile(config *Config) *Pile
  • func (p *Pile) Shard(id string) *Shard
  • func (p *Pile) Start() error
  • func (p *Pile) Stop()
• type Shard
  • func (s *Shard) Activate() (*sql.DB, error)
  • func (s *Shard) Deactivate()
  • func (s *Shard) Save()
• type Storer

Variables

var Debug bool

Types

type Config

type Config struct {
	Name          string
	Url           string
	DbPath        string
	MigrateCb     func(*sql.DB) error
	ActivationTtl time.Duration
	SaveInterval  time.Duration
	Storage       Storer
	Leaser        LockerMaker
}

type ErrAlreadyActive

type ErrAlreadyActive struct {
	Url string
}

func (*ErrAlreadyActive) Error

func (e *ErrAlreadyActive) Error() string

type Locker

type Locker interface {
	TryLock() error
	TryUnlock() error
}

type LockerMaker

type LockerMaker interface {
	MakeLock(kind string, id string, url string) Locker
}

type Pile

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

func NewPile

func NewPile(config *Config) *Pile

func (*Pile) Shard

func (p *Pile) Shard(id string) *Shard

func (*Pile) Start

func (p *Pile) Start() error

func (*Pile) Stop

func (p *Pile) Stop()

type Shard

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

func (*Shard) Activate

func (s *Shard) Activate() (*sql.DB, error)

func (*Shard) Deactivate

func (s *Shard) Deactivate()

func (*Shard) Save

func (s *Shard) Save()

type Storer

type Storer interface {
	Upload(kind string, id string, file io.ReadSeeker) error
	Download(kind string, id string) (io.ReadCloser, error)
}