mocks

Jul 25, 2024

Changes in this version

type DataPuller

+ func (_m *DataPuller) ListFiles(ctx context.Context, prefix string, recursive bool) ([]*puller.ListObject, error)

type DataPuller_Expecter

+ func (_e *DataPuller_Expecter) ListFiles(ctx interface{}, prefix interface{}, recursive interface{}) *DataPuller_ListFiles_Call

+ type DataPuller_ListFiles_Call struct

+ func (_c *DataPuller_ListFiles_Call) Return(_a0 []*puller.ListObject, _a1 error) *DataPuller_ListFiles_Call

+ func (_c *DataPuller_ListFiles_Call) Run(run func(ctx context.Context, prefix string, recursive bool)) *DataPuller_ListFiles_Call

+ func (_c *DataPuller_ListFiles_Call) RunAndReturn(run func(context.Context, string, bool) ([]*puller.ListObject, error)) *DataPuller_ListFiles_Call

Jun 21, 2024

Changes in this version

+ type DataPuller struct

+ func NewDataPuller(t mockConstructorTestingTNewDataPuller) *DataPuller

+ func (_m *DataPuller) Close(ctx context.Context, basePath string) error

+ func (_m *DataPuller) EXPECT() *DataPuller_Expecter

+ func (_m *DataPuller) Extract(ctx context.Context, archivePath string) error

+ func (_m *DataPuller) Pull(ctx context.Context, clusterName string, runID string) (string, error)

+ type DataPuller_Close_Call struct

+ func (_c *DataPuller_Close_Call) Return(_a0 error) *DataPuller_Close_Call

+ func (_c *DataPuller_Close_Call) Run(run func(ctx context.Context, basePath string)) *DataPuller_Close_Call

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

+ type DataPuller_Expecter struct

+ func (_e *DataPuller_Expecter) Close(ctx interface{}, basePath interface{}) *DataPuller_Close_Call

+ func (_e *DataPuller_Expecter) Extract(ctx interface{}, archivePath interface{}) *DataPuller_Extract_Call

+ func (_e *DataPuller_Expecter) Pull(ctx interface{}, clusterName interface{}, runID interface{}) *DataPuller_Pull_Call

+ type DataPuller_Extract_Call struct

+ func (_c *DataPuller_Extract_Call) Return(_a0 error) *DataPuller_Extract_Call

+ func (_c *DataPuller_Extract_Call) Run(run func(ctx context.Context, archivePath string)) *DataPuller_Extract_Call

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

+ type DataPuller_Pull_Call struct

+ func (_c *DataPuller_Pull_Call) Return(_a0 string, _a1 error) *DataPuller_Pull_Call

+ func (_c *DataPuller_Pull_Call) Run(run func(ctx context.Context, clusterName string, runID string)) *DataPuller_Pull_Call

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