sqliteStorage

Documentation

Index

• func NewPiecesStorage(opts NewPoolOpts) (_ storage.ClientImplCloser, err error)
• func NewPool(opts NewPoolOpts) (_ ConnPool, _ ProviderOpts, err error)
• func NewProvider(pool ConnPool, opts ProviderOpts) (_ *provider, err error)
• func SetCapacity(conn conn, cap int64) error
• func UnlimitCapacity(conn conn) error
• type ConnPool
• type NewPoolOpts
• type ProviderOpts

Functions

func NewPiecesStorage

func NewPiecesStorage(opts NewPoolOpts) (_ storage.ClientImplCloser, err error)

A convenience function that creates a connection pool, resource provider, and a pieces storage ClientImpl and returns them all with a Close attached.

func NewPool

func NewPool(opts NewPoolOpts) (_ ConnPool, _ ProviderOpts, err error)

func NewProvider

func NewProvider(pool ConnPool, opts ProviderOpts) (_ *provider, err error)

Needs the ConnPool size so it can initialize all the connections with pragmas. Takes ownership of the ConnPool (since it has to initialize all the connections anyway).

func SetCapacity

func SetCapacity(conn conn, cap int64) error

Set the capacity limit to exactly this value.

func UnlimitCapacity

func UnlimitCapacity(conn conn) error

Remove any capacity limits.

Types

type ConnPool

type ConnPool interface {
	Get(context.Context) conn
	Put(conn)
	Close() error
}

type NewPoolOpts

type NewPoolOpts struct {
	Path     string
	Memory   bool
	NumConns int
	// Forces WAL, disables shared caching.
	ConcurrentBlobReads bool
	DontInitSchema      bool
	// If non-zero, overrides the existing setting.
	Capacity int64
}

type ProviderOpts

type ProviderOpts struct {
	NumConns int
	// Concurrent blob reads require WAL.
	ConcurrentBlobRead bool
	BatchWrites        bool
}

There's some overlap here with NewPoolOpts, and I haven't decided what needs to be done. For now, the fact that the pool opts are a superset, means our helper NewPiecesStorage can just take the top-level option type.