io

Documentation

Index

• func GetBFApplyPool() *conc.Pool[any]
• func GetOrCreateIOPool() *conc.Pool[any]
• func GetOrCreateStatsPool() *conc.Pool[any]
• func ResizeBFApplyPool(evt *config.Event)
• type BinlogIO
  • func NewBinlogIO(cm storage.ChunkManager) BinlogIO
• type BinlogIoImpl
  • func (b *BinlogIoImpl) AsyncDownload(ctx context.Context, paths []string) []*conc.Future[any]
  • func (b *BinlogIoImpl) AsyncUpload(ctx context.Context, kvs map[string][]byte) []*conc.Future[any]
  • func (b *BinlogIoImpl) Download(ctx context.Context, paths []string) ([][]byte, error)
  • func (b *BinlogIoImpl) Upload(ctx context.Context, kvs map[string][]byte) error
• type MockBinlogIO
  • func NewMockBinlogIO(t interface{ ... }) *MockBinlogIO
  • func (_m *MockBinlogIO) AsyncDownload(ctx context.Context, paths []string) []*conc.Future[interface{}]
  • func (_m *MockBinlogIO) AsyncUpload(ctx context.Context, kvs map[string][]byte) []*conc.Future[interface{}]
  • func (_m *MockBinlogIO) Download(ctx context.Context, paths []string) ([][]byte, error)
  • func (_m *MockBinlogIO) EXPECT() *MockBinlogIO_Expecter
  • func (_m *MockBinlogIO) Upload(ctx context.Context, kvs map[string][]byte) error
• type MockBinlogIO_AsyncDownload_Call
  • func (_c *MockBinlogIO_AsyncDownload_Call) Return(_a0 []*conc.Future[interface{}]) *MockBinlogIO_AsyncDownload_Call
  • func (_c *MockBinlogIO_AsyncDownload_Call) Run(run func(ctx context.Context, paths []string)) *MockBinlogIO_AsyncDownload_Call
  • func (_c *MockBinlogIO_AsyncDownload_Call) RunAndReturn(run func(context.Context, []string) []*conc.Future[interface{}]) *MockBinlogIO_AsyncDownload_Call
• type MockBinlogIO_AsyncUpload_Call
  • func (_c *MockBinlogIO_AsyncUpload_Call) Return(_a0 []*conc.Future[interface{}]) *MockBinlogIO_AsyncUpload_Call
  • func (_c *MockBinlogIO_AsyncUpload_Call) Run(run func(ctx context.Context, kvs map[string][]byte)) *MockBinlogIO_AsyncUpload_Call
  • func (_c *MockBinlogIO_AsyncUpload_Call) RunAndReturn(run func(context.Context, map[string][]byte) []*conc.Future[interface{}]) *MockBinlogIO_AsyncUpload_Call
• type MockBinlogIO_Download_Call
  • func (_c *MockBinlogIO_Download_Call) Return(_a0 [][]byte, _a1 error) *MockBinlogIO_Download_Call
  • func (_c *MockBinlogIO_Download_Call) Run(run func(ctx context.Context, paths []string)) *MockBinlogIO_Download_Call
  • func (_c *MockBinlogIO_Download_Call) RunAndReturn(run func(context.Context, []string) ([][]byte, error)) *MockBinlogIO_Download_Call
• type MockBinlogIO_Expecter
  • func (_e *MockBinlogIO_Expecter) AsyncDownload(ctx interface{}, paths interface{}) *MockBinlogIO_AsyncDownload_Call
  • func (_e *MockBinlogIO_Expecter) AsyncUpload(ctx interface{}, kvs interface{}) *MockBinlogIO_AsyncUpload_Call
  • func (_e *MockBinlogIO_Expecter) Download(ctx interface{}, paths interface{}) *MockBinlogIO_Download_Call
  • func (_e *MockBinlogIO_Expecter) Upload(ctx interface{}, kvs interface{}) *MockBinlogIO_Upload_Call
