sql2keyval

README

go-sql2keyval

database/sql as key value store

Documentation

Index

• Variables
• func Bool2error(ok bool, egen func() error) error
• func Compose[T, U, V any](f func(T) U, g func(U) V) func(T) V
• func IterFlat2Chan[T any](i Iter[Iter[T]], c chan<- T, lmt int)
• func IterReduce[T, U any](i Iter[T], init U, reducer func(state U, item T) U) U
• func OptionEmptyNew[T any]() optionEmpty[T]
• func OptionNew[T any](val T) optionValue[T]
• func RegisterQueryGenerator(driverName string, gen QueryGenerator)
• type Add
• type AddBucket
• type AddLog
• type Batch
  • func BatchNew(bucket string, Key, Val []byte) Batch
  • func (b Batch) Bucket() string
  • func (b Batch) Pair() Pair
  • func (b Batch) WithKey(k []byte) Batch
• type Del
• type DelBucket
• type Exec
• type Get
• type InsLog
• type Iter
  • func IterEmptyNew[T any]() Iter[T]
  • func IterFromArray[T any](a []T) Iter[T]
  • func IterFromChan[T any](c <-chan T) Iter[T]
  • func IterFromChanNB[T any](c <-chan T) Iter[T]
  • func IterFromOpt[T any](o Option[T]) Iter[T]
  • func IterInts(lbi int, ube int) Iter[int]
  • func IterMap[T, U any](i Iter[T], f func(T) U) Iter[U]
  • func (i Iter[T]) Count() uint64
  • func (i Iter[T]) IntoInspect(f func(T)) Iter[T]
  • func (iter Iter[T]) Take(imax int) Iter[T]
  • func (i Iter[T]) ToArray() (a []T)
• type Lst
• type Option
  • func OptionMap[T, U any](o Option[T], f func(T) U) Option[U]
• type Pair
  • func (p Pair) WithKey(Key []byte) Pair
• type Pairs2Bucket
  • func NonAtomicPairs2BucketNew(s Set2Bucket) Pairs2Bucket
• type Query
• type QueryCb
• type QueryGenerator
• type Record
• type RecordConsumer
• type Set
  • func NonAtomicSetNew(del Del, add Add) Set
• type Set2Bucket
• type SetBatch
• type SetMany
  • func NonAtomicSetsNew(s Set) SetMany
• type SetMany2Bucket
  • func NonAtomicSetsSingleNew(s Set2Bucket) SetMany2Bucket

Variables

var AddBucketFactory func(driverName string) func(Exec) AddBucket = compose(getQueryGeneratorOrEmpty, addBucketFactory)

var AddFactory func(driverName string) func(Exec) Add = compose(getQueryGeneratorOrEmpty, addFactory)

var DelBucketFactory func(driverName string) func(Exec) DelBucket = compose(getQueryGeneratorOrEmpty, delBucketFactory)

var DelFactory func(driverName string) func(Exec) Del = compose(getQueryGeneratorOrEmpty, delFactory)

var GetFactory func(driverName string) func(Query) Get = compose(getQueryGeneratorOrEmpty, getFactory)

var LstFactory func(driverName string) func(QueryCb) Lst = compose(getQueryGeneratorOrEmpty, lstFactory)

var SetFactory func(driverName string) func(Exec) Set = compose(getQueryGeneratorOrEmpty, setFactory)

Functions

func Bool2error

func Bool2error(ok bool, egen func() error) error

func Compose

func Compose[T, U, V any](f func(T) U, g func(U) V) func(T) V

func IterFlat2Chan

func IterFlat2Chan[T any](i Iter[Iter[T]], c chan<- T, lmt int)

func IterReduce

func IterReduce[T, U any](i Iter[T], init U, reducer func(state U, item T) U) U

func OptionEmptyNew

func OptionEmptyNew[T any]() optionEmpty[T]

func OptionNew

func OptionNew[T any](val T) optionValue[T]

func RegisterQueryGenerator

func RegisterQueryGenerator(driverName string, gen QueryGenerator)

Types

type Add

type Add func(ctx context.Context, bucket string, key []byte, val []byte) error

