crdt

Sep 26, 2022

Changes in this version

type Datastore

+ func (store *Datastore) InternalStats() Stats

+ func (store *Datastore) IsDirty() bool

+ func (store *Datastore) MarkClean()

+ func (store *Datastore) MarkDirty()

+ type Stats struct

+ Heads []cid.Cid

+ MaxHeight uint64

+ QueuedJobs int

Feb 15, 2022

Changes in this version

type Options

+ MultiHeadProcessing bool

Feb 1, 2022

Changes in this version

type Datastore

+ func (store *Datastore) Repair() error

type Options

+ RepairInterval time.Duration

+ type SessionDAGService interface

+ Session func(context.Context) ipld.NodeGetter

Jan 11, 2022

Changes in this version

type Datastore

+ func (store *Datastore) DotDAG(w io.Writer) error

Dec 17, 2021

Changes in this version

+ var TombstonesBloomFilterHashes float64 = 2

+ var TombstonesBloomFilterSize float64 = 30 * 1024 * 1024 * 8

Apr 11, 2020

Changes in this version

type Datastore

+ func (store *Datastore) Sync(prefix ds.Key) error

Aug 27, 2019

Changes in this version

type Options

+ MaxBatchDeltaSize int

May 21, 2019

Changes in this version

type Options

+ DAGSyncerTimeout time.Duration

+ NumWorkers int

+ type SessionDAGSyncer interface

+ Session func(context.Context) ipld.NodeGetter

Apr 16, 2019

Changes in this version

type DAGSyncer

+ HasBlock func(c cid.Cid) (bool, error)

Apr 15, 2019

Changes in this version

+ type PubSubBroadcaster struct

+ func NewPubSubBroadcaster(ctx context.Context, psub *pubsub.PubSub, topic string) (*PubSubBroadcaster, error)

+ func (pbc *PubSubBroadcaster) Broadcast(data []byte) error

+ func (pbc *PubSubBroadcaster) Next() ([]byte, error)

Apr 11, 2019

Changes in this version

type Options

+ DeleteHook func(k ds.Key)

+ PutHook func(k ds.Key, v []byte)

Mar 26, 2019

Changes in this version

+ var ErrNoMoreBroadcast = errors.New("receiving blocks aborted since no new blocks will be broadcasted")

+ type Broadcaster interface

+ Broadcast func([]byte) error

+ Next func() ([]byte, error)

+ type DAGSyncer interface

+ IsKnownBlock func(c cid.Cid) (bool, error)

+ type Datastore struct

+ func New(store ds.Datastore, namespace ds.Key, dagSyncer DAGSyncer, bcast Broadcaster, ...) *Datastore

+ func (store *Datastore) Batch() (ds.Batch, error)

+ func (store *Datastore) Close() error

+ func (store *Datastore) Delete(key ds.Key) error

+ func (store *Datastore) Get(key ds.Key) (value []byte, err error)

+ func (store *Datastore) GetSize(key ds.Key) (size int, err error)

+ func (store *Datastore) Has(key ds.Key) (exists bool, err error)

+ func (store *Datastore) IsThreadSafe()

+ func (store *Datastore) PrintDAG() error

+ func (store *Datastore) Put(key ds.Key, value []byte) error

+ func (store *Datastore) Query(q query.Query) (query.Results, error)

+ type Options struct

+ Logger logging.StandardLogger

+ RebroadcastInterval time.Duration

+ func DefaultOptions() *Options