events

Documentation

Overview

Package events is a generated GoMock package.

Index

• type EventsClientSuite
  • func (suite *EventsClientSuite) TearDownTest()
  • func (suite *EventsClientSuite) TestPublishTick()
• type MockPort
  • func NewMockPort(ctrl *gomock.Controller) *MockPort
  • func (m *MockPort) Close(ctx context.Context)
  • func (m *MockPort) EXPECT() *MockPortMockRecorder
  • func (m *MockPort) PublishTick(ctx context.Context, tick tick.Tick) error
  • func (m *MockPort) SubscribeToTicks(ctx context.Context, sub event.PricesSubscription) (<-chan tick.Tick, error)
• type MockPortMockRecorder
  • func (mr *MockPortMockRecorder) Close(ctx interface{}) *gomock.Call
  • func (mr *MockPortMockRecorder) PublishTick(ctx, tick interface{}) *gomock.Call
  • func (mr *MockPortMockRecorder) SubscribeToTicks(ctx, sub interface{}) *gomock.Call
• type Port

Types

type EventsClientSuite

type EventsClientSuite struct {
	suite.Suite
	Client Port
}

func (*EventsClientSuite) TearDownTest

func (suite *EventsClientSuite) TearDownTest()

func (*EventsClientSuite) TestPublishTick

func (suite *EventsClientSuite) TestPublishTick()

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) PublishTick

func (m *MockPort) PublishTick(ctx context.Context, tick tick.Tick) error

PublishTick mocks base method.

func (*MockPort) SubscribeToTicks

func (m *MockPort) SubscribeToTicks(ctx context.Context, sub event.PricesSubscription) (<-chan tick.Tick, error)

SubscribeToTicks 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) PublishTick

func (mr *MockPortMockRecorder) PublishTick(ctx, tick interface{}) *gomock.Call

PublishTick indicates an expected call of PublishTick.

func (*MockPortMockRecorder) SubscribeToTicks

func (mr *MockPortMockRecorder) SubscribeToTicks(ctx, sub interface{}) *gomock.Call

SubscribeToTicks indicates an expected call of SubscribeToTicks.

type Port

type Port interface {
	PublishTick(ctx context.Context, tick tick.Tick) error
	SubscribeToTicks(ctx context.Context, sub event.PricesSubscription) (<-chan tick.Tick, error)

	Close(ctx context.Context)
}