mocks

package
v0.21.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 16, 2024 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FileRecorder 

type FileRecorder struct {
	mock.Mock
}

FileRecorder is an autogenerated mock type for the FileRecorder type

func NewFileRecorder 

func NewFileRecorder(t interface {
	mock.TestingT
	Cleanup(func())
}) *FileRecorder

NewFileRecorder creates a new instance of FileRecorder. 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 (*FileRecorder) DeleteRecordedFiles 

func (_m *FileRecorder) DeleteRecordedFiles(ctx context.Context) error

DeleteRecordedFiles provides a mock function with given fields: ctx

func (*FileRecorder) EXPECT 

func (_m *FileRecorder) EXPECT() *FileRecorder_Expecter

func (*FileRecorder) Files 

func (_m *FileRecorder) Files() []parquet.File

Files provides a mock function with given fields:

func (*FileRecorder) RecordFile 

func (_m *FileRecorder) RecordFile(bucket string, key string)

RecordFile provides a mock function with given fields: bucket, key

func (*FileRecorder) RenameRecordedFiles 

func (_m *FileRecorder) RenameRecordedFiles(ctx context.Context, newPrefix string) error

RenameRecordedFiles provides a mock function with given fields: ctx, newPrefix

type FileRecorder_DeleteRecordedFiles_Call 

type FileRecorder_DeleteRecordedFiles_Call struct {
	*mock.Call
}

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

func (*FileRecorder_DeleteRecordedFiles_Call) Return 

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

func (*FileRecorder_DeleteRecordedFiles_Call) Run 

func (_c *FileRecorder_DeleteRecordedFiles_Call) Run(run func(ctx context.Context)) *FileRecorder_DeleteRecordedFiles_Call

func (*FileRecorder_DeleteRecordedFiles_Call) RunAndReturn 

func (_c *FileRecorder_DeleteRecordedFiles_Call) RunAndReturn(run func(context.Context) error) *FileRecorder_DeleteRecordedFiles_Call

type FileRecorder_Expecter 

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

func (*FileRecorder_Expecter) DeleteRecordedFiles 

func (_e *FileRecorder_Expecter) DeleteRecordedFiles(ctx interface{}) *FileRecorder_DeleteRecordedFiles_Call

DeleteRecordedFiles is a helper method to define mock.On call

  • ctx context.Context

func (*FileRecorder_Expecter) Files 

func (_e *FileRecorder_Expecter) Files() *FileRecorder_Files_Call

Files is a helper method to define mock.On call

func (*FileRecorder_Expecter) RecordFile 

func (_e *FileRecorder_Expecter) RecordFile(bucket interface{}, key interface{}) *FileRecorder_RecordFile_Call

RecordFile is a helper method to define mock.On call

  • bucket string
  • key string

func (*FileRecorder_Expecter) RenameRecordedFiles 

func (_e *FileRecorder_Expecter) RenameRecordedFiles(ctx interface{}, newPrefix interface{}) *FileRecorder_RenameRecordedFiles_Call

RenameRecordedFiles is a helper method to define mock.On call

  • ctx context.Context
  • newPrefix string

type FileRecorder_Files_Call 

type FileRecorder_Files_Call struct {
	*mock.Call
}

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

func (*FileRecorder_Files_Call) Return 

func (_c *FileRecorder_Files_Call) Return(_a0 []parquet.File) *FileRecorder_Files_Call

func (*FileRecorder_Files_Call) Run 

func (_c *FileRecorder_Files_Call) Run(run func()) *FileRecorder_Files_Call

func (*FileRecorder_Files_Call) RunAndReturn 

func (_c *FileRecorder_Files_Call) RunAndReturn(run func() []parquet.File) *FileRecorder_Files_Call

type FileRecorder_RecordFile_Call 

type FileRecorder_RecordFile_Call struct {
	*mock.Call
}

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

func (*FileRecorder_RecordFile_Call) Return 

func (_c *FileRecorder_RecordFile_Call) Return() *FileRecorder_RecordFile_Call

func (*FileRecorder_RecordFile_Call) Run 

func (_c *FileRecorder_RecordFile_Call) Run(run func(bucket string, key string)) *FileRecorder_RecordFile_Call

func (*FileRecorder_RecordFile_Call) RunAndReturn 

func (_c *FileRecorder_RecordFile_Call) RunAndReturn(run func(string, string)) *FileRecorder_RecordFile_Call

type FileRecorder_RenameRecordedFiles_Call 

type FileRecorder_RenameRecordedFiles_Call struct {
	*mock.Call
}

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

func (*FileRecorder_RenameRecordedFiles_Call) Return 

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