• type MockBinlogIO_Upload_Call
  • func (_c *MockBinlogIO_Upload_Call) Return(_a0 error) *MockBinlogIO_Upload_Call
  • func (_c *MockBinlogIO_Upload_Call) Run(run func(ctx context.Context, kvs map[string][]byte)) *MockBinlogIO_Upload_Call
  • func (_c *MockBinlogIO_Upload_Call) RunAndReturn(run func(context.Context, map[string][]byte) error) *MockBinlogIO_Upload_Call

Functions

func GetBFApplyPool

func GetBFApplyPool() *conc.Pool[any]

func GetOrCreateIOPool

func GetOrCreateIOPool() *conc.Pool[any]

func GetOrCreateStatsPool

func GetOrCreateStatsPool() *conc.Pool[any]

func ResizeBFApplyPool

func ResizeBFApplyPool(evt *config.Event)

Types

type BinlogIO

type BinlogIO interface {
	Download(ctx context.Context, paths []string) ([][]byte, error)
	AsyncDownload(ctx context.Context, paths []string) []*conc.Future[any]
	Upload(ctx context.Context, kvs map[string][]byte) error
	AsyncUpload(ctx context.Context, kvs map[string][]byte) []*conc.Future[any]
}

func NewBinlogIO

func NewBinlogIO(cm storage.ChunkManager) BinlogIO

type BinlogIoImpl

type BinlogIoImpl struct {
	storage.ChunkManager
	// contains filtered or unexported fields
}

func (*BinlogIoImpl) AsyncDownload

func (b *BinlogIoImpl) AsyncDownload(ctx context.Context, paths []string) []*conc.Future[any]

func (*BinlogIoImpl) AsyncUpload

func (b *BinlogIoImpl) AsyncUpload(ctx context.Context, kvs map[string][]byte) []*conc.Future[any]

func (*BinlogIoImpl) Download

func (b *BinlogIoImpl) Download(ctx context.Context, paths []string) ([][]byte, error)

func (*BinlogIoImpl) Upload

func (b *BinlogIoImpl) Upload(ctx context.Context, kvs map[string][]byte) error

type MockBinlogIO

type MockBinlogIO struct {
	mock.Mock
}

MockBinlogIO is an autogenerated mock type for the BinlogIO type

func NewMockBinlogIO

