testing

package

v2.8.3-rc2 Latest Latest Go to latest Published: Oct 9, 2026 License: BSD-3-Clause Imports: 13 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/ethersphere/bee

Links

Open Source Insights

Documentation ¶

Overview ¶

package testing provides tests for update and resolution of time-based feeds

Index ¶

func TestFinderBasic(t *testing.T, finderf func(storage.Getter, *feeds.Feed) feeds.Lookup, ...)
func TestFinderFixIntervals(t *testing.T, nextf func() (bool, int64), ...)
func TestFinderIntervals(t *testing.T, nextf func() (bool, int64), ...)
func TestFinderRandomIntervals(t *testing.T, finderf func(storage.Getter, *feeds.Feed) feeds.Lookup, ...)
type Timeout
- func (t *Timeout) Get(ctx context.Context, addr swarm.Address) (swarm.Chunk, error)
- func (t *Timeout) GetInto(ctx context.Context, addr swarm.Address, buf []byte) (int, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func TestFinderBasic ¶

func TestFinderBasic(t *testing.T, finderf func(storage.Getter, *feeds.Feed) feeds.Lookup, updaterf func(putter storage.Putter, signer crypto.Signer, topic []byte) (feeds.Updater, error))

nolint:tparallel

func TestFinderFixIntervals ¶

func TestFinderFixIntervals(t *testing.T, nextf func() (bool, int64), finderf func(storage.Getter, *feeds.Feed) feeds.Lookup, updaterf func(putter storage.Putter, signer crypto.Signer, topic []byte) (feeds.Updater, error))

nolint:tparallel

func TestFinderIntervals ¶

func TestFinderIntervals(t *testing.T, nextf func() (bool, int64), finderf func(storage.Getter, *feeds.Feed) feeds.Lookup, updaterf func(putter storage.Putter, signer crypto.Signer, topic []byte) (feeds.Updater, error))

func TestFinderRandomIntervals ¶

func TestFinderRandomIntervals(t *testing.T, finderf func(storage.Getter, *feeds.Feed) feeds.Lookup, updaterf func(putter storage.Putter, signer crypto.Signer, topic []byte) (feeds.Updater, error))

Types ¶

type Timeout ¶

type Timeout struct {
	storage.ChunkStore
}

func (*Timeout) Get ¶

func (t *Timeout) Get(ctx context.Context, addr swarm.Address) (swarm.Chunk, error)

Get overrides the mock storer and introduces latency

func (*Timeout) GetInto ¶

func (t *Timeout) GetInto(ctx context.Context, addr swarm.Address, buf []byte) (int, error)

GetInto implements the ChunkStore interface. Without this override the promoted method would bypass the latency Get introduces.

Source Files ¶

View all Source files

lookup.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL