Documentation ¶
Index ¶
- type 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) ListFiles(ctx context.Context, prefix string, recursive bool) ([]*puller.ListObject, error)
- func (_m *DataPuller) Pull(ctx context.Context, clusterName string, runID string) (string, error)
- type DataPuller_Close_Call
- type DataPuller_Expecter
- 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) ListFiles(ctx interface{}, prefix interface{}, recursive interface{}) *DataPuller_ListFiles_Call
- func (_e *DataPuller_Expecter) Pull(ctx interface{}, clusterName interface{}, runID interface{}) *DataPuller_Pull_Call
- type DataPuller_Extract_Call
- 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_ListFiles_Call
- 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
- type DataPuller_Pull_Call
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DataPuller ¶
DataPuller is an autogenerated mock type for the DataPuller type
func NewDataPuller ¶
func NewDataPuller(t mockConstructorTestingTNewDataPuller) *DataPuller
NewDataPuller creates a new instance of DataPuller. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*DataPuller) Close ¶
func (_m *DataPuller) Close(ctx context.Context, basePath string) error
Close provides a mock function with given fields: ctx, basePath
func (*DataPuller) EXPECT ¶
func (_m *DataPuller) EXPECT() *DataPuller_Expecter
func (*DataPuller) Extract ¶
func (_m *DataPuller) Extract(ctx context.Context, archivePath string) error
Extract provides a mock function with given fields: ctx, archivePath
func (*DataPuller) ListFiles ¶ added in v1.3.3
func (_m *DataPuller) ListFiles(ctx context.Context, prefix string, recursive bool) ([]*puller.ListObject, error)
ListFiles provides a mock function with given fields: ctx, prefix, recursive
type DataPuller_Close_Call ¶
DataPuller_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'
func (*DataPuller_Close_Call) Return ¶
func (_c *DataPuller_Close_Call) Return(_a0 error) *DataPuller_Close_Call
func (*DataPuller_Close_Call) Run ¶
func (_c *DataPuller_Close_Call) Run(run func(ctx context.Context, basePath string)) *DataPuller_Close_Call
func (*DataPuller_Close_Call) RunAndReturn ¶
func (_c *DataPuller_Close_Call) RunAndReturn(run func(context.Context, string) error) *DataPuller_Close_Call
type DataPuller_Expecter ¶
type DataPuller_Expecter struct {
// contains filtered or unexported fields
}
func (*DataPuller_Expecter) Close ¶
func (_e *DataPuller_Expecter) Close(ctx interface{}, basePath interface{}) *DataPuller_Close_Call
Close is a helper method to define mock.On call
- ctx context.Context
- basePath string
func (*DataPuller_Expecter) Extract ¶
func (_e *DataPuller_Expecter) Extract(ctx interface{}, archivePath interface{}) *DataPuller_Extract_Call
Extract is a helper method to define mock.On call
- ctx context.Context
- archivePath string
func (*DataPuller_Expecter) ListFiles ¶ added in v1.3.3
func (_e *DataPuller_Expecter) ListFiles(ctx interface{}, prefix interface{}, recursive interface{}) *DataPuller_ListFiles_Call
ListFiles is a helper method to define mock.On call
- ctx context.Context
- prefix string
- recursive bool
func (*DataPuller_Expecter) Pull ¶
func (_e *DataPuller_Expecter) Pull(ctx interface{}, clusterName interface{}, runID interface{}) *DataPuller_Pull_Call
Pull is a helper method to define mock.On call
- ctx context.Context
- clusterName string
- runID string
type DataPuller_Extract_Call ¶
DataPuller_Extract_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Extract'
func (*DataPuller_Extract_Call) Return ¶
func (_c *DataPuller_Extract_Call) Return(_a0 error) *DataPuller_Extract_Call
func (*DataPuller_Extract_Call) Run ¶
func (_c *DataPuller_Extract_Call) Run(run func(ctx context.Context, archivePath string)) *DataPuller_Extract_Call
func (*DataPuller_Extract_Call) RunAndReturn ¶
func (_c *DataPuller_Extract_Call) RunAndReturn(run func(context.Context, string) error) *DataPuller_Extract_Call
type DataPuller_ListFiles_Call ¶ added in v1.3.3
DataPuller_ListFiles_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListFiles'
func (*DataPuller_ListFiles_Call) Return ¶ added in v1.3.3
func (_c *DataPuller_ListFiles_Call) Return(_a0 []*puller.ListObject, _a1 error) *DataPuller_ListFiles_Call
func (*DataPuller_ListFiles_Call) Run ¶ added in v1.3.3
func (_c *DataPuller_ListFiles_Call) Run(run func(ctx context.Context, prefix string, recursive bool)) *DataPuller_ListFiles_Call
func (*DataPuller_ListFiles_Call) RunAndReturn ¶ added in v1.3.3
func (_c *DataPuller_ListFiles_Call) RunAndReturn(run func(context.Context, string, bool) ([]*puller.ListObject, error)) *DataPuller_ListFiles_Call
type DataPuller_Pull_Call ¶
DataPuller_Pull_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Pull'
func (*DataPuller_Pull_Call) Return ¶
func (_c *DataPuller_Pull_Call) Return(_a0 string, _a1 error) *DataPuller_Pull_Call
func (*DataPuller_Pull_Call) Run ¶
func (_c *DataPuller_Pull_Call) Run(run func(ctx context.Context, clusterName string, runID string)) *DataPuller_Pull_Call
func (*DataPuller_Pull_Call) RunAndReturn ¶
func (_c *DataPuller_Pull_Call) RunAndReturn(run func(context.Context, string, string) (string, error)) *DataPuller_Pull_Call