metadata

package module

Go to main page

Versions in this module

v0

v0.0.7

Jul 23, 2025

Changes in this version

type JSONIndex

+ func (J *JSONIndex) GetAll() ([]*IndexEntry, error)

type RedisIndex

+ func (r *RedisIndex) GetAll() ([]*IndexEntry, error)

type TableIndex

+ GetAll func() ([]*IndexEntry, error)

v0.0.6

Jul 17, 2025

v0.0.5

Jul 17, 2025

Changes in this version

+ type KVStoreIndex interface

+ Delete func(key string) error

+ Destroy func()

+ Get func(key string) ([]byte, error)

+ Put func(key string, value []byte) error

+ func NewJSONKVStoreIndex(path string) (KVStoreIndex, error)

+ func NewRedisKVStore(URL string) (KVStoreIndex, error)

v0.0.4

Jun 10, 2025

Changes in this version

type DBIndex

+ func NewJSONDBIndex(layers []Layer) DBIndex

+ type DropPlan struct

+ Database string

+ ID string

+ Layer string

+ Path string

+ Table string

+ TimeS int32

+ WriterID string

+ func (d DropPlan) Id() string

+ type Identified interface

+ Id func() string

type IndexEntry

+ WriterID string

type JSONIndex

+ func (J *JSONIndex) EndMove(plan MovePlan) Promise[int32]

+ func (J *JSONIndex) GetDropPlanner() TableDropPlanner

+ func (J *JSONIndex) GetMovePlan(writerId string, layer string) (MovePlan, error)

+ func (J *JSONIndex) GetMovePlanner() TableMovePlanner

+ type Layer struct

+ Name string

+ TTLSec int32

+ Type string

+ URL string

type MergeConfigurationsConf

+ func (m MergeConfigurationsConf) MaxSize() int64

+ func (m MergeConfigurationsConf) MergeIterationId() int64

+ func (m MergeConfigurationsConf) TimeoutSec() int64

type MergePlan

+ WriterID string

+ func (m MergePlan) Id() string

+ type MovePlan struct

+ Database string

+ ID string

+ LayerFrom string

+ LayerTo string

+ PathFrom string

+ PathTo string

+ Table string

+ WriterID string

+ func (m MovePlan) Id() string

type RedisIndex

+ func (r *RedisIndex) EndMove(plan MovePlan) Promise[int32]

+ func (r *RedisIndex) GetDropPlanner() TableDropPlanner

+ func (r *RedisIndex) GetMovePlan(writerId string, layer string) (MovePlan, error)

+ func (r *RedisIndex) GetMovePlanner() TableMovePlanner

+ type TableDropPlanner interface

+ GetDropQueue func(writerId string, layer string) (DropPlan, error)

+ RmFromDropQueue func(plan DropPlan) Promise[int32]

type TableIndex

+ GetDropPlanner func() TableDropPlanner

+ GetMovePlanner func() TableMovePlanner

+ type TableMovePlanner interface

+ EndMove func(plan MovePlan) Promise[int32]

+ GetMovePlan func(writerId string, layer string) (MovePlan, error)

v0.0.3

May 27, 2025

v0.0.2

May 26, 2025

Changes in this version

+ type TableMergePlanner interface

+ EndMerge func(plan *MergePlan) error

+ GetMergePlan func(layer string, iteration int) (*MergePlan, error)

+ type TableQuerier interface

+ Query func(options QueryOptions) ([]*IndexEntry, error)

v0.0.1

May 23, 2025

Changes in this version

+ var END_MERGE_SCRIPT []byte

+ var GET_MERGE_PLAN_SCRIPT []byte

+ var SCRIPT_PATCH_INDEX []byte

+ type DBIndex interface

+ Databases func() ([]string, error)

+ Paths func(database string, table string) ([]string, error)

+ Tables func(database string) ([]string, error)

+ func NewRedisDbIndex(URL string) (DBIndex, error)

+ type IndexEntry struct

+ ChunkTime int64

+ Database string

+ Layer string

+ Max map[string]any

+ MaxTime int64

+ Min map[string]any

