testing

Documentation

Index

• 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)
• type ChannelsFetcherMock
  • func NewChannelsFetcherMock(channels []string) *ChannelsFetcherMock
  • func (c ChannelsFetcherMock) GetChannels(ctx context.Context) (*peer.ChannelQueryResponse, 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)

type ChannelsFetcherMock

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

func NewChannelsFetcherMock

func NewChannelsFetcherMock(channels []string) *ChannelsFetcherMock

func (ChannelsFetcherMock) GetChannels

func (c ChannelsFetcherMock) GetChannels(ctx context.Context) (*peer.ChannelQueryResponse, error)