engine

Jun 16, 2023

Changes in this version

type Option

+ func WithCache(cache cache.Interface) Option

May 24, 2023

Changes in this version

type Option

+ func WithDHKeyShard(enabled bool) Option

+ func WithDHShardConcurrency(n int) Option

May 3, 2023

Changes in this version

type Option

+ func WithDHStoreCluster(clusterUrls []string) Option

Feb 20, 2023

Changes in this version

type Option

+ func WithHttpClientTimeout(timeout time.Duration) Option

Jan 20, 2023

Changes in this version

+ type Engine struct

+ func New(resultCache cache.Interface, valueStore indexer.Interface, options ...Option) *Engine

+ func (e *Engine) Close() error

+ func (e *Engine) Flush() error

+ func (e *Engine) Get(m multihash.Multihash) ([]indexer.Value, bool, error)

+ func (e *Engine) Iter() (indexer.Iterator, error)

+ func (e *Engine) Put(value indexer.Value, mhs ...multihash.Multihash) error

+ func (e *Engine) Remove(value indexer.Value, mhs ...multihash.Multihash) error

+ func (e *Engine) RemoveProvider(ctx context.Context, providerID peer.ID) error

+ func (e *Engine) RemoveProviderContext(providerID peer.ID, contextID []byte) error

+ func (e *Engine) Size() (int64, error)

+ func (e *Engine) Stats() (*indexer.Stats, error)

+ type Option func(*config) error

+ func WithCacheOnPut(on bool) Option

+ func WithDHBatchSize(size int) Option

+ func WithDHStore(dhsURL string) Option

+ func WithVSNoNewMH(ok bool) Option