Documentation ¶
Index ¶
- type MockOpener
- type MockOpenerBuilder
- type MockOpenerBuilder_Build_Call
- func (_c *MockOpenerBuilder_Build_Call) Return(_a0 wal.Opener, _a1 error) *MockOpenerBuilder_Build_Call
- func (_c *MockOpenerBuilder_Build_Call) Run(run func()) *MockOpenerBuilder_Build_Call
- func (_c *MockOpenerBuilder_Build_Call) RunAndReturn(run func() (wal.Opener, error)) *MockOpenerBuilder_Build_Call
- type MockOpenerBuilder_Expecter
- type MockOpenerBuilder_Name_Call
- type MockOpener_Close_Call
- type MockOpener_Expecter
- type MockOpener_Open_Call
- func (_c *MockOpener_Open_Call) Return(_a0 wal.WAL, _a1 error) *MockOpener_Open_Call
- func (_c *MockOpener_Open_Call) Run(run func(ctx context.Context, opt *wal.OpenOption)) *MockOpener_Open_Call
- func (_c *MockOpener_Open_Call) RunAndReturn(run func(context.Context, *wal.OpenOption) (wal.WAL, error)) *MockOpener_Open_Call
- type MockScanner
- type MockScanner_Chan_Call
- type MockScanner_Channel_Call
- type MockScanner_Close_Call
- type MockScanner_Done_Call
- type MockScanner_Error_Call
- type MockScanner_Expecter
- func (_e *MockScanner_Expecter) Chan() *MockScanner_Chan_Call
- func (_e *MockScanner_Expecter) Channel() *MockScanner_Channel_Call
- func (_e *MockScanner_Expecter) Close() *MockScanner_Close_Call
- func (_e *MockScanner_Expecter) Done() *MockScanner_Done_Call
- func (_e *MockScanner_Expecter) Error() *MockScanner_Error_Call
- type MockWAL
- func (_m *MockWAL) Append(ctx context.Context, msg message.MutableMessage) (*types.AppendResult, error)
- func (_m *MockWAL) AppendAsync(ctx context.Context, msg message.MutableMessage, ...)
- func (_m *MockWAL) Available() <-chan struct{}
- func (_m *MockWAL) Channel() types.PChannelInfo
- func (_m *MockWAL) Close()
- func (_m *MockWAL) EXPECT() *MockWAL_Expecter
- func (_m *MockWAL) IsAvailable() bool
- func (_m *MockWAL) Read(ctx context.Context, deliverPolicy wal.ReadOption) (wal.Scanner, error)
- func (_m *MockWAL) WALName() string
- type MockWAL_AppendAsync_Call
- type MockWAL_Append_Call
- func (_c *MockWAL_Append_Call) Return(_a0 *types.AppendResult, _a1 error) *MockWAL_Append_Call
- func (_c *MockWAL_Append_Call) Run(run func(ctx context.Context, msg message.MutableMessage)) *MockWAL_Append_Call
- func (_c *MockWAL_Append_Call) RunAndReturn(run func(context.Context, message.MutableMessage) (*types.AppendResult, error)) *MockWAL_Append_Call
- type MockWAL_Available_Call
- type MockWAL_Channel_Call
- type MockWAL_Close_Call
- type MockWAL_Expecter
- func (_e *MockWAL_Expecter) Append(ctx interface{}, msg interface{}) *MockWAL_Append_Call
- func (_e *MockWAL_Expecter) AppendAsync(ctx interface{}, msg interface{}, cb interface{}) *MockWAL_AppendAsync_Call
- func (_e *MockWAL_Expecter) Available() *MockWAL_Available_Call
- func (_e *MockWAL_Expecter) Channel() *MockWAL_Channel_Call
- func (_e *MockWAL_Expecter) Close() *MockWAL_Close_Call
- func (_e *MockWAL_Expecter) IsAvailable() *MockWAL_IsAvailable_Call
- func (_e *MockWAL_Expecter) Read(ctx interface{}, deliverPolicy interface{}) *MockWAL_Read_Call
- func (_e *MockWAL_Expecter) WALName() *MockWAL_WALName_Call
- type MockWAL_IsAvailable_Call
- type MockWAL_Read_Call
- func (_c *MockWAL_Read_Call) Return(_a0 wal.Scanner, _a1 error) *MockWAL_Read_Call
- func (_c *MockWAL_Read_Call) Run(run func(ctx context.Context, deliverPolicy wal.ReadOption)) *MockWAL_Read_Call
- func (_c *MockWAL_Read_Call) RunAndReturn(run func(context.Context, wal.ReadOption) (wal.Scanner, error)) *MockWAL_Read_Call
- type MockWAL_WALName_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockOpener ¶
MockOpener is an autogenerated mock type for the Opener type
func NewMockOpener ¶
func NewMockOpener(t interface { mock.TestingT Cleanup(func()) }) *MockOpener
NewMockOpener creates a new instance of MockOpener. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*MockOpener) Close ¶
func (_m *MockOpener) Close()
Close provides a mock function with given fields:
func (*MockOpener) EXPECT ¶
func (_m *MockOpener) EXPECT() *MockOpener_Expecter
func (*MockOpener) Open ¶
func (_m *MockOpener) Open(ctx context.Context, opt *wal.OpenOption) (wal.WAL, error)
Open provides a mock function with given fields: ctx, opt
type MockOpenerBuilder ¶
MockOpenerBuilder is an autogenerated mock type for the OpenerBuilder type
func NewMockOpenerBuilder ¶
func NewMockOpenerBuilder(t interface { mock.TestingT Cleanup(func()) }) *MockOpenerBuilder
NewMockOpenerBuilder creates a new instance of MockOpenerBuilder. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*MockOpenerBuilder) Build ¶
func (_m *MockOpenerBuilder) Build() (wal.Opener, error)
Build provides a mock function with given fields:
func (*MockOpenerBuilder) EXPECT ¶
func (_m *MockOpenerBuilder) EXPECT() *MockOpenerBuilder_Expecter
func (*MockOpenerBuilder) Name ¶
func (_m *MockOpenerBuilder) Name() string
Name provides a mock function with given fields:
type MockOpenerBuilder_Build_Call ¶
MockOpenerBuilder_Build_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Build'
func (*MockOpenerBuilder_Build_Call) Return ¶
func (_c *MockOpenerBuilder_Build_Call) Return(_a0 wal.Opener, _a1 error) *MockOpenerBuilder_Build_Call
func (*MockOpenerBuilder_Build_Call) Run ¶
func (_c *MockOpenerBuilder_Build_Call) Run(run func()) *MockOpenerBuilder_Build_Call
func (*MockOpenerBuilder_Build_Call) RunAndReturn ¶
func (_c *MockOpenerBuilder_Build_Call) RunAndReturn(run func() (wal.Opener, error)) *MockOpenerBuilder_Build_Call
type MockOpenerBuilder_Expecter ¶
type MockOpenerBuilder_Expecter struct {
// contains filtered or unexported fields
}
func (*MockOpenerBuilder_Expecter) Build ¶
func (_e *MockOpenerBuilder_Expecter) Build() *MockOpenerBuilder_Build_Call
Build is a helper method to define mock.On call
func (*MockOpenerBuilder_Expecter) Name ¶
func (_e *MockOpenerBuilder_Expecter) Name() *MockOpenerBuilder_Name_Call
Name is a helper method to define mock.On call
type MockOpenerBuilder_Name_Call ¶
MockOpenerBuilder_Name_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Name'
func (*MockOpenerBuilder_Name_Call) Return ¶
func (_c *MockOpenerBuilder_Name_Call) Return(_a0 string) *MockOpenerBuilder_Name_Call
func (*MockOpenerBuilder_Name_Call) Run ¶
func (_c *MockOpenerBuilder_Name_Call) Run(run func()) *MockOpenerBuilder_Name_Call
func (*MockOpenerBuilder_Name_Call) RunAndReturn ¶
func (_c *MockOpenerBuilder_Name_Call) RunAndReturn(run func() string) *MockOpenerBuilder_Name_Call
type MockOpener_Close_Call ¶
MockOpener_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'
func (*MockOpener_Close_Call) Return ¶
func (_c *MockOpener_Close_Call) Return() *MockOpener_Close_Call
func (*MockOpener_Close_Call) Run ¶
func (_c *MockOpener_Close_Call) Run(run func()) *MockOpener_Close_Call
func (*MockOpener_Close_Call) RunAndReturn ¶
func (_c *MockOpener_Close_Call) RunAndReturn(run func()) *MockOpener_Close_Call
type MockOpener_Expecter ¶
type MockOpener_Expecter struct {
// contains filtered or unexported fields
}
func (*MockOpener_Expecter) Close ¶
func (_e *MockOpener_Expecter) Close() *MockOpener_Close_Call
Close is a helper method to define mock.On call
func (*MockOpener_Expecter) Open ¶
func (_e *MockOpener_Expecter) Open(ctx interface{}, opt interface{}) *MockOpener_Open_Call
Open is a helper method to define mock.On call
- ctx context.Context
- opt *wal.OpenOption
type MockOpener_Open_Call ¶
MockOpener_Open_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Open'
func (*MockOpener_Open_Call) Return ¶
func (_c *MockOpener_Open_Call) Return(_a0 wal.WAL, _a1 error) *MockOpener_Open_Call
func (*MockOpener_Open_Call) Run ¶
func (_c *MockOpener_Open_Call) Run(run func(ctx context.Context, opt *wal.OpenOption)) *MockOpener_Open_Call
func (*MockOpener_Open_Call) RunAndReturn ¶
func (_c *MockOpener_Open_Call) RunAndReturn(run func(context.Context, *wal.OpenOption) (wal.WAL, error)) *MockOpener_Open_Call
type MockScanner ¶
MockScanner is an autogenerated mock type for the Scanner type
func NewMockScanner ¶
func NewMockScanner(t interface { mock.TestingT Cleanup(func()) }) *MockScanner
NewMockScanner creates a new instance of MockScanner. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*MockScanner) Chan ¶
func (_m *MockScanner) Chan() <-chan message.ImmutableMessage
Chan provides a mock function with given fields:
func (*MockScanner) Channel ¶
func (_m *MockScanner) Channel() types.PChannelInfo
Channel provides a mock function with given fields:
func (*MockScanner) Close ¶
func (_m *MockScanner) Close() error
Close provides a mock function with given fields:
func (*MockScanner) Done ¶
func (_m *MockScanner) Done() <-chan struct{}
Done provides a mock function with given fields:
func (*MockScanner) EXPECT ¶
func (_m *MockScanner) EXPECT() *MockScanner_Expecter
func (*MockScanner) Error ¶
func (_m *MockScanner) Error() error
Error provides a mock function with given fields:
type MockScanner_Chan_Call ¶
MockScanner_Chan_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Chan'
func (*MockScanner_Chan_Call) Return ¶
func (_c *MockScanner_Chan_Call) Return(_a0 <-chan message.ImmutableMessage) *MockScanner_Chan_Call
func (*MockScanner_Chan_Call) Run ¶
func (_c *MockScanner_Chan_Call) Run(run func()) *MockScanner_Chan_Call
func (*MockScanner_Chan_Call) RunAndReturn ¶
func (_c *MockScanner_Chan_Call) RunAndReturn(run func() <-chan message.ImmutableMessage) *MockScanner_Chan_Call
type MockScanner_Channel_Call ¶
MockScanner_Channel_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Channel'
func (*MockScanner_Channel_Call) Return ¶
func (_c *MockScanner_Channel_Call) Return(_a0 types.PChannelInfo) *MockScanner_Channel_Call
func (*MockScanner_Channel_Call) Run ¶
func (_c *MockScanner_Channel_Call) Run(run func()) *MockScanner_Channel_Call
func (*MockScanner_Channel_Call) RunAndReturn ¶
func (_c *MockScanner_Channel_Call) RunAndReturn(run func() types.PChannelInfo) *MockScanner_Channel_Call
type MockScanner_Close_Call ¶
MockScanner_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'
func (*MockScanner_Close_Call) Return ¶
func (_c *MockScanner_Close_Call) Return(_a0 error) *MockScanner_Close_Call
func (*MockScanner_Close_Call) Run ¶
func (_c *MockScanner_Close_Call) Run(run func()) *MockScanner_Close_Call
func (*MockScanner_Close_Call) RunAndReturn ¶
func (_c *MockScanner_Close_Call) RunAndReturn(run func() error) *MockScanner_Close_Call
type MockScanner_Done_Call ¶
MockScanner_Done_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Done'
func (*MockScanner_Done_Call) Return ¶
func (_c *MockScanner_Done_Call) Return(_a0 <-chan struct{}) *MockScanner_Done_Call
func (*MockScanner_Done_Call) Run ¶
func (_c *MockScanner_Done_Call) Run(run func()) *MockScanner_Done_Call
func (*MockScanner_Done_Call) RunAndReturn ¶
func (_c *MockScanner_Done_Call) RunAndReturn(run func() <-chan struct{}) *MockScanner_Done_Call
type MockScanner_Error_Call ¶
MockScanner_Error_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Error'
func (*MockScanner_Error_Call) Return ¶
func (_c *MockScanner_Error_Call) Return(_a0 error) *MockScanner_Error_Call
func (*MockScanner_Error_Call) Run ¶
func (_c *MockScanner_Error_Call) Run(run func()) *MockScanner_Error_Call
func (*MockScanner_Error_Call) RunAndReturn ¶
func (_c *MockScanner_Error_Call) RunAndReturn(run func() error) *MockScanner_Error_Call
type MockScanner_Expecter ¶
type MockScanner_Expecter struct {
// contains filtered or unexported fields
}
func (*MockScanner_Expecter) Chan ¶
func (_e *MockScanner_Expecter) Chan() *MockScanner_Chan_Call
Chan is a helper method to define mock.On call
func (*MockScanner_Expecter) Channel ¶
func (_e *MockScanner_Expecter) Channel() *MockScanner_Channel_Call
Channel is a helper method to define mock.On call
func (*MockScanner_Expecter) Close ¶
func (_e *MockScanner_Expecter) Close() *MockScanner_Close_Call
Close is a helper method to define mock.On call
func (*MockScanner_Expecter) Done ¶
func (_e *MockScanner_Expecter) Done() *MockScanner_Done_Call
Done is a helper method to define mock.On call
func (*MockScanner_Expecter) Error ¶
func (_e *MockScanner_Expecter) Error() *MockScanner_Error_Call
Error is a helper method to define mock.On call
type MockWAL ¶
MockWAL is an autogenerated mock type for the WAL type
func NewMockWAL ¶
NewMockWAL creates a new instance of MockWAL. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*MockWAL) Append ¶
func (_m *MockWAL) Append(ctx context.Context, msg message.MutableMessage) (*types.AppendResult, error)
Append provides a mock function with given fields: ctx, msg
func (*MockWAL) AppendAsync ¶
func (_m *MockWAL) AppendAsync(ctx context.Context, msg message.MutableMessage, cb func(*types.AppendResult, error))
AppendAsync provides a mock function with given fields: ctx, msg, cb
func (*MockWAL) Available ¶
func (_m *MockWAL) Available() <-chan struct{}
Available provides a mock function with given fields:
func (*MockWAL) Channel ¶
func (_m *MockWAL) Channel() types.PChannelInfo
Channel provides a mock function with given fields:
func (*MockWAL) Close ¶
func (_m *MockWAL) Close()
Close provides a mock function with given fields:
func (*MockWAL) EXPECT ¶
func (_m *MockWAL) EXPECT() *MockWAL_Expecter
func (*MockWAL) IsAvailable ¶
IsAvailable provides a mock function with given fields:
type MockWAL_AppendAsync_Call ¶
MockWAL_AppendAsync_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AppendAsync'
func (*MockWAL_AppendAsync_Call) Return ¶
func (_c *MockWAL_AppendAsync_Call) Return() *MockWAL_AppendAsync_Call
func (*MockWAL_AppendAsync_Call) Run ¶
func (_c *MockWAL_AppendAsync_Call) Run(run func(ctx context.Context, msg message.MutableMessage, cb func(*types.AppendResult, error))) *MockWAL_AppendAsync_Call
func (*MockWAL_AppendAsync_Call) RunAndReturn ¶
func (_c *MockWAL_AppendAsync_Call) RunAndReturn(run func(context.Context, message.MutableMessage, func(*types.AppendResult, error))) *MockWAL_AppendAsync_Call
type MockWAL_Append_Call ¶
MockWAL_Append_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Append'
func (*MockWAL_Append_Call) Return ¶
func (_c *MockWAL_Append_Call) Return(_a0 *types.AppendResult, _a1 error) *MockWAL_Append_Call
func (*MockWAL_Append_Call) Run ¶
func (_c *MockWAL_Append_Call) Run(run func(ctx context.Context, msg message.MutableMessage)) *MockWAL_Append_Call
func (*MockWAL_Append_Call) RunAndReturn ¶
func (_c *MockWAL_Append_Call) RunAndReturn(run func(context.Context, message.MutableMessage) (*types.AppendResult, error)) *MockWAL_Append_Call
type MockWAL_Available_Call ¶
MockWAL_Available_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Available'
func (*MockWAL_Available_Call) Return ¶
func (_c *MockWAL_Available_Call) Return(_a0 <-chan struct{}) *MockWAL_Available_Call
func (*MockWAL_Available_Call) Run ¶
func (_c *MockWAL_Available_Call) Run(run func()) *MockWAL_Available_Call
func (*MockWAL_Available_Call) RunAndReturn ¶
func (_c *MockWAL_Available_Call) RunAndReturn(run func() <-chan struct{}) *MockWAL_Available_Call
type MockWAL_Channel_Call ¶
MockWAL_Channel_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Channel'
func (*MockWAL_Channel_Call) Return ¶
func (_c *MockWAL_Channel_Call) Return(_a0 types.PChannelInfo) *MockWAL_Channel_Call
func (*MockWAL_Channel_Call) Run ¶
func (_c *MockWAL_Channel_Call) Run(run func()) *MockWAL_Channel_Call
func (*MockWAL_Channel_Call) RunAndReturn ¶
func (_c *MockWAL_Channel_Call) RunAndReturn(run func() types.PChannelInfo) *MockWAL_Channel_Call
type MockWAL_Close_Call ¶
MockWAL_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'
func (*MockWAL_Close_Call) Return ¶
func (_c *MockWAL_Close_Call) Return() *MockWAL_Close_Call
func (*MockWAL_Close_Call) Run ¶
func (_c *MockWAL_Close_Call) Run(run func()) *MockWAL_Close_Call
func (*MockWAL_Close_Call) RunAndReturn ¶
func (_c *MockWAL_Close_Call) RunAndReturn(run func()) *MockWAL_Close_Call
type MockWAL_Expecter ¶
type MockWAL_Expecter struct {
// contains filtered or unexported fields
}
func (*MockWAL_Expecter) Append ¶
func (_e *MockWAL_Expecter) Append(ctx interface{}, msg interface{}) *MockWAL_Append_Call
Append is a helper method to define mock.On call
- ctx context.Context
- msg message.MutableMessage
func (*MockWAL_Expecter) AppendAsync ¶
func (_e *MockWAL_Expecter) AppendAsync(ctx interface{}, msg interface{}, cb interface{}) *MockWAL_AppendAsync_Call
AppendAsync is a helper method to define mock.On call
- ctx context.Context
- msg message.MutableMessage
- cb func(*types.AppendResult , error)
func (*MockWAL_Expecter) Available ¶
func (_e *MockWAL_Expecter) Available() *MockWAL_Available_Call
Available is a helper method to define mock.On call
func (*MockWAL_Expecter) Channel ¶
func (_e *MockWAL_Expecter) Channel() *MockWAL_Channel_Call
Channel is a helper method to define mock.On call
func (*MockWAL_Expecter) Close ¶
func (_e *MockWAL_Expecter) Close() *MockWAL_Close_Call
Close is a helper method to define mock.On call
func (*MockWAL_Expecter) IsAvailable ¶
func (_e *MockWAL_Expecter) IsAvailable() *MockWAL_IsAvailable_Call
IsAvailable is a helper method to define mock.On call
func (*MockWAL_Expecter) Read ¶
func (_e *MockWAL_Expecter) Read(ctx interface{}, deliverPolicy interface{}) *MockWAL_Read_Call
Read is a helper method to define mock.On call
- ctx context.Context
- deliverPolicy wal.ReadOption
func (*MockWAL_Expecter) WALName ¶
func (_e *MockWAL_Expecter) WALName() *MockWAL_WALName_Call
WALName is a helper method to define mock.On call
type MockWAL_IsAvailable_Call ¶
MockWAL_IsAvailable_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsAvailable'
func (*MockWAL_IsAvailable_Call) Return ¶
func (_c *MockWAL_IsAvailable_Call) Return(_a0 bool) *MockWAL_IsAvailable_Call
func (*MockWAL_IsAvailable_Call) Run ¶
func (_c *MockWAL_IsAvailable_Call) Run(run func()) *MockWAL_IsAvailable_Call
func (*MockWAL_IsAvailable_Call) RunAndReturn ¶
func (_c *MockWAL_IsAvailable_Call) RunAndReturn(run func() bool) *MockWAL_IsAvailable_Call
type MockWAL_Read_Call ¶
MockWAL_Read_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Read'
func (*MockWAL_Read_Call) Return ¶
func (_c *MockWAL_Read_Call) Return(_a0 wal.Scanner, _a1 error) *MockWAL_Read_Call
func (*MockWAL_Read_Call) Run ¶
func (_c *MockWAL_Read_Call) Run(run func(ctx context.Context, deliverPolicy wal.ReadOption)) *MockWAL_Read_Call
func (*MockWAL_Read_Call) RunAndReturn ¶
func (_c *MockWAL_Read_Call) RunAndReturn(run func(context.Context, wal.ReadOption) (wal.Scanner, error)) *MockWAL_Read_Call
type MockWAL_WALName_Call ¶
MockWAL_WALName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WALName'
func (*MockWAL_WALName_Call) Return ¶
func (_c *MockWAL_WALName_Call) Return(_a0 string) *MockWAL_WALName_Call
func (*MockWAL_WALName_Call) Run ¶
func (_c *MockWAL_WALName_Call) Run(run func()) *MockWAL_WALName_Call
func (*MockWAL_WALName_Call) RunAndReturn ¶
func (_c *MockWAL_WALName_Call) RunAndReturn(run func() string) *MockWAL_WALName_Call