func (*FileRecorder_RenameRecordedFiles_Call) Run 

func (_c *FileRecorder_RenameRecordedFiles_Call) Run(run func(ctx context.Context, newPrefix string)) *FileRecorder_RenameRecordedFiles_Call

func (*FileRecorder_RenameRecordedFiles_Call) RunAndReturn 

func (_c *FileRecorder_RenameRecordedFiles_Call) RunAndReturn(run func(context.Context, string) error) *FileRecorder_RenameRecordedFiles_Call

type Partitioner 

type Partitioner struct {
	mock.Mock
}

Partitioner is an autogenerated mock type for the Partitioner type

func NewPartitioner 

func NewPartitioner(t interface {
	mock.TestingT
	Cleanup(func())
}) *Partitioner

NewPartitioner creates a new instance of Partitioner. 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 (*Partitioner) EXPECT 

func (_m *Partitioner) EXPECT() *Partitioner_Expecter

func (*Partitioner) Flush 

func (_m *Partitioner) Flush()

Flush provides a mock function with given fields:

func (*Partitioner) Ingest 

func (_m *Partitioner) Ingest(data parquet.Partitionable)

Ingest provides a mock function with given fields: data

func (*Partitioner) Out 

func (_m *Partitioner) Out() <-chan *parquet.Partition

Out provides a mock function with given fields:

func (*Partitioner) Size 

func (_m *Partitioner) Size() int

Size provides a mock function with given fields:

func (*Partitioner) Start 

func (_m *Partitioner) Start()

Start provides a mock function with given fields:

func (*Partitioner) Stop 

func (_m *Partitioner) Stop()

Stop provides a mock function with given fields:

func (*Partitioner) Trim 

func (_m *Partitioner) Trim(size int)

Trim provides a mock function with given fields: size

type Partitioner_Expecter 

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

func (*Partitioner_Expecter) Flush 

func (_e *Partitioner_Expecter) Flush() *Partitioner_Flush_Call

Flush is a helper method to define mock.On call

func (*Partitioner_Expecter) Ingest 

func (_e *Partitioner_Expecter) Ingest(data interface{}) *Partitioner_Ingest_Call

Ingest is a helper method to define mock.On call

  • data parquet.Partitionable

func (*Partitioner_Expecter) Out 

func (_e *Partitioner_Expecter) Out() *Partitioner_Out_Call

Out is a helper method to define mock.On call

func (*Partitioner_Expecter) Size 

func (_e *Partitioner_Expecter) Size() *Partitioner_Size_Call

Size is a helper method to define mock.On call

func (*Partitioner_Expecter) Start 

func (_e *Partitioner_Expecter) Start() *Partitioner_Start_Call

Start is a helper method to define mock.On call

func (*Partitioner_Expecter) Stop 

func (_e *Partitioner_Expecter) Stop() *Partitioner_Stop_Call

Stop is a helper method to define mock.On call

func (*Partitioner_Expecter) Trim 

func (_e *Partitioner_Expecter) Trim(size interface{}) *Partitioner_Trim_Call

Trim is a helper method to define mock.On call

  • size int

type Partitioner_Flush_Call 

type Partitioner_Flush_Call struct {
	*mock.Call
}

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

func (*Partitioner_Flush_Call) Return 

func (_c *Partitioner_Flush_Call) Return() *Partitioner_Flush_Call

func (*Partitioner_Flush_Call) Run 

func (_c *Partitioner_Flush_Call) Run(run func()) *Partitioner_Flush_Call

func (*Partitioner_Flush_Call) RunAndReturn 

func (_c *Partitioner_Flush_Call) RunAndReturn(run func()) *Partitioner_Flush_Call

type Partitioner_Ingest_Call 

type Partitioner_Ingest_Call struct {
	*mock.Call
}

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

func (*Partitioner_Ingest_Call) Return 

func (_c *Partitioner_Ingest_Call) Return() *Partitioner_Ingest_Call

func (*Partitioner_Ingest_Call) Run 

func (_c *Partitioner_Ingest_Call) Run(run func(data parquet.Partitionable)) *Partitioner_Ingest_Call

func (*Partitioner_Ingest_Call) RunAndReturn 

func (_c *Partitioner_Ingest_Call) RunAndReturn(run func(parquet.Partitionable)) *Partitioner_Ingest_Call

type Partitioner_Out_Call 

type Partitioner_Out_Call struct {
	*mock.Call
}

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

func (*Partitioner_Out_Call) Return 

func (_c *Partitioner_Out_Call) Return(_a0 <-chan *parquet.Partition) *Partitioner_Out_Call

func (*Partitioner_Out_Call) Run 