+ MinTime int64

+ Path string

+ RowCount int64

+ SizeBytes int64

+ Table string

+ type JSONIndex struct

+ func (J *JSONIndex) Batch(add []*IndexEntry, rm []*IndexEntry) Promise[int32]

+ func (J *JSONIndex) EndMerge(plan *MergePlan) error

+ func (J *JSONIndex) Get(_path string) *IndexEntry

+ func (J *JSONIndex) GetDropQueue() []string

+ func (J *JSONIndex) GetMergePlan(layer string, database string, table string, iteration int) (*MergePlan, error)

+ func (J *JSONIndex) GetMergePlanner() MergePlanner

+ func (J *JSONIndex) GetQuerier() Querier

+ func (J *JSONIndex) Query(options QueryOptions) ([]*IndexEntry, error)

+ func (J *JSONIndex) RmFromDropQueue(files []string) Promise[int32]

+ func (J *JSONIndex) Run()

+ func (J *JSONIndex) Stop()

+ type MergeConfigurationsConf [][3]int64

+ var MergeConfigurations MergeConfigurationsConf

+ type MergePlan struct

+ Database string

+ From []string

+ ID string

+ Iteration int

+ Layer string

+ Table string

+ To string

+ type MergePlanner interface

+ EndMerge func(plan *MergePlan) error

+ GetMergePlan func(layer string, database string, table string, iteration int) (*MergePlan, error)

+ type Promise interface

+ Done func(res T, err error)

+ Get func() (T, error)

+ Peek func() (int32, T, error)

+ func Fulfilled[T any](err error, res T) Promise[T]

+ func NewPromise[T any]() Promise[T]

+ func NewWaitForAll[T any](promises []Promise[T]) Promise[T]

+ type QEntry struct

+ Path string

+ TimeS int32

+ type Querier interface

+ Query func(options QueryOptions) ([]*IndexEntry, error)

+ type QueryOptions struct

+ After time.Time

+ Before time.Time

+ Database string

+ Folder string

+ Iteration int

+ Table string

+ type RedisIndex struct

+ func (r *RedisIndex) AddToDropQueue(files []string) Promise[int32]

+ func (r *RedisIndex) Batch(add []*IndexEntry, rm []*IndexEntry) Promise[int32]

+ func (r *RedisIndex) EndMerge(plan *MergePlan) error

+ func (r *RedisIndex) Get(path string) *IndexEntry

+ func (r *RedisIndex) GetDropQueue() []string

+ func (r *RedisIndex) GetMergePlan(layer string, database string, table string, iteration int) (*MergePlan, error)

+ func (r *RedisIndex) GetMergePlanner() MergePlanner

+ func (r *RedisIndex) GetQuerier() Querier

+ func (r *RedisIndex) Query(options QueryOptions) ([]*IndexEntry, error)

+ func (r *RedisIndex) RmFromDropQueue(files []string) Promise[int32]

+ func (r *RedisIndex) Run()

+ func (r *RedisIndex) Stop()

+ type SinglePromise struct

+ func (p *SinglePromise[T]) Done(res T, err error)

+ func (p *SinglePromise[T]) Get() (T, error)

+ func (p *SinglePromise[T]) Peek() (int32, T, error)

+ type TableIndex interface

+ Batch func(add []*IndexEntry, rm []*IndexEntry) Promise[int32]

+ Get func(path string) *IndexEntry

+ GetDropQueue func() []string

+ GetMergePlanner func() MergePlanner

+ GetQuerier func() Querier

+ RmFromDropQueue func(files []string) Promise[int32]

+ Run func()

+ Stop func()

+ func NewJSONIndex(root string, database string, table string) TableIndex

+ func NewRedisIndex(URL string) (TableIndex, error)

+ type WaitForAllPromise struct

+ func (p *WaitForAllPromise[T]) Add(promise Promise[T])

+ func (p *WaitForAllPromise[T]) Done(res T, err error)

+ func (p *WaitForAllPromise[T]) Get() (T, error)

+ func (p *WaitForAllPromise[T]) Peek() (int32, T, error)

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