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(_ context.Context, channelName string, _ msp.SigningIdentity, ...) (<-chan *common.Block, func() error, error)
  • func (m *BlocksDelivererMock) ParsedBlocks(_ context.Context, channelName string, _ msp.SigningIdentity, ...) (<-chan *hlfproto.Block, func() error, 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(
	_ context.Context,
	channelName string,
	_ msp.SigningIdentity,
	blockRange ...int64,
) (<-chan *common.Block, func() error, error)

func (*BlocksDelivererMock) ParsedBlocks

func (m *BlocksDelivererMock) ParsedBlocks(
	_ context.Context,
	channelName string,
	_ msp.SigningIdentity,
	blockRange ...int64,
) (<-chan *hlfproto.Block, func() error, error)