mocks

Documentation

Index

• Constants
• Variables
• func NewBlockEvent(block *cb.Block) *pb.Event
• func NewFilteredBlockEvent(fblock *pb.FilteredBlock) *pb.Event
• type MockConnection
  • func NewConnection(opts ...clientmocks.Opt) *MockConnection
  • func (c *MockConnection) Send(emsg *pb.Event) error

Constants

const (
	// RegInterests is the register operation (used in the OperationMap)
	RegInterests clientmocks.Operation = "reg-interests"

	// UnregInterests is the unregister operation (used in the OperationMap)
	UnregInterests clientmocks.Operation = "unreg-interests"
)

Variables

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

BlockEventFactory creates block events

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

FilteredBlockEventFactory creates filtered block events

Functions

func NewBlockEvent

func NewBlockEvent(block *cb.Block) *pb.Event

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

func NewFilteredBlockEvent

func NewFilteredBlockEvent(fblock *pb.FilteredBlock) *pb.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 mock event hub connection used for unit testing

func NewConnection

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

NewConnection returns a new MockConnection using the given options

func (*MockConnection) Send

func (c *MockConnection) Send(emsg *pb.Event) error

Send simulates sending register/unregister events to the event hub