buffered_async

Documentation

Overview

Package buffered_async is a generated GoMock package.

Index

• type FetchResult
• type MockreaderHelper
  • func NewMockreaderHelper(ctrl *gomock.Controller) *MockreaderHelper
  • func (m *MockreaderHelper) EXPECT() *MockreaderHelperMockRecorder
  • func (m *MockreaderHelper) Read() (interface{}, errors.Error)
• type MockreaderHelperMockRecorder
  • func (mr *MockreaderHelperMockRecorder) Read() *gomock.Call
• type Reader
• type ReaderFunc
• type ReaderImpl
  • func NewReaderImpl(maxCacheSize int) *ReaderImpl
  • func (reader *ReaderImpl) Start(readerFunc ReaderFunc) <-chan FetchResult
  • func (reader *ReaderImpl) Stop()

Types

type FetchResult

type FetchResult struct {
	FetchedMessage interface{}
	Err            errors.Error
}

type MockreaderHelper

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

MockreaderHelper is a mock of readerHelper interface.

func NewMockreaderHelper

func NewMockreaderHelper(ctrl *gomock.Controller) *MockreaderHelper

NewMockreaderHelper creates a new mock instance.

func (*MockreaderHelper) EXPECT

func (m *MockreaderHelper) EXPECT() *MockreaderHelperMockRecorder

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

func (*MockreaderHelper) Read

func (m *MockreaderHelper) Read() (interface{}, errors.Error)

Read mocks base method.

type MockreaderHelperMockRecorder

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

MockreaderHelperMockRecorder is the mock recorder for MockreaderHelper.

func (*MockreaderHelperMockRecorder) Read

func (mr *MockreaderHelperMockRecorder) Read() *gomock.Call

Read indicates an expected call of Read.

type Reader

type Reader interface {
	Start(readerFunc ReaderFunc) <-chan interface{}
	Stop()
}

type ReaderFunc

type ReaderFunc func() (interface{}, errors.Error)

type ReaderImpl

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

func NewReaderImpl

func NewReaderImpl(maxCacheSize int) *ReaderImpl

func (*ReaderImpl) Start

func (reader *ReaderImpl) Start(readerFunc ReaderFunc) <-chan FetchResult

func (*ReaderImpl) Stop

func (reader *ReaderImpl) Stop()