Documentation
¶
Index ¶
- type AuditEventRepository
- func (_m *AuditEventRepository) Create(_a0 context.Context, _a1 domain.AuditEvent) (domain.AuditEvent, error)
- func (_m *AuditEventRepository) EXPECT() *AuditEventRepository_Expecter
- func (_m *AuditEventRepository) Get(ctx context.Context, opts ...search.Option) (domain.AuditEvent, error)
- func (_m *AuditEventRepository) List(ctx context.Context, opts ...search.Option) (resource.ListResponse[domain.AuditEvent], error)
- func (_m *AuditEventRepository) Query(ctx context.Context, f app.AuditEventFilter) (resource.ListResponse[domain.AuditEvent], error)
- type AuditEventRepository_Create_Call
- func (_c *AuditEventRepository_Create_Call) Return(_a0 domain.AuditEvent, _a1 error) *AuditEventRepository_Create_Call
- func (_c *AuditEventRepository_Create_Call) Run(run func(_a0 context.Context, _a1 domain.AuditEvent)) *AuditEventRepository_Create_Call
- func (_c *AuditEventRepository_Create_Call) RunAndReturn(run func(context.Context, domain.AuditEvent) (domain.AuditEvent, error)) *AuditEventRepository_Create_Call
- type AuditEventRepository_Expecter
- func (_e *AuditEventRepository_Expecter) Create(_a0 interface{}, _a1 interface{}) *AuditEventRepository_Create_Call
- func (_e *AuditEventRepository_Expecter) Get(ctx interface{}, opts ...interface{}) *AuditEventRepository_Get_Call
- func (_e *AuditEventRepository_Expecter) List(ctx interface{}, opts ...interface{}) *AuditEventRepository_List_Call
- func (_e *AuditEventRepository_Expecter) Query(ctx interface{}, f interface{}) *AuditEventRepository_Query_Call
- type AuditEventRepository_Get_Call
- func (_c *AuditEventRepository_Get_Call) Return(_a0 domain.AuditEvent, _a1 error) *AuditEventRepository_Get_Call
- func (_c *AuditEventRepository_Get_Call) Run(run func(ctx context.Context, opts ...search.Option)) *AuditEventRepository_Get_Call
- func (_c *AuditEventRepository_Get_Call) RunAndReturn(run func(context.Context, ...search.Option) (domain.AuditEvent, error)) *AuditEventRepository_Get_Call
- type AuditEventRepository_List_Call
- func (_c *AuditEventRepository_List_Call) Return(_a0 resource.ListResponse[domain.AuditEvent], _a1 error) *AuditEventRepository_List_Call
- func (_c *AuditEventRepository_List_Call) Run(run func(ctx context.Context, opts ...search.Option)) *AuditEventRepository_List_Call
- func (_c *AuditEventRepository_List_Call) RunAndReturn(...) *AuditEventRepository_List_Call
- type AuditEventRepository_Query_Call
- func (_c *AuditEventRepository_Query_Call) Return(_a0 resource.ListResponse[domain.AuditEvent], _a1 error) *AuditEventRepository_Query_Call
- func (_c *AuditEventRepository_Query_Call) Run(run func(ctx context.Context, f app.AuditEventFilter)) *AuditEventRepository_Query_Call
- func (_c *AuditEventRepository_Query_Call) RunAndReturn(...) *AuditEventRepository_Query_Call
- type AuditEventUsecase
- func (_m *AuditEventUsecase) Append(ctx context.Context, event domain.AuditEvent) (domain.AuditEvent, error)
- func (_m *AuditEventUsecase) EXPECT() *AuditEventUsecase_Expecter
- func (_m *AuditEventUsecase) Get(ctx context.Context, opts ...search.Option) (domain.AuditEvent, error)
- func (_m *AuditEventUsecase) List(ctx context.Context, opts ...search.Option) (resource.ListResponse[domain.AuditEvent], error)
- func (_m *AuditEventUsecase) Query(ctx context.Context, f app.AuditEventFilter) (resource.ListResponse[domain.AuditEvent], error)
- func (_m *AuditEventUsecase) Subscribe(f app.AuditEventFilter) (*app.Subscription, error)
- type AuditEventUsecase_Append_Call
- func (_c *AuditEventUsecase_Append_Call) Return(_a0 domain.AuditEvent, _a1 error) *AuditEventUsecase_Append_Call
- func (_c *AuditEventUsecase_Append_Call) Run(run func(ctx context.Context, event domain.AuditEvent)) *AuditEventUsecase_Append_Call
- func (_c *AuditEventUsecase_Append_Call) RunAndReturn(run func(context.Context, domain.AuditEvent) (domain.AuditEvent, error)) *AuditEventUsecase_Append_Call
- type AuditEventUsecase_Expecter
- func (_e *AuditEventUsecase_Expecter) Append(ctx interface{}, event interface{}) *AuditEventUsecase_Append_Call
- func (_e *AuditEventUsecase_Expecter) Get(ctx interface{}, opts ...interface{}) *AuditEventUsecase_Get_Call
- func (_e *AuditEventUsecase_Expecter) List(ctx interface{}, opts ...interface{}) *AuditEventUsecase_List_Call
- func (_e *AuditEventUsecase_Expecter) Query(ctx interface{}, f interface{}) *AuditEventUsecase_Query_Call
- func (_e *AuditEventUsecase_Expecter) Subscribe(f interface{}) *AuditEventUsecase_Subscribe_Call
- type AuditEventUsecase_Get_Call
- func (_c *AuditEventUsecase_Get_Call) Return(_a0 domain.AuditEvent, _a1 error) *AuditEventUsecase_Get_Call
- func (_c *AuditEventUsecase_Get_Call) Run(run func(ctx context.Context, opts ...search.Option)) *AuditEventUsecase_Get_Call
- func (_c *AuditEventUsecase_Get_Call) RunAndReturn(run func(context.Context, ...search.Option) (domain.AuditEvent, error)) *AuditEventUsecase_Get_Call
- type AuditEventUsecase_List_Call
- func (_c *AuditEventUsecase_List_Call) Return(_a0 resource.ListResponse[domain.AuditEvent], _a1 error) *AuditEventUsecase_List_Call
- func (_c *AuditEventUsecase_List_Call) Run(run func(ctx context.Context, opts ...search.Option)) *AuditEventUsecase_List_Call
- func (_c *AuditEventUsecase_List_Call) RunAndReturn(...) *AuditEventUsecase_List_Call
- type AuditEventUsecase_Query_Call
- func (_c *AuditEventUsecase_Query_Call) Return(_a0 resource.ListResponse[domain.AuditEvent], _a1 error) *AuditEventUsecase_Query_Call
- func (_c *AuditEventUsecase_Query_Call) Run(run func(ctx context.Context, f app.AuditEventFilter)) *AuditEventUsecase_Query_Call
- func (_c *AuditEventUsecase_Query_Call) RunAndReturn(...) *AuditEventUsecase_Query_Call
- type AuditEventUsecase_Subscribe_Call
- func (_c *AuditEventUsecase_Subscribe_Call) Return(_a0 *app.Subscription, _a1 error) *AuditEventUsecase_Subscribe_Call
- func (_c *AuditEventUsecase_Subscribe_Call) Run(run func(f app.AuditEventFilter)) *AuditEventUsecase_Subscribe_Call
- func (_c *AuditEventUsecase_Subscribe_Call) RunAndReturn(run func(app.AuditEventFilter) (*app.Subscription, error)) *AuditEventUsecase_Subscribe_Call
- type Forwarder
- type Forwarder_Expecter
- type Forwarder_Forward_Call
- func (_c *Forwarder_Forward_Call) Return(_a0 error) *Forwarder_Forward_Call
- func (_c *Forwarder_Forward_Call) Run(run func(ctx context.Context, event domain.AuditEvent)) *Forwarder_Forward_Call
- func (_c *Forwarder_Forward_Call) RunAndReturn(run func(context.Context, domain.AuditEvent) error) *Forwarder_Forward_Call
- type Forwarder_Name_Call
- type PartitionStore
- type PartitionStore_DropPartition_Call
- func (_c *PartitionStore_DropPartition_Call) Return(_a0 error) *PartitionStore_DropPartition_Call
- func (_c *PartitionStore_DropPartition_Call) Run(run func(ctx context.Context, name string)) *PartitionStore_DropPartition_Call
- func (_c *PartitionStore_DropPartition_Call) RunAndReturn(run func(context.Context, string) error) *PartitionStore_DropPartition_Call
- type PartitionStore_Expecter
- type PartitionStore_ListMonthlyPartitions_Call
- func (_c *PartitionStore_ListMonthlyPartitions_Call) Return(_a0 []string, _a1 error) *PartitionStore_ListMonthlyPartitions_Call
- func (_c *PartitionStore_ListMonthlyPartitions_Call) Run(run func(ctx context.Context)) *PartitionStore_ListMonthlyPartitions_Call
- func (_c *PartitionStore_ListMonthlyPartitions_Call) RunAndReturn(run func(context.Context) ([]string, error)) *PartitionStore_ListMonthlyPartitions_Call
- type RetentionSweeper
- type RetentionSweeper_Expecter
- type RetentionSweeper_Sweep_Call
- func (_c *RetentionSweeper_Sweep_Call) Return(_a0 int, _a1 error) *RetentionSweeper_Sweep_Call
- func (_c *RetentionSweeper_Sweep_Call) Run(run func(ctx context.Context, before time.Time)) *RetentionSweeper_Sweep_Call
- func (_c *RetentionSweeper_Sweep_Call) RunAndReturn(run func(context.Context, time.Time) (int, error)) *RetentionSweeper_Sweep_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AuditEventRepository ¶
AuditEventRepository is an autogenerated mock type for the AuditEventRepository type
func NewAuditEventRepository ¶
func NewAuditEventRepository(t interface {
mock.TestingT
Cleanup(func())
}) *AuditEventRepository
NewAuditEventRepository creates a new instance of AuditEventRepository. 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 (*AuditEventRepository) Create ¶
func (_m *AuditEventRepository) Create(_a0 context.Context, _a1 domain.AuditEvent) (domain.AuditEvent, error)
Create provides a mock function with given fields: _a0, _a1
func (*AuditEventRepository) EXPECT ¶
func (_m *AuditEventRepository) EXPECT() *AuditEventRepository_Expecter
func (*AuditEventRepository) Get ¶
func (_m *AuditEventRepository) Get(ctx context.Context, opts ...search.Option) (domain.AuditEvent, error)
Get provides a mock function with given fields: ctx, opts
func (*AuditEventRepository) List ¶
func (_m *AuditEventRepository) List(ctx context.Context, opts ...search.Option) (resource.ListResponse[domain.AuditEvent], error)
List provides a mock function with given fields: ctx, opts
func (*AuditEventRepository) Query ¶
func (_m *AuditEventRepository) Query(ctx context.Context, f app.AuditEventFilter) (resource.ListResponse[domain.AuditEvent], error)
Query provides a mock function with given fields: ctx, f
type AuditEventRepository_Create_Call ¶
AuditEventRepository_Create_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Create'
func (*AuditEventRepository_Create_Call) Return ¶
func (_c *AuditEventRepository_Create_Call) Return(_a0 domain.AuditEvent, _a1 error) *AuditEventRepository_Create_Call
func (*AuditEventRepository_Create_Call) Run ¶
func (_c *AuditEventRepository_Create_Call) Run(run func(_a0 context.Context, _a1 domain.AuditEvent)) *AuditEventRepository_Create_Call
func (*AuditEventRepository_Create_Call) RunAndReturn ¶
func (_c *AuditEventRepository_Create_Call) RunAndReturn(run func(context.Context, domain.AuditEvent) (domain.AuditEvent, error)) *AuditEventRepository_Create_Call
type AuditEventRepository_Expecter ¶
type AuditEventRepository_Expecter struct {
// contains filtered or unexported fields
}
func (*AuditEventRepository_Expecter) Create ¶
func (_e *AuditEventRepository_Expecter) Create(_a0 interface{}, _a1 interface{}) *AuditEventRepository_Create_Call
Create is a helper method to define mock.On call
- _a0 context.Context
- _a1 domain.AuditEvent
func (*AuditEventRepository_Expecter) Get ¶
func (_e *AuditEventRepository_Expecter) Get(ctx interface{}, opts ...interface{}) *AuditEventRepository_Get_Call
Get is a helper method to define mock.On call
- ctx context.Context
- opts ...search.Option
func (*AuditEventRepository_Expecter) List ¶
func (_e *AuditEventRepository_Expecter) List(ctx interface{}, opts ...interface{}) *AuditEventRepository_List_Call
List is a helper method to define mock.On call
- ctx context.Context
- opts ...search.Option
func (*AuditEventRepository_Expecter) Query ¶
func (_e *AuditEventRepository_Expecter) Query(ctx interface{}, f interface{}) *AuditEventRepository_Query_Call
Query is a helper method to define mock.On call
- ctx context.Context
- f app.AuditEventFilter
type AuditEventRepository_Get_Call ¶
AuditEventRepository_Get_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Get'
func (*AuditEventRepository_Get_Call) Return ¶
func (_c *AuditEventRepository_Get_Call) Return(_a0 domain.AuditEvent, _a1 error) *AuditEventRepository_Get_Call
func (*AuditEventRepository_Get_Call) Run ¶
func (_c *AuditEventRepository_Get_Call) Run(run func(ctx context.Context, opts ...search.Option)) *AuditEventRepository_Get_Call
func (*AuditEventRepository_Get_Call) RunAndReturn ¶
func (_c *AuditEventRepository_Get_Call) RunAndReturn(run func(context.Context, ...search.Option) (domain.AuditEvent, error)) *AuditEventRepository_Get_Call
type AuditEventRepository_List_Call ¶
AuditEventRepository_List_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'List'
func (*AuditEventRepository_List_Call) Return ¶
func (_c *AuditEventRepository_List_Call) Return(_a0 resource.ListResponse[domain.AuditEvent], _a1 error) *AuditEventRepository_List_Call
func (*AuditEventRepository_List_Call) Run ¶
func (_c *AuditEventRepository_List_Call) Run(run func(ctx context.Context, opts ...search.Option)) *AuditEventRepository_List_Call
func (*AuditEventRepository_List_Call) RunAndReturn ¶
func (_c *AuditEventRepository_List_Call) RunAndReturn(run func(context.Context, ...search.Option) (resource.ListResponse[domain.AuditEvent], error)) *AuditEventRepository_List_Call
type AuditEventRepository_Query_Call ¶
AuditEventRepository_Query_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Query'
func (*AuditEventRepository_Query_Call) Return ¶
func (_c *AuditEventRepository_Query_Call) Return(_a0 resource.ListResponse[domain.AuditEvent], _a1 error) *AuditEventRepository_Query_Call
func (*AuditEventRepository_Query_Call) Run ¶
func (_c *AuditEventRepository_Query_Call) Run(run func(ctx context.Context, f app.AuditEventFilter)) *AuditEventRepository_Query_Call
func (*AuditEventRepository_Query_Call) RunAndReturn ¶
func (_c *AuditEventRepository_Query_Call) RunAndReturn(run func(context.Context, app.AuditEventFilter) (resource.ListResponse[domain.AuditEvent], error)) *AuditEventRepository_Query_Call
type AuditEventUsecase ¶
AuditEventUsecase is an autogenerated mock type for the AuditEventUsecase type
func NewAuditEventUsecase ¶
func NewAuditEventUsecase(t interface {
mock.TestingT
Cleanup(func())
}) *AuditEventUsecase
NewAuditEventUsecase creates a new instance of AuditEventUsecase. 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 (*AuditEventUsecase) Append ¶
func (_m *AuditEventUsecase) Append(ctx context.Context, event domain.AuditEvent) (domain.AuditEvent, error)
Append provides a mock function with given fields: ctx, event
func (*AuditEventUsecase) EXPECT ¶
func (_m *AuditEventUsecase) EXPECT() *AuditEventUsecase_Expecter
func (*AuditEventUsecase) Get ¶
func (_m *AuditEventUsecase) Get(ctx context.Context, opts ...search.Option) (domain.AuditEvent, error)
Get provides a mock function with given fields: ctx, opts
func (*AuditEventUsecase) List ¶
func (_m *AuditEventUsecase) List(ctx context.Context, opts ...search.Option) (resource.ListResponse[domain.AuditEvent], error)
List provides a mock function with given fields: ctx, opts
func (*AuditEventUsecase) Query ¶
func (_m *AuditEventUsecase) Query(ctx context.Context, f app.AuditEventFilter) (resource.ListResponse[domain.AuditEvent], error)
Query provides a mock function with given fields: ctx, f
func (*AuditEventUsecase) Subscribe ¶
func (_m *AuditEventUsecase) Subscribe(f app.AuditEventFilter) (*app.Subscription, error)
Subscribe provides a mock function with given fields: f
type AuditEventUsecase_Append_Call ¶
AuditEventUsecase_Append_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Append'
func (*AuditEventUsecase_Append_Call) Return ¶
func (_c *AuditEventUsecase_Append_Call) Return(_a0 domain.AuditEvent, _a1 error) *AuditEventUsecase_Append_Call
func (*AuditEventUsecase_Append_Call) Run ¶
func (_c *AuditEventUsecase_Append_Call) Run(run func(ctx context.Context, event domain.AuditEvent)) *AuditEventUsecase_Append_Call
func (*AuditEventUsecase_Append_Call) RunAndReturn ¶
func (_c *AuditEventUsecase_Append_Call) RunAndReturn(run func(context.Context, domain.AuditEvent) (domain.AuditEvent, error)) *AuditEventUsecase_Append_Call
type AuditEventUsecase_Expecter ¶
type AuditEventUsecase_Expecter struct {
// contains filtered or unexported fields
}
func (*AuditEventUsecase_Expecter) Append ¶
func (_e *AuditEventUsecase_Expecter) Append(ctx interface{}, event interface{}) *AuditEventUsecase_Append_Call
Append is a helper method to define mock.On call
- ctx context.Context
- event domain.AuditEvent
func (*AuditEventUsecase_Expecter) Get ¶
func (_e *AuditEventUsecase_Expecter) Get(ctx interface{}, opts ...interface{}) *AuditEventUsecase_Get_Call
Get is a helper method to define mock.On call
- ctx context.Context
- opts ...search.Option
func (*AuditEventUsecase_Expecter) List ¶
func (_e *AuditEventUsecase_Expecter) List(ctx interface{}, opts ...interface{}) *AuditEventUsecase_List_Call
List is a helper method to define mock.On call
- ctx context.Context
- opts ...search.Option
func (*AuditEventUsecase_Expecter) Query ¶
func (_e *AuditEventUsecase_Expecter) Query(ctx interface{}, f interface{}) *AuditEventUsecase_Query_Call
Query is a helper method to define mock.On call
- ctx context.Context
- f app.AuditEventFilter
func (*AuditEventUsecase_Expecter) Subscribe ¶
func (_e *AuditEventUsecase_Expecter) Subscribe(f interface{}) *AuditEventUsecase_Subscribe_Call
Subscribe is a helper method to define mock.On call
- f app.AuditEventFilter
type AuditEventUsecase_Get_Call ¶
AuditEventUsecase_Get_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Get'
func (*AuditEventUsecase_Get_Call) Return ¶
func (_c *AuditEventUsecase_Get_Call) Return(_a0 domain.AuditEvent, _a1 error) *AuditEventUsecase_Get_Call
func (*AuditEventUsecase_Get_Call) Run ¶
func (_c *AuditEventUsecase_Get_Call) Run(run func(ctx context.Context, opts ...search.Option)) *AuditEventUsecase_Get_Call
func (*AuditEventUsecase_Get_Call) RunAndReturn ¶
func (_c *AuditEventUsecase_Get_Call) RunAndReturn(run func(context.Context, ...search.Option) (domain.AuditEvent, error)) *AuditEventUsecase_Get_Call
type AuditEventUsecase_List_Call ¶
AuditEventUsecase_List_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'List'
func (*AuditEventUsecase_List_Call) Return ¶
func (_c *AuditEventUsecase_List_Call) Return(_a0 resource.ListResponse[domain.AuditEvent], _a1 error) *AuditEventUsecase_List_Call
func (*AuditEventUsecase_List_Call) Run ¶
func (_c *AuditEventUsecase_List_Call) Run(run func(ctx context.Context, opts ...search.Option)) *AuditEventUsecase_List_Call
func (*AuditEventUsecase_List_Call) RunAndReturn ¶
func (_c *AuditEventUsecase_List_Call) RunAndReturn(run func(context.Context, ...search.Option) (resource.ListResponse[domain.AuditEvent], error)) *AuditEventUsecase_List_Call
type AuditEventUsecase_Query_Call ¶
AuditEventUsecase_Query_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Query'
func (*AuditEventUsecase_Query_Call) Return ¶
func (_c *AuditEventUsecase_Query_Call) Return(_a0 resource.ListResponse[domain.AuditEvent], _a1 error) *AuditEventUsecase_Query_Call
func (*AuditEventUsecase_Query_Call) Run ¶
func (_c *AuditEventUsecase_Query_Call) Run(run func(ctx context.Context, f app.AuditEventFilter)) *AuditEventUsecase_Query_Call
func (*AuditEventUsecase_Query_Call) RunAndReturn ¶
func (_c *AuditEventUsecase_Query_Call) RunAndReturn(run func(context.Context, app.AuditEventFilter) (resource.ListResponse[domain.AuditEvent], error)) *AuditEventUsecase_Query_Call
type AuditEventUsecase_Subscribe_Call ¶
AuditEventUsecase_Subscribe_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Subscribe'
func (*AuditEventUsecase_Subscribe_Call) Return ¶
func (_c *AuditEventUsecase_Subscribe_Call) Return(_a0 *app.Subscription, _a1 error) *AuditEventUsecase_Subscribe_Call
func (*AuditEventUsecase_Subscribe_Call) Run ¶
func (_c *AuditEventUsecase_Subscribe_Call) Run(run func(f app.AuditEventFilter)) *AuditEventUsecase_Subscribe_Call
func (*AuditEventUsecase_Subscribe_Call) RunAndReturn ¶
func (_c *AuditEventUsecase_Subscribe_Call) RunAndReturn(run func(app.AuditEventFilter) (*app.Subscription, error)) *AuditEventUsecase_Subscribe_Call
type Forwarder ¶
Forwarder is an autogenerated mock type for the Forwarder type
func NewForwarder ¶
NewForwarder creates a new instance of Forwarder. 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 (*Forwarder) EXPECT ¶
func (_m *Forwarder) EXPECT() *Forwarder_Expecter
type Forwarder_Expecter ¶
type Forwarder_Expecter struct {
// contains filtered or unexported fields
}
func (*Forwarder_Expecter) Forward ¶
func (_e *Forwarder_Expecter) Forward(ctx interface{}, event interface{}) *Forwarder_Forward_Call
Forward is a helper method to define mock.On call
- ctx context.Context
- event domain.AuditEvent
func (*Forwarder_Expecter) Name ¶
func (_e *Forwarder_Expecter) Name() *Forwarder_Name_Call
Name is a helper method to define mock.On call
type Forwarder_Forward_Call ¶
Forwarder_Forward_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Forward'
func (*Forwarder_Forward_Call) Return ¶
func (_c *Forwarder_Forward_Call) Return(_a0 error) *Forwarder_Forward_Call
func (*Forwarder_Forward_Call) Run ¶
func (_c *Forwarder_Forward_Call) Run(run func(ctx context.Context, event domain.AuditEvent)) *Forwarder_Forward_Call
func (*Forwarder_Forward_Call) RunAndReturn ¶
func (_c *Forwarder_Forward_Call) RunAndReturn(run func(context.Context, domain.AuditEvent) error) *Forwarder_Forward_Call
type Forwarder_Name_Call ¶
Forwarder_Name_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Name'
func (*Forwarder_Name_Call) Return ¶
func (_c *Forwarder_Name_Call) Return(_a0 string) *Forwarder_Name_Call
func (*Forwarder_Name_Call) Run ¶
func (_c *Forwarder_Name_Call) Run(run func()) *Forwarder_Name_Call
func (*Forwarder_Name_Call) RunAndReturn ¶
func (_c *Forwarder_Name_Call) RunAndReturn(run func() string) *Forwarder_Name_Call
type PartitionStore ¶
PartitionStore is an autogenerated mock type for the PartitionStore type
func NewPartitionStore ¶
func NewPartitionStore(t interface {
mock.TestingT
Cleanup(func())
}) *PartitionStore
NewPartitionStore creates a new instance of PartitionStore. 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 (*PartitionStore) DropPartition ¶
func (_m *PartitionStore) DropPartition(ctx context.Context, name string) error
DropPartition provides a mock function with given fields: ctx, name
func (*PartitionStore) EXPECT ¶
func (_m *PartitionStore) EXPECT() *PartitionStore_Expecter
func (*PartitionStore) ListMonthlyPartitions ¶
func (_m *PartitionStore) ListMonthlyPartitions(ctx context.Context) ([]string, error)
ListMonthlyPartitions provides a mock function with given fields: ctx
type PartitionStore_DropPartition_Call ¶
PartitionStore_DropPartition_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DropPartition'
func (*PartitionStore_DropPartition_Call) Return ¶
func (_c *PartitionStore_DropPartition_Call) Return(_a0 error) *PartitionStore_DropPartition_Call
func (*PartitionStore_DropPartition_Call) Run ¶
func (_c *PartitionStore_DropPartition_Call) Run(run func(ctx context.Context, name string)) *PartitionStore_DropPartition_Call
func (*PartitionStore_DropPartition_Call) RunAndReturn ¶
func (_c *PartitionStore_DropPartition_Call) RunAndReturn(run func(context.Context, string) error) *PartitionStore_DropPartition_Call
type PartitionStore_Expecter ¶
type PartitionStore_Expecter struct {
// contains filtered or unexported fields
}
func (*PartitionStore_Expecter) DropPartition ¶
func (_e *PartitionStore_Expecter) DropPartition(ctx interface{}, name interface{}) *PartitionStore_DropPartition_Call
DropPartition is a helper method to define mock.On call
- ctx context.Context
- name string
func (*PartitionStore_Expecter) ListMonthlyPartitions ¶
func (_e *PartitionStore_Expecter) ListMonthlyPartitions(ctx interface{}) *PartitionStore_ListMonthlyPartitions_Call
ListMonthlyPartitions is a helper method to define mock.On call
- ctx context.Context
type PartitionStore_ListMonthlyPartitions_Call ¶
PartitionStore_ListMonthlyPartitions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListMonthlyPartitions'
func (*PartitionStore_ListMonthlyPartitions_Call) Return ¶
func (_c *PartitionStore_ListMonthlyPartitions_Call) Return(_a0 []string, _a1 error) *PartitionStore_ListMonthlyPartitions_Call
func (*PartitionStore_ListMonthlyPartitions_Call) Run ¶
func (_c *PartitionStore_ListMonthlyPartitions_Call) Run(run func(ctx context.Context)) *PartitionStore_ListMonthlyPartitions_Call
func (*PartitionStore_ListMonthlyPartitions_Call) RunAndReturn ¶
func (_c *PartitionStore_ListMonthlyPartitions_Call) RunAndReturn(run func(context.Context) ([]string, error)) *PartitionStore_ListMonthlyPartitions_Call
type RetentionSweeper ¶
RetentionSweeper is an autogenerated mock type for the RetentionSweeper type
func NewRetentionSweeper ¶
func NewRetentionSweeper(t interface {
mock.TestingT
Cleanup(func())
}) *RetentionSweeper
NewRetentionSweeper creates a new instance of RetentionSweeper. 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 (*RetentionSweeper) EXPECT ¶
func (_m *RetentionSweeper) EXPECT() *RetentionSweeper_Expecter
type RetentionSweeper_Expecter ¶
type RetentionSweeper_Expecter struct {
// contains filtered or unexported fields
}
func (*RetentionSweeper_Expecter) Sweep ¶
func (_e *RetentionSweeper_Expecter) Sweep(ctx interface{}, before interface{}) *RetentionSweeper_Sweep_Call
Sweep is a helper method to define mock.On call
- ctx context.Context
- before time.Time
type RetentionSweeper_Sweep_Call ¶
RetentionSweeper_Sweep_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Sweep'
func (*RetentionSweeper_Sweep_Call) Return ¶
func (_c *RetentionSweeper_Sweep_Call) Return(_a0 int, _a1 error) *RetentionSweeper_Sweep_Call
func (*RetentionSweeper_Sweep_Call) Run ¶
func (_c *RetentionSweeper_Sweep_Call) Run(run func(ctx context.Context, before time.Time)) *RetentionSweeper_Sweep_Call
func (*RetentionSweeper_Sweep_Call) RunAndReturn ¶
func (_c *RetentionSweeper_Sweep_Call) RunAndReturn(run func(context.Context, time.Time) (int, error)) *RetentionSweeper_Sweep_Call