func (_c *Partitioner_Out_Call) Run(run func()) *Partitioner_Out_Call

func (*Partitioner_Out_Call) RunAndReturn 

func (_c *Partitioner_Out_Call) RunAndReturn(run func() <-chan *parquet.Partition) *Partitioner_Out_Call

type Partitioner_Size_Call 

type Partitioner_Size_Call struct {
	*mock.Call
}

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

func (*Partitioner_Size_Call) Return 

func (_c *Partitioner_Size_Call) Return(_a0 int) *Partitioner_Size_Call

func (*Partitioner_Size_Call) Run 

func (_c *Partitioner_Size_Call) Run(run func()) *Partitioner_Size_Call

func (*Partitioner_Size_Call) RunAndReturn 

func (_c *Partitioner_Size_Call) RunAndReturn(run func() int) *Partitioner_Size_Call

type Partitioner_Start_Call 

type Partitioner_Start_Call struct {
	*mock.Call
}

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

func (*Partitioner_Start_Call) Return 

func (_c *Partitioner_Start_Call) Return() *Partitioner_Start_Call

func (*Partitioner_Start_Call) Run 

func (_c *Partitioner_Start_Call) Run(run func()) *Partitioner_Start_Call

func (*Partitioner_Start_Call) RunAndReturn 

func (_c *Partitioner_Start_Call) RunAndReturn(run func()) *Partitioner_Start_Call

type Partitioner_Stop_Call 

type Partitioner_Stop_Call struct {
	*mock.Call
}

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

func (*Partitioner_Stop_Call) Return 

func (_c *Partitioner_Stop_Call) Return() *Partitioner_Stop_Call

func (*Partitioner_Stop_Call) Run 

func (_c *Partitioner_Stop_Call) Run(run func()) *Partitioner_Stop_Call

func (*Partitioner_Stop_Call) RunAndReturn 

func (_c *Partitioner_Stop_Call) RunAndReturn(run func()) *Partitioner_Stop_Call

type Partitioner_Trim_Call 

type Partitioner_Trim_Call struct {
	*mock.Call
}

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

func (*Partitioner_Trim_Call) Return 

func (_c *Partitioner_Trim_Call) Return() *Partitioner_Trim_Call

func (*Partitioner_Trim_Call) Run 

func (_c *Partitioner_Trim_Call) Run(run func(size int)) *Partitioner_Trim_Call

func (*Partitioner_Trim_Call) RunAndReturn 

func (_c *Partitioner_Trim_Call) RunAndReturn(run func(int)) *Partitioner_Trim_Call

type Reader 

type Reader struct {
	mock.Mock
}

Reader is an autogenerated mock type for the Reader type

func NewReader 

func NewReader(t interface {
	mock.TestingT
	Cleanup(func())
}) *Reader

NewReader creates a new instance of Reader. 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 (*Reader) EXPECT 

func (_m *Reader) EXPECT() *Reader_Expecter

func (*Reader) ReadDate 

func (_m *Reader) ReadDate(ctx context.Context, datetime time.Time, target interface{}) error

ReadDate provides a mock function with given fields: ctx, datetime, target

func (*Reader) ReadDateAsync 

func (_m *Reader) ReadDateAsync(ctx context.Context, datetime time.Time, target interface{}, callback parquet.ResultCallback) error

ReadDateAsync provides a mock function with given fields: ctx, datetime, target, callback

func (*Reader) ReadFileIntoTarget 

func (_m *Reader) ReadFileIntoTarget(ctx context.Context, file string, target interface{}, batchSize int, offset int64) error

ReadFileIntoTarget provides a mock function with given fields: ctx, file, target, batchSize, offset

type Reader_Expecter 

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

func (*Reader_Expecter) ReadDate 

func (_e *Reader_Expecter) ReadDate(ctx interface{}, datetime interface{}, target interface{}) *Reader_ReadDate_Call

ReadDate is a helper method to define mock.On call

  • ctx context.Context
  • datetime time.Time
  • target interface{}

func (*Reader_Expecter) ReadDateAsync 

func (_e *Reader_Expecter) ReadDateAsync(ctx interface{}, datetime interface{}, target interface{}, callback interface{}) *Reader_ReadDateAsync_Call

ReadDateAsync is a helper method to define mock.On call

  • ctx context.Context
  • datetime time.Time
  • target interface{}
  • callback parquet.ResultCallback

func (*Reader_Expecter) ReadFileIntoTarget 

func (_e *Reader_Expecter) ReadFileIntoTarget(ctx interface{}, file interface{}, target interface{}, batchSize interface{}, offset interface{}) *Reader_ReadFileIntoTarget_Call

ReadFileIntoTarget is a helper method to define mock.On call

  • ctx context.Context
  • file string
  • target interface{}
  • batchSize int
  • offset int64

type Reader_ReadDateAsync_Call 

type Reader_ReadDateAsync_Call struct {
	*mock.Call
}

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

func (*Reader_ReadDateAsync_Call) Return 

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

func (*Reader_ReadDateAsync_Call) Run 

func (_c *Reader_ReadDateAsync_Call) Run(run func(ctx context.Context, datetime time.Time, target interface{}, callback parquet.ResultCallback)) *Reader_ReadDateAsync_Call

func (*Reader_ReadDateAsync_Call) RunAndReturn 

func (_c *Reader_ReadDateAsync_Call) RunAndReturn(run func(context.Context, time.Time, interface{}, parquet.ResultCallback) error) *Reader_ReadDateAsync_Call

type Reader_ReadDate_Call 

type Reader_ReadDate_Call struct {
	*mock.Call
}

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

func (*Reader_ReadDate_Call) Return 

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

func (*Reader_ReadDate_Call) Run 

func (_c *Reader_ReadDate_Call) Run(run func(ctx context.Context, datetime time.Time, target interface{})) *Reader_ReadDate_Call

func (*Reader_ReadDate_Call) RunAndReturn 

func (_c *Reader_ReadDate_Call) RunAndReturn(run func(context.Context, time.Time, interface{}) error) *Reader_ReadDate_Call

type Reader_ReadFileIntoTarget_Call 

type Reader_ReadFileIntoTarget_Call struct {
	*mock.Call
}

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

func (*Reader_ReadFileIntoTarget_Call) Return 

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

func (*Reader_ReadFileIntoTarget_Call) Run 

func (_c *Reader_ReadFileIntoTarget_Call) Run(run func(ctx context.Context, file string, target interface{}, batchSize int, offset int64)) *Reader_ReadFileIntoTarget_Call

func (*Reader_ReadFileIntoTarget_Call) RunAndReturn 

func (_c *Reader_ReadFileIntoTarget_Call) RunAndReturn(run func(context.Context, string, interface{}, int, int64) error) *Reader_ReadFileIntoTarget_Call

type Writer 

type Writer struct {
	mock.Mock
}

Writer is an autogenerated mock type for the Writer type

func NewWriter 

func NewWriter(t interface {
	mock.TestingT
	Cleanup(func())
}) *Writer

NewWriter creates a new instance of Writer. 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 (*Writer) EXPECT 

func (_m *Writer) EXPECT() *Writer_Expecter

func (*Writer) Write 

func (_m *Writer) Write(ctx context.Context, datetime time.Time, items interface{}) error

Write provides a mock function with given fields: ctx, datetime, items

func (*Writer) WriteToKey 

func (_m *Writer) WriteToKey(ctx context.Context, key string, items interface{}) error

WriteToKey provides a mock function with given fields: ctx, key, items

type Writer_Expecter 

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

func (*Writer_Expecter) Write 

func (_e *Writer_Expecter) Write(ctx interface{}, datetime interface{}, items interface{}) *Writer_Write_Call

Write is a helper method to define mock.On call

  • ctx context.Context
  • datetime time.Time
  • items interface{}

func (*Writer_Expecter) WriteToKey 

func (_e *Writer_Expecter) WriteToKey(ctx interface{}, key interface{}, items interface{}) *Writer_WriteToKey_Call

WriteToKey is a helper method to define mock.On call

  • ctx context.Context
  • key string
  • items interface{}

type Writer_WriteToKey_Call 

type Writer_WriteToKey_Call struct {
	*mock.Call
}

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

func (*Writer_WriteToKey_Call) Return 

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

func (*Writer_WriteToKey_Call) Run 

func (_c *Writer_WriteToKey_Call) Run(run func(ctx context.Context, key string, items interface{})) *Writer_WriteToKey_Call

func (*Writer_WriteToKey_Call) RunAndReturn 

func (_c *Writer_WriteToKey_Call) RunAndReturn(run func(context.Context, string, interface{}) error) *Writer_WriteToKey_Call

type Writer_Write_Call 

type Writer_Write_Call struct {
	*mock.Call
}

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

func (*Writer_Write_Call) Return 

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

func (*Writer_Write_Call) Run 

func (_c *Writer_Write_Call) Run(run func(ctx context.Context, datetime time.Time, items interface{})) *Writer_Write_Call

func (*Writer_Write_Call) RunAndReturn 

func (_c *Writer_Write_Call) RunAndReturn(run func(context.Context, time.Time, interface{}) error) *Writer_Write_Call

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.