type AddBucket

type AddBucket func(ctx context.Context, bucket string) error

type AddLog

type AddLog func(ctx context.Context, bucket string) error

type Batch

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

func BatchNew

func BatchNew(bucket string, Key, Val []byte) Batch

func (Batch) Bucket

func (b Batch) Bucket() string

func (Batch) Pair

func (b Batch) Pair() Pair

func (Batch) WithKey

func (b Batch) WithKey(k []byte) Batch

type Del

type Del func(ctx context.Context, bucket string, key []byte) error

type DelBucket

type DelBucket func(ctx context.Context, bucket string) error

type Exec

type Exec func(ctx context.Context, query string, args ...any) error

type Get

type Get func(ctx context.Context, bucket string, key []byte) (val []byte, e error)

type InsLog

type InsLog func(ctx context.Context, lg []byte) error

type Iter

type Iter[T any] func() Option[T]

func IterEmptyNew

func IterEmptyNew[T any]() Iter[T]

func IterFromArray

func IterFromArray[T any](a []T) Iter[T]

func IterFromChan

func IterFromChan[T any](c <-chan T) Iter[T]

func IterFromChanNB

func IterFromChanNB[T any](c <-chan T) Iter[T]

func IterFromOpt

func IterFromOpt[T any](o Option[T]) Iter[T]

func IterInts

func IterInts(lbi int, ube int) Iter[int]

func IterMap

func IterMap[T, U any](i Iter[T], f func(T) U) Iter[U]

func (Iter[T]) Count

func (i Iter[T]) Count() uint64

func (Iter[T]) IntoInspect

func (i Iter[T]) IntoInspect(f func(T)) Iter[T]

func (Iter[T]) Take

func (iter Iter[T]) Take(imax int) Iter[T]

func (Iter[T]) ToArray

func (i Iter[T]) ToArray() (a []T)

type Lst

type Lst func(ctx context.Context, bucket string, cb func(key []byte) error) error

type Option

type Option[T any] interface {
	Value() T
	Empty() bool
	HasValue() bool
	ForEach(f func(T))
	Filter(f func(T) bool) Option[T]
}

func OptionMap

func OptionMap[T, U any](o Option[T], f func(T) U) Option[U]

type Pair

type Pair struct {
	Key []byte
	Val []byte
}

func (Pair) WithKey

func (p Pair) WithKey(Key []byte) Pair

type Pairs2Bucket

type Pairs2Bucket func(ctx context.Context, pairs Iter[Pair]) error

func NonAtomicPairs2BucketNew

func NonAtomicPairs2BucketNew(s Set2Bucket) Pairs2Bucket

type Query

type Query func(ctx context.Context, query string, args ...any) Record

type QueryCb

type QueryCb func(ctx context.Context, cb RecordConsumer, query string, args ...any) error

type QueryGenerator

type QueryGenerator interface {
	Get(bucket string) (query string, e error)
	Del(bucket string) (query string, e error)
	Add(bucket string) (query string, e error)
	Set(bucket string) (query string, e error)
	Lst(bucket string) (query string, e error)
	DelBucket(bucket string) (query string, e error)
	AddBucket(bucket string) (query string, e error)
}

type Record

type Record interface{ Scan(dest ...any) error }

type RecordConsumer

type RecordConsumer func(r Record) error

type Set

type Set func(ctx context.Context, bucket string, key []byte, val []byte) error

func NonAtomicSetNew

func NonAtomicSetNew(del Del, add Add) Set

type Set2Bucket

type Set2Bucket func(ctx context.Context, key, val []byte) error

type SetBatch

type SetBatch func(ctx context.Context, many Iter[Batch]) error

type SetMany

type SetMany func(ctx context.Context, bucket string, pairs []Pair) error

func NonAtomicSetsNew

func NonAtomicSetsNew(s Set) SetMany

type SetMany2Bucket

type SetMany2Bucket func(ctx context.Context, pairs []Pair) error

func NonAtomicSetsSingleNew

func NonAtomicSetsSingleNew(s Set2Bucket) SetMany2Bucket