commit

package

Go to main page

Versions in this module

v0

v0.4.1

Oct 13, 2023

v0.4.0

Jul 3, 2023

v0.3.0

Dec 17, 2022

v0.2.3

Dec 3, 2022

Changes in this version

type Reader

+ func (r *Reader) IsDelete() bool

+ func (r *Reader) IsUpsert() bool

v0.2.2

Dec 1, 2022

Changes in this version

type OpType

+ func (o OpType) String() string

v0.2.1

Nov 27, 2022

v0.2.0

Nov 26, 2022

Changes in this version

type OpType

+ const Merge

+ const Skip

type Reader

+ func (r *Reader) SwapBytes(v []byte) []byte

+ func (r *Reader) SwapString(v string) string

v0.1.0

Jun 12, 2022

Changes in this version

+ func Next() uint64

+ type Buffer struct

+ Column string

+ func NewBuffer(capacity int) *Buffer

+ func (b *Buffer) AddFloat32(idx uint32, value float32)

+ func (b *Buffer) AddFloat64(idx uint32, value float64)

+ func (b *Buffer) AddInt(idx uint32, value int)

+ func (b *Buffer) AddInt16(idx uint32, value int16)

+ func (b *Buffer) AddInt32(idx uint32, value int32)

+ func (b *Buffer) AddInt64(idx uint32, value int64)

+ func (b *Buffer) AddNumber(idx uint32, value float64)

+ func (b *Buffer) AddUint(idx uint32, value uint)

+ func (b *Buffer) AddUint16(idx uint32, value uint16)

+ func (b *Buffer) AddUint32(idx uint32, value uint32)

+ func (b *Buffer) AddUint64(idx uint32, value uint64)

+ func (b *Buffer) Clone() *Buffer

+ func (b *Buffer) IsEmpty() bool

+ func (b *Buffer) PutAny(op OpType, idx uint32, value interface{})

+ func (b *Buffer) PutBitmap(op OpType, chunk Chunk, value bitmap.Bitmap)

+ func (b *Buffer) PutBool(idx uint32, value bool)

+ func (b *Buffer) PutBytes(op OpType, idx uint32, value []byte)

+ func (b *Buffer) PutFloat32(idx uint32, value float32)

+ func (b *Buffer) PutFloat64(idx uint32, value float64)

+ func (b *Buffer) PutInt(idx uint32, value int)

+ func (b *Buffer) PutInt16(idx uint32, value int16)

+ func (b *Buffer) PutInt32(idx uint32, value int32)

+ func (b *Buffer) PutInt64(idx uint32, value int64)

+ func (b *Buffer) PutNumber(idx uint32, value float64)

+ func (b *Buffer) PutOperation(op OpType, idx uint32)

+ func (b *Buffer) PutString(op OpType, idx uint32, value string)

+ func (b *Buffer) PutUint(idx uint32, value uint)

+ func (b *Buffer) PutUint16(idx uint32, value uint16)

+ func (b *Buffer) PutUint32(idx uint32, value uint32)

+ func (b *Buffer) PutUint64(idx uint32, value uint64)

+ func (b *Buffer) RangeChunks(fn func(chunk Chunk))

+ func (b *Buffer) ReadFrom(src io.Reader) (int64, error)

+ func (b *Buffer) Reset(column string)

+ func (b *Buffer) WriteTo(dst io.Writer) (int64, error)

+ type Channel chan Commit

+ func (w Channel) Append(commit Commit) error

+ type Chunk uint32

+ func ChunkAt(index uint32) Chunk

+ func (c Chunk) Max() uint32

+ func (c Chunk) Min() uint32

+ func (c Chunk) OfBitmap(v bitmap.Bitmap) bitmap.Bitmap

+ func (c Chunk) Range(v bitmap.Bitmap, fn func(idx uint32))

+ type Commit struct

+ Chunk Chunk

+ ID uint64

+ Updates []*Buffer

+ func (c *Commit) Clone() (clone Commit)

+ func (c *Commit) ReadFrom(src io.Reader) (int64, error)

+ func (c *Commit) WriteTo(dst io.Writer) (int64, error)

+ type Log struct

+ func Open(source io.Reader) *Log

+ func OpenFile(filename string) (*Log, error)

+ func OpenTemp() (*Log, error)

+ func (l *Log) Append(commit Commit) (err error)

+ func (l *Log) Close() (err error)

+ func (l *Log) Copy(dst io.Writer) error

+ func (l *Log) Name() (name string)

+ func (l *Log) Range(fn func(Commit) error) error

+ type Logger interface

+ Append func(commit Commit) error

+ type OpType uint8

+ const Add

+ const Delete

+ const Insert

+ const Put

+ const PutFalse

+ const PutTrue

+ type Reader struct

+ Offset int32

+ Type OpType

+ func NewReader() *Reader

+ func (r *Reader) AddToFloat32(value float32) float32

+ func (r *Reader) AddToFloat64(value float64) float64

+ func (r *Reader) AddToInt(value int) int

+ func (r *Reader) AddToInt16(value int16) int16

+ func (r *Reader) AddToInt32(value int32) int32

+ func (r *Reader) AddToInt64(value int64) int64

+ func (r *Reader) AddToUint(value uint) uint

+ func (r *Reader) AddToUint16(value uint16) uint16

+ func (r *Reader) AddToUint32(value uint32) uint32

+ func (r *Reader) AddToUint64(value uint64) uint64

+ func (r *Reader) Bool() bool

+ func (r *Reader) Bytes() []byte

+ func (r *Reader) Float() float64

+ func (r *Reader) Float32() float32

+ func (r *Reader) Float64() float64

+ func (r *Reader) Index() uint32

+ func (r *Reader) IndexAtChunk() uint32

+ func (r *Reader) Int() int

+ func (r *Reader) Int16() int16

+ func (r *Reader) Int32() int32

+ func (r *Reader) Int64() int64

+ func (r *Reader) Next() bool

+ func (r *Reader) Number() float64

+ func (r *Reader) Range(buf *Buffer, chunk Chunk, fn func(*Reader))

+ func (r *Reader) Rewind()

+ func (r *Reader) Seek(b *Buffer)

+ func (r *Reader) String() string

+ func (r *Reader) SwapBool(b bool)

+ func (r *Reader) SwapFloat32(v float32)

+ func (r *Reader) SwapFloat64(v float64)

+ func (r *Reader) SwapInt(v int)

+ func (r *Reader) SwapInt16(v int16)

+ func (r *Reader) SwapInt32(v int32)

+ func (r *Reader) SwapInt64(v int64)

+ func (r *Reader) SwapUint(v uint)

+ func (r *Reader) SwapUint16(v uint16)

+ func (r *Reader) SwapUint32(v uint32)

+ func (r *Reader) SwapUint64(v uint64)

+ func (r *Reader) Uint() uint

+ func (r *Reader) Uint16() uint16

+ func (r *Reader) Uint32() uint32

+ func (r *Reader) Uint64() uint64

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL