sqlite

Documentation

Index

• func Close() error
• func Init(sessionMode bool, ctx ...context.Context)
• func Select(fileName, id string) (*store.Item, error)
• func Upsert(fileName, id string, unit *store.Item) error
• type Pull
  • func New(sessionMode bool, ctx ...context.Context) *Pull
  • func (p *Pull) Add(fileName string) (*SQL, error)
  • func (p *Pull) Close() error
  • func (p *Pull) DeleteOld() (int64, error)
  • func (p *Pull) Get(fileName string) (*SQL, error)
  • func (p *Pull) Select(fileName, id string) (*store.Item, error)
  • func (p *Pull) Upsert(fileName, id string, unit *store.Item) error
• type Record
• type SQL
  • func Conn(fileName string) (*SQL, error)
  • func (s *SQL) Close() error
  • func (s *SQL) CreateTable() error
  • func (s *SQL) DeleteOld(requested map[string]bool) (int64, error)
  • func (s *SQL) Open() error
  • func (s *SQL) Select(id string) (*store.Item, error)
  • func (s *SQL) SelectAll() ([]*Record, error)
  • func (s *SQL) SelectAllID() ([]string, error)
  • func (s *SQL) Upsert(id string, unit *store.Item) error

Functions

func Close

func Close() error

--------------------------------

func Init

func Init(sessionMode bool, ctx ...context.Context)

func Select

func Select(fileName, id string) (*store.Item, error)

func Upsert

func Upsert(fileName, id string, unit *store.Item) error

Types

type Pull

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

func New

func New(sessionMode bool, ctx ...context.Context) *Pull

func (*Pull) Add

func (p *Pull) Add(fileName string) (*SQL, error)

Add creates new connection and adds to pull

func (*Pull) Close

func (p *Pull) Close() error

func (*Pull) DeleteOld

func (p *Pull) DeleteOld() (int64, error)

func (*Pull) Get

func (p *Pull) Get(fileName string) (*SQL, error)

Add creates new connection and adds to pull

func (*Pull) Select

func (p *Pull) Select(fileName, id string) (*store.Item, error)

func (*Pull) Upsert

func (p *Pull) Upsert(fileName, id string, unit *store.Item) error

Upsert just inserts or update one record

type Record

type Record struct {
	// Args is unique key: MD5 hash from url + request
	ID string `json:"id"`

	// See github.com/iostrovok/cacheproxy/store
	Body *store.Item `json:"body"`
}

type SQL

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

func Conn

func Conn(fileName string) (*SQL, error)

func (*SQL) Close

func (s *SQL) Close() error

func (*SQL) CreateTable

func (s *SQL) CreateTable() error

CreateTable just makes new table

func (*SQL) DeleteOld

func (s *SQL) DeleteOld(requested map[string]bool) (int64, error)

func (*SQL) Open

func (s *SQL) Open() error

func (*SQL) Select

func (s *SQL) Select(id string) (*store.Item, error)

func (*SQL) SelectAll

func (s *SQL) SelectAll() ([]*Record, error)

SelectAll returns all rows sorted by id

func (*SQL) SelectAllID

func (s *SQL) SelectAllID() ([]string, error)

SelectAllID returns all row id sorted by id

func (*SQL) Upsert

func (s *SQL) Upsert(id string, unit *store.Item) error

Upsert