bzzdb

Documentation

Index

• type FeedIndexFetcher
• type FeedIndexer
  • func NewFeedIndexer(indexFetcher FeedIndexFetcher, owner common.Address) *FeedIndexer
  • func (i *FeedIndexer) AcquireNext(ctx context.Context, topic client.Topic) (Index, error)
  • func (i *FeedIndexer) Current(ctx context.Context, topic client.Topic) (Index, bool, error)
  • func (i *FeedIndexer) Release(topic client.Topic, index Index)
• type Index
• type KeyValueStore
  • func New(privateKey *ecdsa.PrivateKey, beeCli client.Client, postage postage.Postage) (KeyValueStore, error)

Types

type FeedIndexFetcher

type FeedIndexFetcher interface {
	FeedIndexLatest(
		ctx context.Context,
		owner common.Address,
		topic client.Topic,
	) (client.FeedIndexResponse, error)
}

type FeedIndexer

type FeedIndexer struct {
	// contains filtered or unexported fields
}

func NewFeedIndexer

func NewFeedIndexer(indexFetcher FeedIndexFetcher, owner common.Address) *FeedIndexer

func (*FeedIndexer) AcquireNext

func (i *FeedIndexer) AcquireNext(ctx context.Context, topic client.Topic) (Index, error)

func (*FeedIndexer) Current

func (i *FeedIndexer) Current(ctx context.Context, topic client.Topic) (Index, bool, error)

func (*FeedIndexer) Release

func (i *FeedIndexer) Release(topic client.Topic, index Index)

type Index

type Index = uint64

type KeyValueStore

type KeyValueStore interface {
	Has(key []byte) (bool, error)
	Get(key []byte) ([]byte, error)
	Put(key []byte, value []byte) error
	Delete(key []byte) error
	io.Closer
}

KeyValueStore is local interface matching ethereum's ethdb.KeyValueStore. Currently this interface only has minimum set of method to cover the most basic operations. Over time this interface should expand to fully match ethdb.KeyValueStore interface.

func New

func New(
	privateKey *ecdsa.PrivateKey,
	beeCli client.Client,
	postage postage.Postage,
) (KeyValueStore, error)