testutil

package

Go to main page

Versions in this module

v0

v0.13.12

May 28, 2024

v0.13.11

May 20, 2024

v0.13.10

Mar 26, 2024

v0.13.9

Sep 21, 2023

Changes in this version

type TestIdentityDAG

+ AllLinksNoIdent []ipld.Link

v0.13.8

Sep 20, 2023

Changes in this version

+ type TestIdentityDAG struct

+ AllLinks []ipld.Link

+ RootLink ipld.Link

+ func SetupIdentityDAG(ctx context.Context, t testing.TB, lsys ipld.LinkSystem) *TestIdentityDAG

+ func (tid *TestIdentityDAG) AllBlocks() []blocks.Block

+ func (tid *TestIdentityDAG) VerifyWholeDAG(ctx context.Context, responseChan <-chan graphsync.ResponseProgress)

v0.13.7

Aug 23, 2023

v0.13.6

Mar 27, 2023

Changes in this version

+ func AssertChannelEmpty(t testing.TB, channel interface{}, errorMessage string)

+ func AssertContainsBlock(t testing.TB, blks []blocks.Block, block blocks.Block)

+ func AssertContainsPeer(t testing.TB, peers []peer.ID, p peer.ID)

+ func AssertDoesReceive(ctx context.Context, t testing.TB, channel interface{}, errorMessage string)

+ func AssertDoesReceiveFirst(t testing.TB, channel interface{}, errorMessage string, ...)

+ func AssertReceive(ctx context.Context, t testing.TB, channel interface{}, out interface{}, ...)

+ func AssertReceiveFirst(t testing.TB, channel interface{}, out interface{}, errorMessage string, ...)

+ func AssertSends(ctx context.Context, t testing.TB, channel interface{}, in interface{}, ...)

+ func AttributeValueInTraceSpan(t *testing.T, stub tracetest.SpanStub, attributeName string) attribute.Value

+ func CollectErrors(ctx context.Context, t *testing.T, errChan <-chan error) []error

+ func CollectResponses(ctx context.Context, t testing.TB, ...) []graphsync.ResponseProgress

+ func ContainsBlock(blks []blocks.Block, block blocks.Block) bool

+ func ContainsPeer(peers []peer.ID, p peer.ID) bool

+ func EventInTraceSpan(t *testing.T, stub tracetest.SpanStub, eventName string) trace.Event

+ func GenerateBlocksOfSize(n int, size int64) []blocks.Block

+ func GenerateCids(n int) []cid.Cid

+ func GeneratePeers(n int) []peer.ID

+ func IndexOf(blks []blocks.Block, c cid.Cid) int

+ func NewFakeBlockData() graphsync.BlockData

+ func NewInvalidSelectorSpec() ipld.Node

+ func NewTestLink() ipld.Link

+ func NewTestStore(blocksWritten map[ipld.Link][]byte) ipld.LinkSystem

+ func NewUnparsableSelectorSpec() ipld.Node

+ func RandomBytes(n int64) []byte

+ func ReadNResponses(ctx context.Context, t testing.TB, ...) []graphsync.ResponseProgress

+ func RefuteContainsBlock(t testing.TB, blks []blocks.Block, block blocks.Block)

+ func RefuteContainsPeer(t testing.TB, peers []peer.ID, p peer.ID)

+ func RepeatTraceStrings(tmpl string, count int) []string

+ func SetupTracing(ctx context.Context) (context.Context, func(t *testing.T) *Collector)

+ func VerifyEmptyErrors(ctx context.Context, t testing.TB, errChan <-chan error)

+ func VerifyEmptyResponse(ctx context.Context, t testing.TB, ...)

+ func VerifyHasErrors(ctx context.Context, t testing.TB, errChan <-chan error)

+ func VerifySingleTerminalError(ctx context.Context, t testing.TB, errChan <-chan error)

+ type Collector struct

+ Spans tracetest.SpanStubs

+ func (c *Collector) ExportSpans(ctx context.Context, spans []trace.ReadOnlySpan) error

+ func (c *Collector) Shutdown(ctx context.Context) error

+ func (c Collector) FindParentSpans() tracetest.SpanStubs

+ func (c Collector) FindSpanByTraceString(trace string) *tracetest.SpanStub

+ func (c Collector) FindSpans(name string) tracetest.SpanStubs

+ func (c Collector) FindSpansWithParent(stub tracetest.SpanStub) tracetest.SpanStubs

+ func (c Collector) SingleExceptionEvent(t *testing.T, trace string, typeRe string, messageRe string, errorCode bool)

+ func (c Collector) TracesToStrings() []string

+ type DispatchedEvent struct

+ Event notifications.Event

+ Topic notifications.Topic

+ type ExceptionEvent struct

+ Message string

+ Type string

+ func EventAsException(t *testing.T, evt trace.Event) ExceptionEvent

+ type MockPublisher struct

+ func NewMockPublisher() *MockPublisher

