events

Documentation

Overview

Package events is a generated GoMock package.

Index

• func TestEventsClientSuite(t *testing.T)
• type EventsClientSuite
  • func (suite *EventsClientSuite) TestOnePubOneSubObject()
• type MockPort
  • func NewMockPort(ctrl *gomock.Controller) *MockPort
  • func (m *MockPort) Close(ctx context.Context)
  • func (m *MockPort) EXPECT() *MockPortMockRecorder
  • func (m *MockPort) Publish(ctx context.Context, backtestID uint, event event.Event) error
  • func (m *MockPort) Subscribe(ctx context.Context, backtestID uint) (<-chan event.Event, error)
• type MockPortMockRecorder
  • func (mr *MockPortMockRecorder) Close(ctx interface{}) *gomock.Call
  • func (mr *MockPortMockRecorder) Publish(ctx, backtestID, event interface{}) *gomock.Call
  • func (mr *MockPortMockRecorder) Subscribe(ctx, backtestID interface{}) *gomock.Call
• type Port

Functions

func TestEventsClientSuite

func TestEventsClientSuite(t *testing.T)

Types

type EventsClientSuite

type EventsClientSuite struct {
	suite.Suite
	Client Port
}

func (*EventsClientSuite) TestOnePubOneSubObject

func (suite *EventsClientSuite) TestOnePubOneSubObject()

type MockPort

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

MockPort is a mock of Port interface.

func NewMockPort

func NewMockPort(ctrl *gomock.Controller) *MockPort

NewMockPort creates a new mock instance.

func (*MockPort) Close

func (m *MockPort) Close(ctx context.Context)

Close mocks base method.

func (*MockPort) EXPECT

func (m *MockPort) EXPECT() *MockPortMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockPort) Publish

func (m *MockPort) Publish(ctx context.Context, backtestID uint, event event.Event) error

Publish mocks base method.

func (*MockPort) Subscribe

func (m *MockPort) Subscribe(ctx context.Context, backtestID uint) (<-chan event.Event, error)

Subscribe mocks base method.

type MockPortMockRecorder

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

MockPortMockRecorder is the mock recorder for MockPort.

func (*MockPortMockRecorder) Close

func (mr *MockPortMockRecorder) Close(ctx interface{}) *gomock.Call

Close indicates an expected call of Close.

func (*MockPortMockRecorder) Publish

func (mr *MockPortMockRecorder) Publish(ctx, backtestID, event interface{}) *gomock.Call

Publish indicates an expected call of Publish.

func (*MockPortMockRecorder) Subscribe

func (mr *MockPortMockRecorder) Subscribe(ctx, backtestID interface{}) *gomock.Call

Subscribe indicates an expected call of Subscribe.

type Port

type Port interface {
	Publish(ctx context.Context, backtestID uint, event event.Event) error
	Subscribe(ctx context.Context, backtestID uint) (<-chan event.Event, error)
	Close(ctx context.Context)
}