Documentation
¶
Index ¶
- type MockBlobRepository
- func (_m *MockBlobRepository) Delete(ctx context.Context, key string) error
- func (_m *MockBlobRepository) EXPECT() *MockBlobRepository_Expecter
- func (_m *MockBlobRepository) Exists(ctx context.Context, path string) (bool, error)
- func (_m *MockBlobRepository) List(ctx context.Context, filter blob.Filter) iter.Seq2[blob.Object, error]
- func (_m *MockBlobRepository) NewReader(ctx context.Context, key string) (io.ReadCloser, error)
- func (_m *MockBlobRepository) NewWriter(ctx context.Context, key string) (io.WriteCloser, error)
- type MockBlobRepository_Delete_Call
- func (_c *MockBlobRepository_Delete_Call) Return(_a0 error) *MockBlobRepository_Delete_Call
- func (_c *MockBlobRepository_Delete_Call) Run(run func(ctx context.Context, key string)) *MockBlobRepository_Delete_Call
- func (_c *MockBlobRepository_Delete_Call) RunAndReturn(run func(context.Context, string) error) *MockBlobRepository_Delete_Call
- type MockBlobRepository_Exists_Call
- func (_c *MockBlobRepository_Exists_Call) Return(_a0 bool, _a1 error) *MockBlobRepository_Exists_Call
- func (_c *MockBlobRepository_Exists_Call) Run(run func(ctx context.Context, path string)) *MockBlobRepository_Exists_Call
- func (_c *MockBlobRepository_Exists_Call) RunAndReturn(run func(context.Context, string) (bool, error)) *MockBlobRepository_Exists_Call
- type MockBlobRepository_Expecter
- func (_e *MockBlobRepository_Expecter) Delete(ctx interface{}, key interface{}) *MockBlobRepository_Delete_Call
- func (_e *MockBlobRepository_Expecter) Exists(ctx interface{}, path interface{}) *MockBlobRepository_Exists_Call
- func (_e *MockBlobRepository_Expecter) List(ctx interface{}, filter interface{}) *MockBlobRepository_List_Call
- func (_e *MockBlobRepository_Expecter) NewReader(ctx interface{}, key interface{}) *MockBlobRepository_NewReader_Call
- func (_e *MockBlobRepository_Expecter) NewWriter(ctx interface{}, key interface{}) *MockBlobRepository_NewWriter_Call
- type MockBlobRepository_List_Call
- func (_c *MockBlobRepository_List_Call) Return(_a0 iter.Seq2[blob.Object, error]) *MockBlobRepository_List_Call
- func (_c *MockBlobRepository_List_Call) Run(run func(ctx context.Context, filter blob.Filter)) *MockBlobRepository_List_Call
- func (_c *MockBlobRepository_List_Call) RunAndReturn(run func(context.Context, blob.Filter) iter.Seq2[blob.Object, error]) *MockBlobRepository_List_Call
- type MockBlobRepository_NewReader_Call
- func (_c *MockBlobRepository_NewReader_Call) Return(_a0 io.ReadCloser, _a1 error) *MockBlobRepository_NewReader_Call
- func (_c *MockBlobRepository_NewReader_Call) Run(run func(ctx context.Context, key string)) *MockBlobRepository_NewReader_Call
- func (_c *MockBlobRepository_NewReader_Call) RunAndReturn(run func(context.Context, string) (io.ReadCloser, error)) *MockBlobRepository_NewReader_Call
- type MockBlobRepository_NewWriter_Call
- func (_c *MockBlobRepository_NewWriter_Call) Return(_a0 io.WriteCloser, _a1 error) *MockBlobRepository_NewWriter_Call
- func (_c *MockBlobRepository_NewWriter_Call) Run(run func(ctx context.Context, key string)) *MockBlobRepository_NewWriter_Call
- func (_c *MockBlobRepository_NewWriter_Call) RunAndReturn(run func(context.Context, string) (io.WriteCloser, error)) *MockBlobRepository_NewWriter_Call
- type MockClient
- func (_m *MockClient) Download(ctx context.Context, app string, w io.Writer) error
- func (_m *MockClient) EXPECT() *MockClient_Expecter
- func (_m *MockClient) ProfileAndUpload(ctx context.Context, app string, src string, duration time.Duration) error
- func (_m *MockClient) Upload(ctx context.Context, app string, r io.Reader) error
- type MockClient_Download_Call
- func (_c *MockClient_Download_Call) Return(_a0 error) *MockClient_Download_Call
- func (_c *MockClient_Download_Call) Run(run func(ctx context.Context, app string, w io.Writer)) *MockClient_Download_Call
- func (_c *MockClient_Download_Call) RunAndReturn(run func(context.Context, string, io.Writer) error) *MockClient_Download_Call
- type MockClient_Expecter
- func (_e *MockClient_Expecter) Download(ctx interface{}, app interface{}, w interface{}) *MockClient_Download_Call
- func (_e *MockClient_Expecter) ProfileAndUpload(ctx interface{}, app interface{}, src interface{}, duration interface{}) *MockClient_ProfileAndUpload_Call
- func (_e *MockClient_Expecter) Upload(ctx interface{}, app interface{}, r interface{}) *MockClient_Upload_Call
- type MockClient_ProfileAndUpload_Call
- func (_c *MockClient_ProfileAndUpload_Call) Return(_a0 error) *MockClient_ProfileAndUpload_Call
- func (_c *MockClient_ProfileAndUpload_Call) Run(run func(ctx context.Context, app string, src string, duration time.Duration)) *MockClient_ProfileAndUpload_Call
- func (_c *MockClient_ProfileAndUpload_Call) RunAndReturn(run func(context.Context, string, string, time.Duration) error) *MockClient_ProfileAndUpload_Call
- type MockClient_Upload_Call
- func (_c *MockClient_Upload_Call) Return(_a0 error) *MockClient_Upload_Call
- func (_c *MockClient_Upload_Call) Run(run func(ctx context.Context, app string, r io.Reader)) *MockClient_Upload_Call
- func (_c *MockClient_Upload_Call) RunAndReturn(run func(context.Context, string, io.Reader) error) *MockClient_Upload_Call
- type MockEventWriter
- type MockEventWriter_Expecter
- type MockEventWriter_Write_Call
- func (_c *MockEventWriter_Write_Call) Return(_a0 error) *MockEventWriter_Write_Call
- func (_c *MockEventWriter_Write_Call) Run(run func(ctx context.Context, evt event.Payload)) *MockEventWriter_Write_Call
- func (_c *MockEventWriter_Write_Call) RunAndReturn(run func(context.Context, event.Payload) error) *MockEventWriter_Write_Call
- type MockTargetSource
- type MockTargetSource_Expecter
- type MockTargetSource_List_Call
- func (_c *MockTargetSource_List_Call) Return(_a0 []target.Target, _a1 error) *MockTargetSource_List_Call
- func (_c *MockTargetSource_List_Call) Run(run func(ctx context.Context)) *MockTargetSource_List_Call
- func (_c *MockTargetSource_List_Call) RunAndReturn(run func(context.Context) ([]target.Target, error)) *MockTargetSource_List_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockBlobRepository ¶
MockBlobRepository is an autogenerated mock type for the BlobRepository type
func NewMockBlobRepository ¶
func NewMockBlobRepository(t interface {
mock.TestingT
Cleanup(func())
}) *MockBlobRepository
NewMockBlobRepository creates a new instance of MockBlobRepository. 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 (*MockBlobRepository) Delete ¶
func (_m *MockBlobRepository) Delete(ctx context.Context, key string) error
Delete provides a mock function with given fields: ctx, key
func (*MockBlobRepository) EXPECT ¶
func (_m *MockBlobRepository) EXPECT() *MockBlobRepository_Expecter
func (*MockBlobRepository) List ¶
func (_m *MockBlobRepository) List(ctx context.Context, filter blob.Filter) iter.Seq2[blob.Object, error]
List provides a mock function with given fields: ctx, filter
func (*MockBlobRepository) NewReader ¶
func (_m *MockBlobRepository) NewReader(ctx context.Context, key string) (io.ReadCloser, error)
NewReader provides a mock function with given fields: ctx, key
func (*MockBlobRepository) NewWriter ¶
func (_m *MockBlobRepository) NewWriter(ctx context.Context, key string) (io.WriteCloser, error)
NewWriter provides a mock function with given fields: ctx, key
type MockBlobRepository_Delete_Call ¶
MockBlobRepository_Delete_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Delete'
func (*MockBlobRepository_Delete_Call) Return ¶
func (_c *MockBlobRepository_Delete_Call) Return(_a0 error) *MockBlobRepository_Delete_Call
func (*MockBlobRepository_Delete_Call) Run ¶
func (_c *MockBlobRepository_Delete_Call) Run(run func(ctx context.Context, key string)) *MockBlobRepository_Delete_Call
func (*MockBlobRepository_Delete_Call) RunAndReturn ¶
func (_c *MockBlobRepository_Delete_Call) RunAndReturn(run func(context.Context, string) error) *MockBlobRepository_Delete_Call
type MockBlobRepository_Exists_Call ¶
MockBlobRepository_Exists_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Exists'
func (*MockBlobRepository_Exists_Call) Return ¶
func (_c *MockBlobRepository_Exists_Call) Return(_a0 bool, _a1 error) *MockBlobRepository_Exists_Call
func (*MockBlobRepository_Exists_Call) Run ¶
func (_c *MockBlobRepository_Exists_Call) Run(run func(ctx context.Context, path string)) *MockBlobRepository_Exists_Call
func (*MockBlobRepository_Exists_Call) RunAndReturn ¶
func (_c *MockBlobRepository_Exists_Call) RunAndReturn(run func(context.Context, string) (bool, error)) *MockBlobRepository_Exists_Call
type MockBlobRepository_Expecter ¶
type MockBlobRepository_Expecter struct {
// contains filtered or unexported fields
}
func (*MockBlobRepository_Expecter) Delete ¶
func (_e *MockBlobRepository_Expecter) Delete(ctx interface{}, key interface{}) *MockBlobRepository_Delete_Call
Delete is a helper method to define mock.On call
- ctx context.Context
- key string
func (*MockBlobRepository_Expecter) Exists ¶
func (_e *MockBlobRepository_Expecter) Exists(ctx interface{}, path interface{}) *MockBlobRepository_Exists_Call
Exists is a helper method to define mock.On call
- ctx context.Context
- path string
func (*MockBlobRepository_Expecter) List ¶
func (_e *MockBlobRepository_Expecter) List(ctx interface{}, filter interface{}) *MockBlobRepository_List_Call
List is a helper method to define mock.On call
- ctx context.Context
- filter blob.Filter
func (*MockBlobRepository_Expecter) NewReader ¶
func (_e *MockBlobRepository_Expecter) NewReader(ctx interface{}, key interface{}) *MockBlobRepository_NewReader_Call
NewReader is a helper method to define mock.On call
- ctx context.Context
- key string
func (*MockBlobRepository_Expecter) NewWriter ¶
func (_e *MockBlobRepository_Expecter) NewWriter(ctx interface{}, key interface{}) *MockBlobRepository_NewWriter_Call
NewWriter is a helper method to define mock.On call
- ctx context.Context
- key string
type MockBlobRepository_List_Call ¶
MockBlobRepository_List_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'List'
func (*MockBlobRepository_List_Call) Return ¶
func (_c *MockBlobRepository_List_Call) Return(_a0 iter.Seq2[blob.Object, error]) *MockBlobRepository_List_Call
func (*MockBlobRepository_List_Call) Run ¶
func (_c *MockBlobRepository_List_Call) Run(run func(ctx context.Context, filter blob.Filter)) *MockBlobRepository_List_Call
func (*MockBlobRepository_List_Call) RunAndReturn ¶
type MockBlobRepository_NewReader_Call ¶
MockBlobRepository_NewReader_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NewReader'
func (*MockBlobRepository_NewReader_Call) Return ¶
func (_c *MockBlobRepository_NewReader_Call) Return(_a0 io.ReadCloser, _a1 error) *MockBlobRepository_NewReader_Call
func (*MockBlobRepository_NewReader_Call) Run ¶
func (_c *MockBlobRepository_NewReader_Call) Run(run func(ctx context.Context, key string)) *MockBlobRepository_NewReader_Call
func (*MockBlobRepository_NewReader_Call) RunAndReturn ¶
func (_c *MockBlobRepository_NewReader_Call) RunAndReturn(run func(context.Context, string) (io.ReadCloser, error)) *MockBlobRepository_NewReader_Call
type MockBlobRepository_NewWriter_Call ¶
MockBlobRepository_NewWriter_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NewWriter'
func (*MockBlobRepository_NewWriter_Call) Return ¶
func (_c *MockBlobRepository_NewWriter_Call) Return(_a0 io.WriteCloser, _a1 error) *MockBlobRepository_NewWriter_Call
func (*MockBlobRepository_NewWriter_Call) Run ¶
func (_c *MockBlobRepository_NewWriter_Call) Run(run func(ctx context.Context, key string)) *MockBlobRepository_NewWriter_Call
func (*MockBlobRepository_NewWriter_Call) RunAndReturn ¶
func (_c *MockBlobRepository_NewWriter_Call) RunAndReturn(run func(context.Context, string) (io.WriteCloser, error)) *MockBlobRepository_NewWriter_Call
type MockClient ¶
MockClient is an autogenerated mock type for the Client type
func NewMockClient ¶
func NewMockClient(t interface {
mock.TestingT
Cleanup(func())
}) *MockClient
NewMockClient creates a new instance of MockClient. 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 (*MockClient) EXPECT ¶
func (_m *MockClient) EXPECT() *MockClient_Expecter
func (*MockClient) ProfileAndUpload ¶
func (_m *MockClient) ProfileAndUpload(ctx context.Context, app string, src string, duration time.Duration) error
ProfileAndUpload provides a mock function with given fields: ctx, app, src, duration
type MockClient_Download_Call ¶
MockClient_Download_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Download'
func (*MockClient_Download_Call) Return ¶
func (_c *MockClient_Download_Call) Return(_a0 error) *MockClient_Download_Call
func (*MockClient_Download_Call) Run ¶
func (_c *MockClient_Download_Call) Run(run func(ctx context.Context, app string, w io.Writer)) *MockClient_Download_Call
func (*MockClient_Download_Call) RunAndReturn ¶
func (_c *MockClient_Download_Call) RunAndReturn(run func(context.Context, string, io.Writer) error) *MockClient_Download_Call
type MockClient_Expecter ¶
type MockClient_Expecter struct {
// contains filtered or unexported fields
}
func (*MockClient_Expecter) Download ¶
func (_e *MockClient_Expecter) Download(ctx interface{}, app interface{}, w interface{}) *MockClient_Download_Call
Download is a helper method to define mock.On call
- ctx context.Context
- app string
- w io.Writer
func (*MockClient_Expecter) ProfileAndUpload ¶
func (_e *MockClient_Expecter) ProfileAndUpload(ctx interface{}, app interface{}, src interface{}, duration interface{}) *MockClient_ProfileAndUpload_Call
ProfileAndUpload is a helper method to define mock.On call
- ctx context.Context
- app string
- src string
- duration time.Duration
func (*MockClient_Expecter) Upload ¶
func (_e *MockClient_Expecter) Upload(ctx interface{}, app interface{}, r interface{}) *MockClient_Upload_Call
Upload is a helper method to define mock.On call
- ctx context.Context
- app string
- r io.Reader
type MockClient_ProfileAndUpload_Call ¶
MockClient_ProfileAndUpload_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ProfileAndUpload'
func (*MockClient_ProfileAndUpload_Call) Return ¶
func (_c *MockClient_ProfileAndUpload_Call) Return(_a0 error) *MockClient_ProfileAndUpload_Call
func (*MockClient_ProfileAndUpload_Call) Run ¶
func (_c *MockClient_ProfileAndUpload_Call) Run(run func(ctx context.Context, app string, src string, duration time.Duration)) *MockClient_ProfileAndUpload_Call
func (*MockClient_ProfileAndUpload_Call) RunAndReturn ¶
func (_c *MockClient_ProfileAndUpload_Call) RunAndReturn(run func(context.Context, string, string, time.Duration) error) *MockClient_ProfileAndUpload_Call
type MockClient_Upload_Call ¶
MockClient_Upload_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Upload'
func (*MockClient_Upload_Call) Return ¶
func (_c *MockClient_Upload_Call) Return(_a0 error) *MockClient_Upload_Call
func (*MockClient_Upload_Call) Run ¶
func (_c *MockClient_Upload_Call) Run(run func(ctx context.Context, app string, r io.Reader)) *MockClient_Upload_Call
func (*MockClient_Upload_Call) RunAndReturn ¶
func (_c *MockClient_Upload_Call) RunAndReturn(run func(context.Context, string, io.Reader) error) *MockClient_Upload_Call
type MockEventWriter ¶
MockEventWriter is an autogenerated mock type for the EventWriter type
func NewMockEventWriter ¶
func NewMockEventWriter(t interface {
mock.TestingT
Cleanup(func())
}) *MockEventWriter
NewMockEventWriter creates a new instance of MockEventWriter. 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 (*MockEventWriter) EXPECT ¶
func (_m *MockEventWriter) EXPECT() *MockEventWriter_Expecter
type MockEventWriter_Expecter ¶
type MockEventWriter_Expecter struct {
// contains filtered or unexported fields
}
func (*MockEventWriter_Expecter) Write ¶
func (_e *MockEventWriter_Expecter) Write(ctx interface{}, evt interface{}) *MockEventWriter_Write_Call
Write is a helper method to define mock.On call
- ctx context.Context
- evt event.Payload
type MockEventWriter_Write_Call ¶
MockEventWriter_Write_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Write'
func (*MockEventWriter_Write_Call) Return ¶
func (_c *MockEventWriter_Write_Call) Return(_a0 error) *MockEventWriter_Write_Call
func (*MockEventWriter_Write_Call) Run ¶
func (_c *MockEventWriter_Write_Call) Run(run func(ctx context.Context, evt event.Payload)) *MockEventWriter_Write_Call
func (*MockEventWriter_Write_Call) RunAndReturn ¶
func (_c *MockEventWriter_Write_Call) RunAndReturn(run func(context.Context, event.Payload) error) *MockEventWriter_Write_Call
type MockTargetSource ¶ added in v0.7.0
MockTargetSource is an autogenerated mock type for the TargetSource type
func NewMockTargetSource ¶ added in v0.7.0
func NewMockTargetSource(t interface {
mock.TestingT
Cleanup(func())
}) *MockTargetSource
NewMockTargetSource creates a new instance of MockTargetSource. 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 (*MockTargetSource) EXPECT ¶ added in v0.7.0
func (_m *MockTargetSource) EXPECT() *MockTargetSource_Expecter
type MockTargetSource_Expecter ¶ added in v0.7.0
type MockTargetSource_Expecter struct {
// contains filtered or unexported fields
}
func (*MockTargetSource_Expecter) List ¶ added in v0.7.0
func (_e *MockTargetSource_Expecter) List(ctx interface{}) *MockTargetSource_List_Call
List is a helper method to define mock.On call
- ctx context.Context
type MockTargetSource_List_Call ¶ added in v0.7.0
MockTargetSource_List_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'List'
func (*MockTargetSource_List_Call) Return ¶ added in v0.7.0
func (_c *MockTargetSource_List_Call) Return(_a0 []target.Target, _a1 error) *MockTargetSource_List_Call
func (*MockTargetSource_List_Call) Run ¶ added in v0.7.0
func (_c *MockTargetSource_List_Call) Run(run func(ctx context.Context)) *MockTargetSource_List_Call
func (*MockTargetSource_List_Call) RunAndReturn ¶ added in v0.7.0
func (_c *MockTargetSource_List_Call) RunAndReturn(run func(context.Context) ([]target.Target, error)) *MockTargetSource_List_Call