+ func (mp *MockPublisher) AddSubscriber(subscriber notifications.Subscriber)

+ func (mp *MockPublisher) PublishEvents(topic notifications.Topic, events []notifications.Event)

+ type TestBlockChain struct

+ GenisisLink ipld.Link

+ GenisisNode ipld.Node

+ MiddleLinks []ipld.Link

+ MiddleNodes []ipld.Node

+ TipLink ipld.Link

+ TipNode ipld.Node

+ func SetupBlockChain(ctx context.Context, t testing.TB, lsys ipld.LinkSystem, size uint64, ...) *TestBlockChain

+ func (tbc *TestBlockChain) AllBlocks() []blocks.Block

+ func (tbc *TestBlockChain) Blocks(from int, to int) []blocks.Block

+ func (tbc *TestBlockChain) Chooser(ipld.Link, ipld.LinkContext) (ipld.NodePrototype, error)

+ func (tbc *TestBlockChain) LinkTipIndex(fromTip int) ipld.Link

+ func (tbc *TestBlockChain) NodeTipIndex(fromTip int) ipld.Node

+ func (tbc *TestBlockChain) PathTipIndex(fromTip int) ipld.Path

+ func (tbc *TestBlockChain) RemainderBlocks(from int) []blocks.Block

+ func (tbc *TestBlockChain) Selector() ipld.Node

+ func (tbc *TestBlockChain) VerifyRemainder(ctx context.Context, responseChan <-chan graphsync.ResponseProgress, from int)

+ func (tbc *TestBlockChain) VerifyRemainderSync(responses []graphsync.ResponseProgress, from int)

+ func (tbc *TestBlockChain) VerifyRemainderWithTypes(ctx context.Context, responseChan <-chan graphsync.ResponseProgress, from int)

+ func (tbc *TestBlockChain) VerifyResponseRange(ctx context.Context, responseChan <-chan graphsync.ResponseProgress, from int, ...)

+ func (tbc *TestBlockChain) VerifyResponseRangeSync(responses []graphsync.ResponseProgress, from int, to int)

+ func (tbc *TestBlockChain) VerifyWholeChain(ctx context.Context, responseChan <-chan graphsync.ResponseProgress)

+ func (tbc *TestBlockChain) VerifyWholeChainSync(responses []graphsync.ResponseProgress)

+ func (tbc *TestBlockChain) VerifyWholeChainWithTypes(ctx context.Context, responseChan <-chan graphsync.ResponseProgress)

+ type TestConnManager struct

+ func NewTestConnManager() *TestConnManager

+ func (tcm *TestConnManager) AssertProtected(t testing.TB, p peer.ID)

+ func (tcm *TestConnManager) AssertProtectedWithTags(t testing.TB, p peer.ID, tags ...string)

+ func (tcm *TestConnManager) Protect(p peer.ID, tag string)

+ func (tcm *TestConnManager) RefuteProtected(t testing.TB, p peer.ID)

+ func (tcm *TestConnManager) RefuteProtectedWithTags(t testing.TB, p peer.ID, tags ...string)

+ func (tcm *TestConnManager) Unprotect(p peer.ID, tag string) bool

+ type TestIPLDTree struct

+ LeafAlpha ipld.Node

+ LeafAlphaBlock blocks.Block

+ LeafAlphaLnk ipld.Link

+ LeafBeta ipld.Node

+ LeafBetaBlock blocks.Block

+ LeafBetaLnk ipld.Link

+ MiddleListBlock blocks.Block

+ MiddleListNode ipld.Node

+ MiddleListNodeLnk ipld.Link

+ MiddleMapBlock blocks.Block

+ MiddleMapNode ipld.Node

+ MiddleMapNodeLnk ipld.Link

+ RootBlock blocks.Block

+ RootNode ipld.Node

+ RootNodeLnk ipld.Link

+ Storage map[ipld.Link][]byte

+ func NewTestIPLDTree() TestIPLDTree

+ type TestSubscriber struct

+ func NewTestSubscriber(bufferSize int) *TestSubscriber

+ func (ts *TestSubscriber) ExpectCloses(ctx context.Context, t *testing.T, topics []notifications.Topic)

+ func (ts *TestSubscriber) ExpectClosesAnyOrder(ctx context.Context, t *testing.T, topics []notifications.Topic)

+ func (ts *TestSubscriber) ExpectEvents(ctx context.Context, t *testing.T, events []DispatchedEvent)

+ func (ts *TestSubscriber) ExpectEventsAllTopics(ctx context.Context, t *testing.T, events []notifications.Event)

+ func (ts *TestSubscriber) ExpectNCloses(ctx context.Context, t *testing.T, n int)

+ func (ts *TestSubscriber) NoEventsReceived(t *testing.T)

+ func (ts *TestSubscriber) OnClose(topic notifications.Topic)

+ func (ts *TestSubscriber) OnNext(topic notifications.Topic, ev notifications.Event)

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