filters

Apr 20, 2023

Changes in this version

+ const UpdateInterval

+ func NewFilteredBlockstore(bstore blockstore.Blockstore, filter Filter) blockstore.Blockstore

+ type BlockFilter struct

+ func NewBlockFilter() *BlockFilter

+ func (bf *BlockFilter) FulfillRequest(p peer.ID, c cid.Cid) (bool, error)

+ func (bf *BlockFilter) ParseUpdate(stream io.Reader) error

+ type ConfigFilter struct

+ func NewConfigFilter() *ConfigFilter

+ func (cf *ConfigFilter) FulfillRequest(p peer.ID, c cid.Cid) (bool, error)

+ func (cf *ConfigFilter) ParseUpdate(stream io.Reader) error

+ type Fetcher func(lastFetchTime time.Time) (bool, io.ReadCloser, error)

+ func FetcherForHTTPEndpoint(endpoint string, authHeader string) Fetcher

+ type Filter interface

+ FulfillRequest func(p peer.ID, c cid.Cid) (bool, error)

+ type FilterDefinition struct

+ CacheFile string

+ Fetcher Fetcher

+ Handler Handler

+ type FilteredBlockstore struct

+ func (f *FilteredBlockstore) Get(ctx context.Context, c cid.Cid) (blocks.Block, error)

+ func (f *FilteredBlockstore) GetSize(ctx context.Context, c cid.Cid) (int, error)

+ func (f *FilteredBlockstore) Has(ctx context.Context, c cid.Cid) (bool, error)

+ type Handler interface

+ ParseUpdate func(io.Reader) error

+ type MultiFilter struct

+ func NewMultiFilter(cfgDir string, apiFilterEndpoint string, apiFilterAuth string, ...) *MultiFilter

+ func NewMultiFilterWithConfigs(cfgDir string, filterDefinitions []FilterDefinition, clock clock.Clock, ...) *MultiFilter

+ func (mf *MultiFilter) Close()

+ func (mf *MultiFilter) FulfillRequest(p peer.ID, c cid.Cid) (bool, error)

+ func (mf *MultiFilter) Start(ctx context.Context) error

+ type PeerListType string

+ const AllowList

+ const DenyList