Versions in this module Expand all Collapse all v0 v0.3.6 Oct 20, 2020 v0.3.5 Oct 19, 2020 v0.3.4 Oct 19, 2020 v0.3.3 Oct 18, 2020 v0.3.2 Oct 16, 2020 v0.3.1 Oct 10, 2020 v0.3.0 Sep 25, 2020 v0.2.10 Sep 8, 2020 v0.2.9 Sep 8, 2020 v0.2.8 Sep 7, 2020 v0.2.7 Sep 4, 2020 v0.2.6 Sep 3, 2020 v0.2.5 Sep 3, 2020 v0.2.4 Aug 24, 2020 Changes in this version + type Event struct + DelPath string + Entry *translate.PartialPeerstoreEntry + Op Operation + PeerID peer.ID + TimeMs uint64 + type EventTee struct + Fn func(evs ...*Event) + func (t *EventTee) OnBatch(puts []BatchItem, deletes []ds.Key) + func (t *EventTee) OnDelete(key ds.Key) + func (t *EventTee) OnPut(key ds.Key, value []byte) + func (t *EventTee) String() string + type Operation string + const Delete + const Put v0.2.3 Aug 11, 2020 Changes in this version + type BatchItem struct + Key ds.Key + Value []byte + type CSVTee struct + CSV *csv.Writer + Log logrus.FieldLogger + Name string + func (t *CSVTee) OnBatch(puts []BatchItem, deletes []ds.Key) + func (t *CSVTee) OnDelete(key ds.Key) + func (t *CSVTee) OnPut(key ds.Key, value []byte) + func (t *CSVTee) String() string + type DSTee struct + Tee Tee + func (t *DSTee) Batch() (ds.Batch, error) + func (t *DSTee) Delete(key ds.Key) error + func (t *DSTee) Put(key ds.Key, value []byte) error + type DSTeeBatch struct + Batch ds.Batch + Tee Tee + func (b *DSTeeBatch) Commit() error + func (b *DSTeeBatch) Delete(key ds.Key) error + func (b *DSTeeBatch) Put(key ds.Key, value []byte) error + func (b *DSTeeBatch) Reset() + type FilterTee struct + Inner Tee + Pattern *regexp.Regexp + func (t *FilterTee) OnBatch(puts []BatchItem, deletes []ds.Key) + func (t *FilterTee) OnDelete(key ds.Key) + func (t *FilterTee) OnPut(key ds.Key, value []byte) + func (t *FilterTee) String() string + type LogTee struct + Log logrus.FieldLogger + func (t *LogTee) OnBatch(puts []BatchItem, deletes []ds.Key) + func (t *LogTee) OnDelete(key ds.Key) + func (t *LogTee) OnPut(key ds.Key, value []byte) + func (t *LogTee) String() string + type MultiTee map[Tee]struct + func (m MultiTee) OnBatch(puts []BatchItem, deletes []ds.Key) + func (m MultiTee) OnDelete(key ds.Key) + func (m MultiTee) OnPut(key ds.Key, value []byte) + func (m MultiTee) String() string + type Tee interface + OnBatch func(puts []BatchItem, deletes []ds.Key) + OnDelete func(key ds.Key) + OnPut func(key ds.Key, value []byte) + String func() string
Go to main page