sbt

Feb 21, 2023

Changes in this version

+ const Bucket10

+ const Bucket100

+ const Bucket100k

+ const Bucket10k

+ const Bucket10m

+ const Bucket1k

+ const Bucket1m

+ const MagicNumber

+ var ErrClosed = errors.New("use of closed BulkIO")

+ func ByteToStringPadded(b []byte) string

+ func StringToBytePadded(s string, length int) []byte

+ type BulkAppendContext struct

+ func NewBulkAppendContext(bucketSize int64) *BulkAppendContext[P, RT]

+ func (w *BulkAppendContext[P, RT]) Append(c *Container[P, RT], row P) error

+ func (w *BulkAppendContext[P, RT]) Close(c *Container[P, RT]) error

+ type BulkIO interface

+ Close func(c *Container[P, RT]) error

+ type Column struct

+ Name string

+ Size uint8

+ Type ColumnType

+ func NewColumn(name string, typ ColumnType, size ...uint8) (c Column)

+ type ColumnPrinter func(row P) []any

+ type ColumnType string

+ const ColumnTypeBinary

+ const ColumnTypeBool

+ const ColumnTypeFloat32

+ const ColumnTypeFloat64

+ const ColumnTypeInt16

+ const ColumnTypeInt32

+ const ColumnTypeInt64

+ const ColumnTypeInt8

+ const ColumnTypeString

+ const ColumnTypeUInt16

+ const ColumnTypeUInt32

+ const ColumnTypeUInt64

+ const ColumnTypeUInt8

+ func (c ColumnType) New(name string, size ...uint8) Column

+ type Container struct

+ func Create(filename string) (b *Container[P, RowType], err error)

+ func Load(filename string) (b *Container[P, RowType], err error)

+ func Open(filename string) (b *Container[P, RowType], err error)

+ func OpenRead(filename string) (b *Container[P, RowType], err error)

+ func (c *Container[P, RowType]) Append(row P) (err error)

+ func (c *Container[P, RowType]) AsIterable() generics.Iterable[containers.Tuple[int64, P]]

+ func (c *Container[P, RowType]) BulkAppend(rows []P) (err error)

+ func (c *Container[P, RowType]) BulkRead(pos int64, rows []P) (n int64, err error)

+ func (c *Container[P, RowType]) BulkSet(index int64, rows []P) (err error)

+ func (c *Container[P, RowType]) Close() (err error)

+ func (c *Container[P, RowType]) Filename() string

+ func (c *Container[P, RowType]) Header() RowSpec

+ func (c *Container[P, RowType]) Iter() *generics.Iterator[containers.Tuple[int64, P]]

+ func (c *Container[P, RowType]) IterBucketSize(bucketSize int64) *generics.Iterator[containers.Tuple[int64, P]]

+ func (c *Container[P, RowType]) IterHandler(iter *generics.Iterator[containers.Tuple[int64, P]])

+ func (c *Container[P, RowType]) NumRows() int64

+ func (c *Container[P, RowType]) Print(out io.Writer, start, count int64, pf ColumnPrinter[P, RowType]) error

+ func (c *Container[P, RowType]) ReadAt(pos int64, row P) (err error)

+ func (c *Container[P, RowType]) SeekContent() (err error)

+ func (c *Container[P, RowType]) SeekEnd() (err error)

+ func (c *Container[P, RowType]) Set(row P, index int64) (err error)

+ func (c *Container[P, RowType]) Size() int64

+ func (c *Container[P, RowType]) Version() uint8

+ type Decoder struct

+ func NewDecoder(buffer []byte) *Decoder

+ func (d *Decoder) DecodeBool() bool

+ func (d *Decoder) DecodeBytes(size int) []byte

+ func (d *Decoder) DecodeFloat32() float32

+ func (d *Decoder) DecodeFloat64() float64

+ func (d *Decoder) DecodeInt16() int16

+ func (d *Decoder) DecodeInt32() int32

+ func (d *Decoder) DecodeInt64() int64

+ func (d *Decoder) DecodeInt8() int8

+ func (d *Decoder) DecodeStringPadded(size int) string

+ func (d *Decoder) DecodeTime() time.Time

+ func (d *Decoder) DecodeUInt16() uint16

+ func (d *Decoder) DecodeUInt32() uint32

+ func (d *Decoder) DecodeUInt64() uint64

+ func (d *Decoder) DecodeUInt8() uint8

+ type Encoder struct

+ func NewEncoder(buffer []byte) *Encoder

+ func (e *Encoder) EncodeBool(v bool)

+ func (e *Encoder) EncodeBytesPadded(b []byte, size int)

+ func (e *Encoder) EncodeFloat32(v float32)

+ func (e *Encoder) EncodeFloat64(v float64)

+ func (e *Encoder) EncodeInt16(v int16)

+ func (e *Encoder) EncodeInt32(v int32)

+ func (e *Encoder) EncodeInt64(v int64)

+ func (e *Encoder) EncodeInt8(v int8)

+ func (e *Encoder) EncodeStringPadded(s string, size int)

+ func (e *Encoder) EncodeTime(t time.Time)

+ func (e *Encoder) EncodeUInt16(v uint16)

+ func (e *Encoder) EncodeUInt32(v uint32)

+ func (e *Encoder) EncodeUInt64(v uint64)

+ func (e *Encoder) EncodeUInt8(v uint8)

+ type Row interface

+ Columns func() RowSpec

+ Decode func(ctx *Decoder) error

+ Encode func(ctx *Encoder) error

+ Factory func() Row

+ type RowSerializerBase struct

+ func (s *RowSerializerBase) Bytes() []byte

+ func (s *RowSerializerBase) Reset(buffer []byte)

+ type RowSpec []Column

+ func NewRowSpec(columns ...Column) (r RowSpec)

+ func (s RowSpec) RowSize() (size uint8)