testing

Documentation

Overview

Package testing provides test implementations of retieval market interfaces

Index

• Variables
• type TestProviderDealEnvironment
  • func NewTestProviderDealEnvironment(node rm.RetrievalProviderNode) *TestProviderDealEnvironment
  • func (te *TestProviderDealEnvironment) ChannelState(_ context.Context, _ datatransfer.ChannelID) (datatransfer.ChannelState, error)
  • func (te *TestProviderDealEnvironment) CloseDataTransfer(_ context.Context, _ datatransfer.ChannelID) error
  • func (te *TestProviderDealEnvironment) DeleteStore(dealID rm.DealID) error
  • func (te *TestProviderDealEnvironment) Node() rm.RetrievalProviderNode
  • func (te *TestProviderDealEnvironment) PrepareBlockstore(ctx context.Context, dealID rm.DealID, pieceCid cid.Cid) error
  • func (te *TestProviderDealEnvironment) ResumeDataTransfer(_ context.Context, _ datatransfer.ChannelID) error
  • func (te *TestProviderDealEnvironment) UpdateValidationStatus(_ context.Context, _ datatransfer.ChannelID, ...) error

Variables

var TrivialTestDecider retrievalimpl.DealDecider = func(_ context.Context, _ rm.ProviderDealState) (bool, string, error) {
	return true, "", nil
}

TrivialTestDecider is a shortest possible DealDecider that accepts all deals

Types

type TestProviderDealEnvironment

type TestProviderDealEnvironment struct {
	ResumeDataTransferError     error
	PrepareBlockstoreError      error
	CloseDataTransferError      error
	DeleteStoreError            error
	ReturnedChannelState        datatransfer.ChannelState
	ChannelStateError           error
	NewValidationStatus         datatransfer.ValidationResult
	UpdateValidationStatusError error
	// contains filtered or unexported fields
}

TestProviderDealEnvironment is a test implementation of ProviderDealEnvironment used by the provider state machine.

func NewTestProviderDealEnvironment

func NewTestProviderDealEnvironment(node rm.RetrievalProviderNode) *TestProviderDealEnvironment

NewTestProviderDealEnvironment returns a new TestProviderDealEnvironment instance

func (*TestProviderDealEnvironment) ChannelState

func (te *TestProviderDealEnvironment) ChannelState(_ context.Context, _ datatransfer.ChannelID) (datatransfer.ChannelState, error)

func (*TestProviderDealEnvironment) CloseDataTransfer

func (te *TestProviderDealEnvironment) CloseDataTransfer(_ context.Context, _ datatransfer.ChannelID) error

func (*TestProviderDealEnvironment) DeleteStore

func (te *TestProviderDealEnvironment) DeleteStore(dealID rm.DealID) error

func (*TestProviderDealEnvironment) Node

func (te *TestProviderDealEnvironment) Node() rm.RetrievalProviderNode

Node returns a provider node instance

func (*TestProviderDealEnvironment) PrepareBlockstore

func (te *TestProviderDealEnvironment) PrepareBlockstore(ctx context.Context, dealID rm.DealID, pieceCid cid.Cid) error

func (*TestProviderDealEnvironment) ResumeDataTransfer

func (te *TestProviderDealEnvironment) ResumeDataTransfer(_ context.Context, _ datatransfer.ChannelID) error

func (*TestProviderDealEnvironment) UpdateValidationStatus

func (te *TestProviderDealEnvironment) UpdateValidationStatus(_ context.Context, _ datatransfer.ChannelID, status datatransfer.ValidationResult) error