testing

Documentation

Index

• func NewDeliverClient(rootPath string, closeWhenAllRead bool) (peer.DeliverClient, error)
• type BlocksDelivererMock
  • func NewBlocksDelivererMock(rootPath string, closeWhenAllRead bool) (*BlocksDelivererMock, error)
  • func (m *BlocksDelivererMock) Blocks(ctx context.Context, channelName string, identity msp.SigningIdentity, ...) (blockChan <-chan *common.Block, closer func() error, err error)

Functions

func NewDeliverClient

func NewDeliverClient(rootPath string, closeWhenAllRead bool) (peer.DeliverClient, error)

Types

type BlocksDelivererMock

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

func NewBlocksDelivererMock

func NewBlocksDelivererMock(rootPath string, closeWhenAllRead bool) (*BlocksDelivererMock, error)

NewBlocksDelivererMock - read all blocks in proto format from provided folder. returns sdkapi.BlocksDeliverer - interface closeWhenAllRead - close channel when all data have been written closerFunc - close func that will be returned from Blocks()

func (*BlocksDelivererMock) Blocks

func (m *BlocksDelivererMock) Blocks(
	ctx context.Context,
	channelName string,
	identity msp.SigningIdentity,
	blockRange ...int64,
) (blockChan <-chan *common.Block, closer func() error, err error)