mocks

Documentation

Index

• func NewMockClientStream() grpc.ClientStream
• func NewMockSubscribeRatesClient(recvChan <-chan *ferprpc.SubscribeRatesResponse) ferprpc.RateService_SubscribeRatesClient
• type MockClientStream
  • func (s *MockClientStream) CloseSend() error
  • func (s *MockClientStream) Context() context.Context
  • func (s *MockClientStream) Header() (metadata.MD, error)
  • func (s *MockClientStream) RecvMsg(m interface{}) error
  • func (s *MockClientStream) SendMsg(m interface{}) error
  • func (s *MockClientStream) Trailer() metadata.MD
• type MockFerpService
  • func NewService() *MockFerpService
  • func (s *MockFerpService) NewSubscribeTransactionsMockData() chan<- *ferprpc.SubscribeRatesResponse
  • func (s *MockFerpService) SubscribeRates(in *ferprpc.SubscribeRatesRequest, opts ...grpc.CallOption) (ferprpc.RateService_SubscribeRatesClient, error)
• type MockSubscribeRatesClient
  • func (c *MockSubscribeRatesClient) Recv() (*ferprpc.SubscribeRatesResponse, error)

Functions

func NewMockClientStream

func NewMockClientStream() grpc.ClientStream

func NewMockSubscribeRatesClient

func NewMockSubscribeRatesClient(recvChan <-chan *ferprpc.SubscribeRatesResponse) ferprpc.RateService_SubscribeRatesClient

Types

type MockClientStream

type MockClientStream struct{}

func (*MockClientStream) CloseSend

func (s *MockClientStream) CloseSend() error

func (*MockClientStream) Context

func (s *MockClientStream) Context() context.Context

func (*MockClientStream) Header

func (s *MockClientStream) Header() (metadata.MD, error)

func (*MockClientStream) RecvMsg

func (s *MockClientStream) RecvMsg(m interface{}) error

func (*MockClientStream) SendMsg

func (s *MockClientStream) SendMsg(m interface{}) error

func (*MockClientStream) Trailer

func (s *MockClientStream) Trailer() metadata.MD

type MockFerpService

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

func NewService

func NewService() *MockFerpService

func (*MockFerpService) NewSubscribeTransactionsMockData

func (s *MockFerpService) NewSubscribeTransactionsMockData() chan<- *ferprpc.SubscribeRatesResponse

func (*MockFerpService) SubscribeRates

func (s *MockFerpService) SubscribeRates(in *ferprpc.SubscribeRatesRequest, opts ...grpc.CallOption) (ferprpc.RateService_SubscribeRatesClient, error)

type MockSubscribeRatesClient

type MockSubscribeRatesClient struct {
	grpc.ClientStream
	// contains filtered or unexported fields
}

func (*MockSubscribeRatesClient) Recv

func (c *MockSubscribeRatesClient) Recv() (*ferprpc.SubscribeRatesResponse, error)