func NewMockBinlogIO(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockBinlogIO

NewMockBinlogIO creates a new instance of MockBinlogIO. 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 (*MockBinlogIO) AsyncDownload

func (_m *MockBinlogIO) AsyncDownload(ctx context.Context, paths []string) []*conc.Future[interface{}]

AsyncDownload provides a mock function with given fields: ctx, paths

func (*MockBinlogIO) AsyncUpload

func (_m *MockBinlogIO) AsyncUpload(ctx context.Context, kvs map[string][]byte) []*conc.Future[interface{}]

AsyncUpload provides a mock function with given fields: ctx, kvs

func (*MockBinlogIO) Download

func (_m *MockBinlogIO) Download(ctx context.Context, paths []string) ([][]byte, error)

Download provides a mock function with given fields: ctx, paths

func (*MockBinlogIO) EXPECT

func (_m *MockBinlogIO) EXPECT() *MockBinlogIO_Expecter

func (*MockBinlogIO) Upload

func (_m *MockBinlogIO) Upload(ctx context.Context, kvs map[string][]byte) error

Upload provides a mock function with given fields: ctx, kvs

type MockBinlogIO_AsyncDownload_Call

type MockBinlogIO_AsyncDownload_Call struct {
	*mock.Call
}

MockBinlogIO_AsyncDownload_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AsyncDownload'

func (*MockBinlogIO_AsyncDownload_Call) Return

func (_c *MockBinlogIO_AsyncDownload_Call) Return(_a0 []*conc.Future[interface{}]) *MockBinlogIO_AsyncDownload_Call

func (*MockBinlogIO_AsyncDownload_Call) Run

func (_c *MockBinlogIO_AsyncDownload_Call) Run(run func(ctx context.Context, paths []string)) *MockBinlogIO_AsyncDownload_Call

func (*MockBinlogIO_AsyncDownload_Call) RunAndReturn

func (_c *MockBinlogIO_AsyncDownload_Call) RunAndReturn(run func(context.Context, []string) []*conc.Future[interface{}]) *MockBinlogIO_AsyncDownload_Call

type MockBinlogIO_AsyncUpload_Call

type MockBinlogIO_AsyncUpload_Call struct {
	*mock.Call
}

MockBinlogIO_AsyncUpload_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AsyncUpload'

func (*MockBinlogIO_AsyncUpload_Call) Return

func (_c *MockBinlogIO_AsyncUpload_Call) Return(_a0 []*conc.Future[interface{}]) *MockBinlogIO_AsyncUpload_Call

func (*MockBinlogIO_AsyncUpload_Call) Run

func (_c *MockBinlogIO_AsyncUpload_Call) Run(run func(ctx context.Context, kvs map[string][]byte)) *MockBinlogIO_AsyncUpload_Call

func (*MockBinlogIO_AsyncUpload_Call) RunAndReturn

func (_c *MockBinlogIO_AsyncUpload_Call) RunAndReturn(run func(context.Context, map[string][]byte) []*conc.Future[interface{}]) *MockBinlogIO_AsyncUpload_Call

type MockBinlogIO_Download_Call

type MockBinlogIO_Download_Call struct {
	*mock.Call
}

MockBinlogIO_Download_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Download'

func (*MockBinlogIO_Download_Call) Return

func (_c *MockBinlogIO_Download_Call) Return(_a0 [][]byte, _a1 error) *MockBinlogIO_Download_Call

func (*MockBinlogIO_Download_Call) Run

func (_c *MockBinlogIO_Download_Call) Run(run func(ctx context.Context, paths []string)) *MockBinlogIO_Download_Call

func (*MockBinlogIO_Download_Call) RunAndReturn

func (_c *MockBinlogIO_Download_Call) RunAndReturn(run func(context.Context, []string) ([][]byte, error)) *MockBinlogIO_Download_Call

type MockBinlogIO_Expecter

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

func (*MockBinlogIO_Expecter) AsyncDownload

func (_e *MockBinlogIO_Expecter) AsyncDownload(ctx interface{}, paths interface{}) *MockBinlogIO_AsyncDownload_Call

AsyncDownload is a helper method to define mock.On call

• ctx context.Context
• paths []string

func (*MockBinlogIO_Expecter) AsyncUpload

func (_e *MockBinlogIO_Expecter) AsyncUpload(ctx interface{}, kvs interface{}) *MockBinlogIO_AsyncUpload_Call

AsyncUpload is a helper method to define mock.On call

• ctx context.Context
• kvs map[string][]byte

func (*MockBinlogIO_Expecter) Download

func (_e *MockBinlogIO_Expecter) Download(ctx interface{}, paths interface{}) *MockBinlogIO_Download_Call

Download is a helper method to define mock.On call

• ctx context.Context
• paths []string

func (*MockBinlogIO_Expecter) Upload

func (_e *MockBinlogIO_Expecter) Upload(ctx interface{}, kvs interface{}) *MockBinlogIO_Upload_Call

Upload is a helper method to define mock.On call

• ctx context.Context
• kvs map[string][]byte

type MockBinlogIO_Upload_Call

type MockBinlogIO_Upload_Call struct {
	*mock.Call
}

MockBinlogIO_Upload_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Upload'

func (*MockBinlogIO_Upload_Call) Return

func (_c *MockBinlogIO_Upload_Call) Return(_a0 error) *MockBinlogIO_Upload_Call

func (*MockBinlogIO_Upload_Call) Run

func (_c *MockBinlogIO_Upload_Call) Run(run func(ctx context.Context, kvs map[string][]byte)) *MockBinlogIO_Upload_Call

func (*MockBinlogIO_Upload_Call) RunAndReturn

func (_c *MockBinlogIO_Upload_Call) RunAndReturn(run func(context.Context, map[string][]byte) error) *MockBinlogIO_Upload_Call