mocks

Jun 21, 2024

Changes in this version

type Provider

+ func (_m *Provider) Clean(ctx context.Context, runId string, cluster string) error

+ type Provider_Clean_Call struct

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

+ func (_c *Provider_Clean_Call) Run(run func(ctx context.Context, runId string, cluster string)) *Provider_Clean_Call

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

type Provider_Expecter

+ func (_e *Provider_Expecter) Clean(ctx interface{}, runId interface{}, cluster interface{}) *Provider_Clean_Call

Nov 3, 2023

Changes in this version

type Provider

+ func (_m *Provider) Reader() interface{}

type Provider_Expecter

+ func (_e *Provider_Expecter) Reader() *Provider_Reader_Call

+ type Provider_Reader_Call struct

+ func (_c *Provider_Reader_Call) Return(_a0 interface{}) *Provider_Reader_Call

+ func (_c *Provider_Reader_Call) Run(run func()) *Provider_Reader_Call

+ func (_c *Provider_Reader_Call) RunAndReturn(run func() interface{}) *Provider_Reader_Call

Oct 19, 2023

Changes in this version

type Provider

+ func (_m *Provider) Prepare(ctx context.Context) error

type Provider_Expecter

+ func (_e *Provider_Expecter) Prepare(ctx interface{}) *Provider_Prepare_Call

+ type Provider_Prepare_Call struct

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

+ func (_c *Provider_Prepare_Call) Run(run func(ctx context.Context)) *Provider_Prepare_Call

+ func (_c *Provider_Prepare_Call) RunAndReturn(run func(context.Context) error) *Provider_Prepare_Call

Aug 11, 2023

Changes in this version

+ type AsyncWriter struct

+ func NewAsyncWriter(t mockConstructorTestingTNewAsyncWriter) *AsyncWriter

+ func (_m *AsyncWriter) Close(ctx context.Context) error

+ func (_m *AsyncWriter) EXPECT() *AsyncWriter_Expecter

+ func (_m *AsyncWriter) Flush(ctx context.Context) error

+ func (_m *AsyncWriter) Queue(ctx context.Context, model interface{}) error

+ type AsyncWriter_Close_Call struct

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

+ func (_c *AsyncWriter_Close_Call) Run(run func(ctx context.Context)) *AsyncWriter_Close_Call

+ func (_c *AsyncWriter_Close_Call) RunAndReturn(run func(context.Context) error) *AsyncWriter_Close_Call

+ type AsyncWriter_Expecter struct

+ func (_e *AsyncWriter_Expecter) Close(ctx interface{}) *AsyncWriter_Close_Call

+ func (_e *AsyncWriter_Expecter) Flush(ctx interface{}) *AsyncWriter_Flush_Call

+ func (_e *AsyncWriter_Expecter) Queue(ctx interface{}, model interface{}) *AsyncWriter_Queue_Call

+ type AsyncWriter_Flush_Call struct

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

+ func (_c *AsyncWriter_Flush_Call) Run(run func(ctx context.Context)) *AsyncWriter_Flush_Call

+ func (_c *AsyncWriter_Flush_Call) RunAndReturn(run func(context.Context) error) *AsyncWriter_Flush_Call

+ type AsyncWriter_Queue_Call struct

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

+ func (_c *AsyncWriter_Queue_Call) Run(run func(ctx context.Context, model interface{})) *AsyncWriter_Queue_Call

+ func (_c *AsyncWriter_Queue_Call) RunAndReturn(run func(context.Context, interface{}) error) *AsyncWriter_Queue_Call

+ type Provider struct

+ func NewProvider(t mockConstructorTestingTNewProvider) *Provider

+ func (_m *Provider) BulkWriter(ctx context.Context, collection collections.Collection, ...) (storedb.AsyncWriter, error)

+ func (_m *Provider) Clear(ctx context.Context) error

+ func (_m *Provider) Close(ctx context.Context) error

+ func (_m *Provider) EXPECT() *Provider_Expecter

+ func (_m *Provider) HealthCheck(ctx context.Context) (bool, error)

+ func (_m *Provider) Name() string

+ func (_m *Provider) Raw() interface{}

+ type Provider_BulkWriter_Call struct

+ func (_c *Provider_BulkWriter_Call) Return(_a0 storedb.AsyncWriter, _a1 error) *Provider_BulkWriter_Call

+ func (_c *Provider_BulkWriter_Call) Run(run func(ctx context.Context, collection collections.Collection, ...)) *Provider_BulkWriter_Call

+ func (_c *Provider_BulkWriter_Call) RunAndReturn(...) *Provider_BulkWriter_Call

+ type Provider_Clear_Call struct

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

+ func (_c *Provider_Clear_Call) Run(run func(ctx context.Context)) *Provider_Clear_Call

+ func (_c *Provider_Clear_Call) RunAndReturn(run func(context.Context) error) *Provider_Clear_Call

+ type Provider_Close_Call struct

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

+ func (_c *Provider_Close_Call) Run(run func(ctx context.Context)) *Provider_Close_Call

+ func (_c *Provider_Close_Call) RunAndReturn(run func(context.Context) error) *Provider_Close_Call

+ type Provider_Expecter struct

+ func (_e *Provider_Expecter) BulkWriter(ctx interface{}, collection interface{}, opts ...interface{}) *Provider_BulkWriter_Call

+ func (_e *Provider_Expecter) Clear(ctx interface{}) *Provider_Clear_Call

+ func (_e *Provider_Expecter) Close(ctx interface{}) *Provider_Close_Call

+ func (_e *Provider_Expecter) HealthCheck(ctx interface{}) *Provider_HealthCheck_Call

+ func (_e *Provider_Expecter) Name() *Provider_Name_Call

+ func (_e *Provider_Expecter) Raw() *Provider_Raw_Call

+ type Provider_HealthCheck_Call struct

+ func (_c *Provider_HealthCheck_Call) Return(_a0 bool, _a1 error) *Provider_HealthCheck_Call

+ func (_c *Provider_HealthCheck_Call) Run(run func(ctx context.Context)) *Provider_HealthCheck_Call

+ func (_c *Provider_HealthCheck_Call) RunAndReturn(run func(context.Context) (bool, error)) *Provider_HealthCheck_Call

+ type Provider_Name_Call struct

+ func (_c *Provider_Name_Call) Return(_a0 string) *Provider_Name_Call

+ func (_c *Provider_Name_Call) Run(run func()) *Provider_Name_Call

+ func (_c *Provider_Name_Call) RunAndReturn(run func() string) *Provider_Name_Call

+ type Provider_Raw_Call struct

+ func (_c *Provider_Raw_Call) Return(_a0 interface{}) *Provider_Raw_Call

+ func (_c *Provider_Raw_Call) Run(run func()) *Provider_Raw_Call

+ func (_c *Provider_Raw_Call) RunAndReturn(run func() interface{}) *Provider_Raw_Call