mocks

Documentation

Index

• Constants
• Variables
• func NewBlockEvent(block *cb.Block, sourceURL string) *connection.Event
• func NewFilteredBlockEvent(fblock *pb.FilteredBlock, sourceURL string) *connection.Event
• type MockConnection
  • func NewConnection(opts ...clientmocks.Opt) *MockConnection
  • func (c *MockConnection) Receive(eventch chan<- interface{})
  • func (c *MockConnection) Send(sinfo *ab.SeekInfo) error

Constants

const (
	// Connect is the Connect operation (used in the OperationMap)
	Connect clientmocks.Operation = "connect"

	// BadRequestResult indicates that the operation should use invalid seek info
	BadRequestResult clientmocks.Result = "bad-request"

	// ForbiddenResult indicates that the user does not have permission to perform the operation
	ForbiddenResult clientmocks.Result = "forbidden"
)

Variables

var BlockEventFactory = func(block servicemocks.Block, sourceURL string) servicemocks.BlockEvent {
	b, ok := block.(*servicemocks.BlockWrapper)
	if !ok {
		panic(fmt.Sprintf("Invalid block type: %T", block))
	}
	return NewBlockEvent(b.Block(), sourceURL)
}

BlockEventFactory creates block events

var FilteredBlockEventFactory = func(block servicemocks.Block, sourceURL string) servicemocks.BlockEvent {
	b, ok := block.(*servicemocks.FilteredBlockWrapper)
	if !ok {
		panic(fmt.Sprintf("Invalid block type: %T", block))
	}
	return NewFilteredBlockEvent(b.Block(), sourceURL)
}

FilteredBlockEventFactory creates filtered block events

Functions

func NewBlockEvent

func NewBlockEvent(block *cb.Block, sourceURL string) *connection.Event

NewBlockEvent returns a new mock block event initialized with the given block

func NewFilteredBlockEvent

func NewFilteredBlockEvent(fblock *pb.FilteredBlock, sourceURL string) *connection.Event

NewFilteredBlockEvent returns a new mock filtered block event initialized with the given filtered block

Types

type MockConnection

type MockConnection struct {
	clientmocks.MockConnection
}

MockConnection is a fake connection used for unit testing

func NewConnection

func NewConnection(opts ...clientmocks.Opt) *MockConnection

NewConnection returns a new MockConnection using the given options

func (*MockConnection) Receive

func (c *MockConnection) Receive(eventch chan<- interface{})

Receive implements the MockConnection interface

func (*MockConnection) Send

func (c *MockConnection) Send(sinfo *ab.SeekInfo) error

Send mockcore sending seek info to the deliver server