mocks

Documentation

Index

• type ChangeStream
  • func NewChangeStream(t interface{ ... }) *ChangeStream
  • func (_m *ChangeStream) Close(ctx context.Context) error
  • func (_m *ChangeStream) Current() bson.Raw
  • func (_m *ChangeStream) Decode(val interface{}) error
  • func (_m *ChangeStream) EXPECT() *ChangeStream_Expecter
  • func (_m *ChangeStream) Err() error
  • func (_m *ChangeStream) ID() int64
  • func (_m *ChangeStream) Next(ctx context.Context) bool
  • func (_m *ChangeStream) ResumeToken() bson.Raw
  • func (_m *ChangeStream) SetBatchSize(size int32)
  • func (_m *ChangeStream) TryNext(ctx context.Context) bool
• type ChangeStream_Close_Call
  • func (_c *ChangeStream_Close_Call) Return(_a0 error) *ChangeStream_Close_Call
  • func (_c *ChangeStream_Close_Call) Run(run func(ctx context.Context)) *ChangeStream_Close_Call
  • func (_c *ChangeStream_Close_Call) RunAndReturn(run func(context.Context) error) *ChangeStream_Close_Call
• type ChangeStream_Current_Call
  • func (_c *ChangeStream_Current_Call) Return(_a0 bson.Raw) *ChangeStream_Current_Call
  • func (_c *ChangeStream_Current_Call) Run(run func()) *ChangeStream_Current_Call
  • func (_c *ChangeStream_Current_Call) RunAndReturn(run func() bson.Raw) *ChangeStream_Current_Call
• type ChangeStream_Decode_Call
  • func (_c *ChangeStream_Decode_Call) Return(_a0 error) *ChangeStream_Decode_Call
  • func (_c *ChangeStream_Decode_Call) Run(run func(val interface{})) *ChangeStream_Decode_Call
  • func (_c *ChangeStream_Decode_Call) RunAndReturn(run func(interface{}) error) *ChangeStream_Decode_Call
• type ChangeStream_Err_Call
  • func (_c *ChangeStream_Err_Call) Return(_a0 error) *ChangeStream_Err_Call
  • func (_c *ChangeStream_Err_Call) Run(run func()) *ChangeStream_Err_Call
  • func (_c *ChangeStream_Err_Call) RunAndReturn(run func() error) *ChangeStream_Err_Call
• type ChangeStream_Expecter
  • func (_e *ChangeStream_Expecter) Close(ctx interface{}) *ChangeStream_Close_Call
  • func (_e *ChangeStream_Expecter) Current() *ChangeStream_Current_Call
  • func (_e *ChangeStream_Expecter) Decode(val interface{}) *ChangeStream_Decode_Call
  • func (_e *ChangeStream_Expecter) Err() *ChangeStream_Err_Call
  • func (_e *ChangeStream_Expecter) ID() *ChangeStream_ID_Call
  • func (_e *ChangeStream_Expecter) Next(ctx interface{}) *ChangeStream_Next_Call
  • func (_e *ChangeStream_Expecter) ResumeToken() *ChangeStream_ResumeToken_Call
  • func (_e *ChangeStream_Expecter) SetBatchSize(size interface{}) *ChangeStream_SetBatchSize_Call
  • func (_e *ChangeStream_Expecter) TryNext(ctx interface{}) *ChangeStream_TryNext_Call
• type ChangeStream_ID_Call
  • func (_c *ChangeStream_ID_Call) Return(_a0 int64) *ChangeStream_ID_Call
  • func (_c *ChangeStream_ID_Call) Run(run func()) *ChangeStream_ID_Call
  • func (_c *ChangeStream_ID_Call) RunAndReturn(run func() int64) *ChangeStream_ID_Call
• type ChangeStream_Next_Call
  • func (_c *ChangeStream_Next_Call) Return(_a0 bool) *ChangeStream_Next_Call
  • func (_c *ChangeStream_Next_Call) Run(run func(ctx context.Context)) *ChangeStream_Next_Call
  • func (_c *ChangeStream_Next_Call) RunAndReturn(run func(context.Context) bool) *ChangeStream_Next_Call
• type ChangeStream_ResumeToken_Call
  • func (_c *ChangeStream_ResumeToken_Call) Return(_a0 bson.Raw) *ChangeStream_ResumeToken_Call
  • func (_c *ChangeStream_ResumeToken_Call) Run(run func()) *ChangeStream_ResumeToken_Call
  • func (_c *ChangeStream_ResumeToken_Call) RunAndReturn(run func() bson.Raw) *ChangeStream_ResumeToken_Call
• type ChangeStream_SetBatchSize_Call
  • func (_c *ChangeStream_SetBatchSize_Call) Return() *ChangeStream_SetBatchSize_Call
  • func (_c *ChangeStream_SetBatchSize_Call) Run(run func(size int32)) *ChangeStream_SetBatchSize_Call
  • func (_c *ChangeStream_SetBatchSize_Call) RunAndReturn(run func(int32)) *ChangeStream_SetBatchSize_Call
• type ChangeStream_TryNext_Call
  • func (_c *ChangeStream_TryNext_Call) Return(_a0 bool) *ChangeStream_TryNext_Call
  • func (_c *ChangeStream_TryNext_Call) Run(run func(ctx context.Context)) *ChangeStream_TryNext_Call
  • func (_c *ChangeStream_TryNext_Call) RunAndReturn(run func(context.Context) bool) *ChangeStream_TryNext_Call
• type Client
  • func NewClient(t interface{ ... }) *Client
  • func (_m *Client) Connect(ctx context.Context) error
  • func (_m *Client) Database(name string, opts ...*options.DatabaseOptions) mongoifc.Database
  • func (_m *Client) Disconnect(ctx context.Context) error
  • func (_m *Client) EXPECT() *Client_Expecter
  • func (_m *Client) ListDatabaseNames(ctx context.Context, filter interface{}, opts ...*options.ListDatabasesOptions) ([]string, error)
  • func (_m *Client) ListDatabases(ctx context.Context, filter interface{}, opts ...*options.ListDatabasesOptions) (mongo.ListDatabasesResult, error)
  • func (_m *Client) NumberSessionsInProgress() int
  • func (_m *Client) Ping(ctx context.Context, rp *readpref.ReadPref) error
  • func (_m *Client) StartSession(opts ...*options.SessionOptions) (mongoifc.Session, error)
  • func (_m *Client) Timeout() *time.Duration
  • func (_m *Client) UseSession(ctx context.Context, fn func(mongoifc.SessionContext) error) error
  • func (_m *Client) UseSessionWithOptions(ctx context.Context, opts *options.SessionOptions, ...) error
  • func (_m *Client) Watch(ctx context.Context, pipeline interface{}, ...) (mongoifc.ChangeStream, error)
• type ClientEncryption
  • func NewClientEncryption(t interface{ ... }) *ClientEncryption
  • func (_m *ClientEncryption) AddKeyAltName(ctx context.Context, id primitive.Binary, keyAltName string) mongoifc.SingleResult
  • func (_m *ClientEncryption) Close(ctx context.Context) error
  • func (_m *ClientEncryption) CreateDataKey(ctx context.Context, kmsProvider string, opts ...*options.DataKeyOptions) (primitive.Binary, error)
  • func (_m *ClientEncryption) CreateEncryptedCollection(ctx context.Context, db mongoifc.Database, coll string, ...) (mongoifc.Collection, primitive.M, error)
  • func (_m *ClientEncryption) Decrypt(ctx context.Context, val primitive.Binary) (bson.RawValue, error)
  • func (_m *ClientEncryption) DeleteKey(ctx context.Context, id primitive.Binary) (*mongo.DeleteResult, error)
  • func (_m *ClientEncryption) EXPECT() *ClientEncryption_Expecter
  • func (_m *ClientEncryption) Encrypt(ctx context.Context, val bson.RawValue, opts ...*options.EncryptOptions) (primitive.Binary, error)
  • func (_m *ClientEncryption) EncryptExpression(ctx context.Context, expr interface{}, result interface{}, ...) error
  • func (_m *ClientEncryption) GetKey(ctx context.Context, id primitive.Binary) mongoifc.SingleResult
  • func (_m *ClientEncryption) GetKeyByAltName(ctx context.Context, keyAltName string) mongoifc.SingleResult
  • func (_m *ClientEncryption) GetKeys(ctx context.Context) (mongoifc.Cursor, error)
  • func (_m *ClientEncryption) RemoveKeyAltName(ctx context.Context, id primitive.Binary, keyAltName string) mongoifc.SingleResult
  • func (_m *ClientEncryption) RewrapManyDataKey(ctx context.Context, filter interface{}, ...) (*mongo.RewrapManyDataKeyResult, error)
• type ClientEncryption_AddKeyAltName_Call
  • func (_c *ClientEncryption_AddKeyAltName_Call) Return(_a0 mongoifc.SingleResult) *ClientEncryption_AddKeyAltName_Call
  • func (_c *ClientEncryption_AddKeyAltName_Call) Run(run func(ctx context.Context, id primitive.Binary, keyAltName string)) *ClientEncryption_AddKeyAltName_Call
  • func (_c *ClientEncryption_AddKeyAltName_Call) RunAndReturn(run func(context.Context, primitive.Binary, string) mongoifc.SingleResult) *ClientEncryption_AddKeyAltName_Call
• type ClientEncryption_Close_Call
  • func (_c *ClientEncryption_Close_Call) Return(_a0 error) *ClientEncryption_Close_Call
  • func (_c *ClientEncryption_Close_Call) Run(run func(ctx context.Context)) *ClientEncryption_Close_Call
  • func (_c *ClientEncryption_Close_Call) RunAndReturn(run func(context.Context) error) *ClientEncryption_Close_Call
• type ClientEncryption_CreateDataKey_Call
  • func (_c *ClientEncryption_CreateDataKey_Call) Return(_a0 primitive.Binary, _a1 error) *ClientEncryption_CreateDataKey_Call
  • func (_c *ClientEncryption_CreateDataKey_Call) Run(...) *ClientEncryption_CreateDataKey_Call
  • func (_c *ClientEncryption_CreateDataKey_Call) RunAndReturn(...) *ClientEncryption_CreateDataKey_Call
• type ClientEncryption_CreateEncryptedCollection_Call
  • func (_c *ClientEncryption_CreateEncryptedCollection_Call) Return(_a0 mongoifc.Collection, _a1 primitive.M, _a2 error) *ClientEncryption_CreateEncryptedCollection_Call
  • func (_c *ClientEncryption_CreateEncryptedCollection_Call) Run(run func(ctx context.Context, db mongoifc.Database, coll string, ...)) *ClientEncryption_CreateEncryptedCollection_Call
  • func (_c *ClientEncryption_CreateEncryptedCollection_Call) RunAndReturn(...) *ClientEncryption_CreateEncryptedCollection_Call
• type ClientEncryption_Decrypt_Call
  • func (_c *ClientEncryption_Decrypt_Call) Return(_a0 bson.RawValue, _a1 error) *ClientEncryption_Decrypt_Call
  • func (_c *ClientEncryption_Decrypt_Call) Run(run func(ctx context.Context, val primitive.Binary)) *ClientEncryption_Decrypt_Call
  • func (_c *ClientEncryption_Decrypt_Call) RunAndReturn(run func(context.Context, primitive.Binary) (bson.RawValue, error)) *ClientEncryption_Decrypt_Call
• type ClientEncryption_DeleteKey_Call
  • func (_c *ClientEncryption_DeleteKey_Call) Return(_a0 *mongo.DeleteResult, _a1 error) *ClientEncryption_DeleteKey_Call
  • func (_c *ClientEncryption_DeleteKey_Call) Run(run func(ctx context.Context, id primitive.Binary)) *ClientEncryption_DeleteKey_Call
  • func (_c *ClientEncryption_DeleteKey_Call) RunAndReturn(run func(context.Context, primitive.Binary) (*mongo.DeleteResult, error)) *ClientEncryption_DeleteKey_Call
• type ClientEncryption_EncryptExpression_Call
  • func (_c *ClientEncryption_EncryptExpression_Call) Return(_a0 error) *ClientEncryption_EncryptExpression_Call
  • func (_c *ClientEncryption_EncryptExpression_Call) Run(run func(ctx context.Context, expr interface{}, result interface{}, ...)) *ClientEncryption_EncryptExpression_Call
  • func (_c *ClientEncryption_EncryptExpression_Call) RunAndReturn(...) *ClientEncryption_EncryptExpression_Call
• type ClientEncryption_Encrypt_Call
  • func (_c *ClientEncryption_Encrypt_Call) Return(_a0 primitive.Binary, _a1 error) *ClientEncryption_Encrypt_Call
  • func (_c *ClientEncryption_Encrypt_Call) Run(...) *ClientEncryption_Encrypt_Call
  • func (_c *ClientEncryption_Encrypt_Call) RunAndReturn(...) *ClientEncryption_Encrypt_Call
• type ClientEncryption_Expecter
  • func (_e *ClientEncryption_Expecter) AddKeyAltName(ctx interface{}, id interface{}, keyAltName interface{}) *ClientEncryption_AddKeyAltName_Call
  • func (_e *ClientEncryption_Expecter) Close(ctx interface{}) *ClientEncryption_Close_Call
  • func (_e *ClientEncryption_Expecter) CreateDataKey(ctx interface{}, kmsProvider interface{}, opts ...interface{}) *ClientEncryption_CreateDataKey_Call
  • func (_e *ClientEncryption_Expecter) CreateEncryptedCollection(ctx interface{}, db interface{}, coll interface{}, createOpts interface{}, ...) *ClientEncryption_CreateEncryptedCollection_Call
  • func (_e *ClientEncryption_Expecter) Decrypt(ctx interface{}, val interface{}) *ClientEncryption_Decrypt_Call
  • func (_e *ClientEncryption_Expecter) DeleteKey(ctx interface{}, id interface{}) *ClientEncryption_DeleteKey_Call
  • func (_e *ClientEncryption_Expecter) Encrypt(ctx interface{}, val interface{}, opts ...interface{}) *ClientEncryption_Encrypt_Call
  • func (_e *ClientEncryption_Expecter) EncryptExpression(ctx interface{}, expr interface{}, result interface{}, opts ...interface{}) *ClientEncryption_EncryptExpression_Call
  • func (_e *ClientEncryption_Expecter) GetKey(ctx interface{}, id interface{}) *ClientEncryption_GetKey_Call
  • func (_e *ClientEncryption_Expecter) GetKeyByAltName(ctx interface{}, keyAltName interface{}) *ClientEncryption_GetKeyByAltName_Call
  • func (_e *ClientEncryption_Expecter) GetKeys(ctx interface{}) *ClientEncryption_GetKeys_Call
  • func (_e *ClientEncryption_Expecter) RemoveKeyAltName(ctx interface{}, id interface{}, keyAltName interface{}) *ClientEncryption_RemoveKeyAltName_Call
  • func (_e *ClientEncryption_Expecter) RewrapManyDataKey(ctx interface{}, filter interface{}, opts ...interface{}) *ClientEncryption_RewrapManyDataKey_Call
• type ClientEncryption_GetKeyByAltName_Call
  • func (_c *ClientEncryption_GetKeyByAltName_Call) Return(_a0 mongoifc.SingleResult) *ClientEncryption_GetKeyByAltName_Call
  • func (_c *ClientEncryption_GetKeyByAltName_Call) Run(run func(ctx context.Context, keyAltName string)) *ClientEncryption_GetKeyByAltName_Call
  • func (_c *ClientEncryption_GetKeyByAltName_Call) RunAndReturn(run func(context.Context, string) mongoifc.SingleResult) *ClientEncryption_GetKeyByAltName_Call
• type ClientEncryption_GetKey_Call
  • func (_c *ClientEncryption_GetKey_Call) Return(_a0 mongoifc.SingleResult) *ClientEncryption_GetKey_Call
  • func (_c *ClientEncryption_GetKey_Call) Run(run func(ctx context.Context, id primitive.Binary)) *ClientEncryption_GetKey_Call
  • func (_c *ClientEncryption_GetKey_Call) RunAndReturn(run func(context.Context, primitive.Binary) mongoifc.SingleResult) *ClientEncryption_GetKey_Call
• type ClientEncryption_GetKeys_Call
  • func (_c *ClientEncryption_GetKeys_Call) Return(_a0 mongoifc.Cursor, _a1 error) *ClientEncryption_GetKeys_Call
  • func (_c *ClientEncryption_GetKeys_Call) Run(run func(ctx context.Context)) *ClientEncryption_GetKeys_Call
  • func (_c *ClientEncryption_GetKeys_Call) RunAndReturn(run func(context.Context) (mongoifc.Cursor, error)) *ClientEncryption_GetKeys_Call
• type ClientEncryption_RemoveKeyAltName_Call
  • func (_c *ClientEncryption_RemoveKeyAltName_Call) Return(_a0 mongoifc.SingleResult) *ClientEncryption_RemoveKeyAltName_Call
  • func (_c *ClientEncryption_RemoveKeyAltName_Call) Run(run func(ctx context.Context, id primitive.Binary, keyAltName string)) *ClientEncryption_RemoveKeyAltName_Call
  • func (_c *ClientEncryption_RemoveKeyAltName_Call) RunAndReturn(run func(context.Context, primitive.Binary, string) mongoifc.SingleResult) *ClientEncryption_RemoveKeyAltName_Call
• type ClientEncryption_RewrapManyDataKey_Call
  • func (_c *ClientEncryption_RewrapManyDataKey_Call) Return(_a0 *mongo.RewrapManyDataKeyResult, _a1 error) *ClientEncryption_RewrapManyDataKey_Call
  • func (_c *ClientEncryption_RewrapManyDataKey_Call) Run(run func(ctx context.Context, filter interface{}, ...)) *ClientEncryption_RewrapManyDataKey_Call
  • func (_c *ClientEncryption_RewrapManyDataKey_Call) RunAndReturn(...) *ClientEncryption_RewrapManyDataKey_Call
• type Client_Connect_Call
  • func (_c *Client_Connect_Call) Return(_a0 error) *Client_Connect_Call
  • func (_c *Client_Connect_Call) Run(run func(ctx context.Context)) *Client_Connect_Call
  • func (_c *Client_Connect_Call) RunAndReturn(run func(context.Context) error) *Client_Connect_Call
• type Client_Database_Call
  • func (_c *Client_Database_Call) Return(_a0 mongoifc.Database) *Client_Database_Call
  • func (_c *Client_Database_Call) Run(run func(name string, opts ...*options.DatabaseOptions)) *Client_Database_Call
  • func (_c *Client_Database_Call) RunAndReturn(run func(string, ...*options.DatabaseOptions) mongoifc.Database) *Client_Database_Call
• type Client_Disconnect_Call
  • func (_c *Client_Disconnect_Call) Return(_a0 error) *Client_Disconnect_Call
  • func (_c *Client_Disconnect_Call) Run(run func(ctx context.Context)) *Client_Disconnect_Call
  • func (_c *Client_Disconnect_Call) RunAndReturn(run func(context.Context) error) *Client_Disconnect_Call
• type Client_Expecter
  • func (_e *Client_Expecter) Connect(ctx interface{}) *Client_Connect_Call
  • func (_e *Client_Expecter) Database(name interface{}, opts ...interface{}) *Client_Database_Call
  • func (_e *Client_Expecter) Disconnect(ctx interface{}) *Client_Disconnect_Call
  • func (_e *Client_Expecter) ListDatabaseNames(ctx interface{}, filter interface{}, opts ...interface{}) *Client_ListDatabaseNames_Call
  • func (_e *Client_Expecter) ListDatabases(ctx interface{}, filter interface{}, opts ...interface{}) *Client_ListDatabases_Call
  • func (_e *Client_Expecter) NumberSessionsInProgress() *Client_NumberSessionsInProgress_Call
  • func (_e *Client_Expecter) Ping(ctx interface{}, rp interface{}) *Client_Ping_Call
  • func (_e *Client_Expecter) StartSession(opts ...interface{}) *Client_StartSession_Call
  • func (_e *Client_Expecter) Timeout() *Client_Timeout_Call
  • func (_e *Client_Expecter) UseSession(ctx interface{}, fn interface{}) *Client_UseSession_Call
  • func (_e *Client_Expecter) UseSessionWithOptions(ctx interface{}, opts interface{}, fn interface{}) *Client_UseSessionWithOptions_Call
  • func (_e *Client_Expecter) Watch(ctx interface{}, pipeline interface{}, opts ...interface{}) *Client_Watch_Call
• type Client_ListDatabaseNames_Call
  • func (_c *Client_ListDatabaseNames_Call) Return(_a0 []string, _a1 error) *Client_ListDatabaseNames_Call
  • func (_c *Client_ListDatabaseNames_Call) Run(...) *Client_ListDatabaseNames_Call
  • func (_c *Client_ListDatabaseNames_Call) RunAndReturn(...) *Client_ListDatabaseNames_Call
• type Client_ListDatabases_Call
  • func (_c *Client_ListDatabases_Call) Return(_a0 mongo.ListDatabasesResult, _a1 error) *Client_ListDatabases_Call
  • func (_c *Client_ListDatabases_Call) Run(...) *Client_ListDatabases_Call
  • func (_c *Client_ListDatabases_Call) RunAndReturn(...) *Client_ListDatabases_Call
• type Client_NumberSessionsInProgress_Call
  • func (_c *Client_NumberSessionsInProgress_Call) Return(_a0 int) *Client_NumberSessionsInProgress_Call
  • func (_c *Client_NumberSessionsInProgress_Call) Run(run func()) *Client_NumberSessionsInProgress_Call
  • func (_c *Client_NumberSessionsInProgress_Call) RunAndReturn(run func() int) *Client_NumberSessionsInProgress_Call
• type Client_Ping_Call
  • func (_c *Client_Ping_Call) Return(_a0 error) *Client_Ping_Call
  • func (_c *Client_Ping_Call) Run(run func(ctx context.Context, rp *readpref.ReadPref)) *Client_Ping_Call
  • func (_c *Client_Ping_Call) RunAndReturn(run func(context.Context, *readpref.ReadPref) error) *Client_Ping_Call
• type Client_StartSession_Call
  • func (_c *Client_StartSession_Call) Return(_a0 mongoifc.Session, _a1 error) *Client_StartSession_Call
  • func (_c *Client_StartSession_Call) Run(run func(opts ...*options.SessionOptions)) *Client_StartSession_Call
  • func (_c *Client_StartSession_Call) RunAndReturn(run func(...*options.SessionOptions) (mongoifc.Session, error)) *Client_StartSession_Call
• type Client_Timeout_Call
  • func (_c *Client_Timeout_Call) Return(_a0 *time.Duration) *Client_Timeout_Call
  • func (_c *Client_Timeout_Call) Run(run func()) *Client_Timeout_Call
  • func (_c *Client_Timeout_Call) RunAndReturn(run func() *time.Duration) *Client_Timeout_Call
• type Client_UseSessionWithOptions_Call
  • func (_c *Client_UseSessionWithOptions_Call) Return(_a0 error) *Client_UseSessionWithOptions_Call
  • func (_c *Client_UseSessionWithOptions_Call) Run(run func(ctx context.Context, opts *options.SessionOptions, ...)) *Client_UseSessionWithOptions_Call
  • func (_c *Client_UseSessionWithOptions_Call) RunAndReturn(...) *Client_UseSessionWithOptions_Call
• type Client_UseSession_Call
  • func (_c *Client_UseSession_Call) Return(_a0 error) *Client_UseSession_Call
  • func (_c *Client_UseSession_Call) Run(run func(ctx context.Context, fn func(mongoifc.SessionContext) error)) *Client_UseSession_Call
  • func (_c *Client_UseSession_Call) RunAndReturn(run func(context.Context, func(mongoifc.SessionContext) error) error) *Client_UseSession_Call
• type Client_Watch_Call
  • func (_c *Client_Watch_Call) Return(_a0 mongoifc.ChangeStream, _a1 error) *Client_Watch_Call
  • func (_c *Client_Watch_Call) Run(run func(ctx context.Context, pipeline interface{}, ...)) *Client_Watch_Call
  • func (_c *Client_Watch_Call) RunAndReturn(...) *Client_Watch_Call
• type Collection
  • func NewCollection(t interface{ ... }) *Collection
  • func (_m *Collection) Aggregate(ctx context.Context, pipeline interface{}, opts ...*options.AggregateOptions) (mongoifc.Cursor, error)
  • func (_m *Collection) BulkWrite(ctx context.Context, models []mongo.WriteModel, ...) (*mongo.BulkWriteResult, error)
  • func (_m *Collection) Clone(opts ...*options.CollectionOptions) (mongoifc.Collection, error)
  • func (_m *Collection) CountDocuments(ctx context.Context, filter interface{}, opts ...*options.CountOptions) (int64, error)
  • func (_m *Collection) Database() mongoifc.Database
  • func (_m *Collection) DeleteMany(ctx context.Context, filter interface{}, opts ...*options.DeleteOptions) (*mongo.DeleteResult, error)
  • func (_m *Collection) DeleteOne(ctx context.Context, filter interface{}, opts ...*options.DeleteOptions) (*mongo.DeleteResult, error)
  • func (_m *Collection) Distinct(ctx context.Context, fieldName string, filter interface{}, ...) ([]interface{}, error)
  • func (_m *Collection) Drop(ctx context.Context) error
  • func (_m *Collection) EXPECT() *Collection_Expecter
  • func (_m *Collection) EstimatedDocumentCount(ctx context.Context, opts ...*options.EstimatedDocumentCountOptions) (int64, error)
  • func (_m *Collection) Find(ctx context.Context, filter interface{}, opts ...*options.FindOptions) (mongoifc.Cursor, error)
  • func (_m *Collection) FindOne(ctx context.Context, filter interface{}, opts ...*options.FindOneOptions) mongoifc.SingleResult
  • func (_m *Collection) FindOneAndDelete(ctx context.Context, filter interface{}, ...) mongoifc.SingleResult
  • func (_m *Collection) FindOneAndReplace(ctx context.Context, filter interface{}, replacement interface{}, ...) mongoifc.SingleResult
  • func (_m *Collection) FindOneAndUpdate(ctx context.Context, filter interface{}, update interface{}, ...) mongoifc.SingleResult
  • func (_m *Collection) Indexes() mongoifc.IndexView
  • func (_m *Collection) InsertMany(ctx context.Context, documents []interface{}, ...) (*mongo.InsertManyResult, error)
  • func (_m *Collection) InsertOne(ctx context.Context, document interface{}, opts ...*options.InsertOneOptions) (*mongo.InsertOneResult, error)
  • func (_m *Collection) Name() string
  • func (_m *Collection) ReplaceOne(ctx context.Context, filter interface{}, replacement interface{}, ...) (*mongo.UpdateResult, error)
  • func (_m *Collection) SearchIndexes() mongoifc.SearchIndexView
  • func (_m *Collection) UpdateByID(ctx context.Context, id interface{}, update interface{}, ...) (*mongo.UpdateResult, error)
  • func (_m *Collection) UpdateMany(ctx context.Context, filter interface{}, update interface{}, ...) (*mongo.UpdateResult, error)
  • func (_m *Collection) UpdateOne(ctx context.Context, filter interface{}, update interface{}, ...) (*mongo.UpdateResult, error)
  • func (_m *Collection) Watch(ctx context.Context, pipeline interface{}, ...) (mongoifc.ChangeStream, error)
• type Collection_Aggregate_Call
  • func (_c *Collection_Aggregate_Call) Return(_a0 mongoifc.Cursor, _a1 error) *Collection_Aggregate_Call
  • func (_c *Collection_Aggregate_Call) Run(...) *Collection_Aggregate_Call
  • func (_c *Collection_Aggregate_Call) RunAndReturn(...) *Collection_Aggregate_Call
• type Collection_BulkWrite_Call
  • func (_c *Collection_BulkWrite_Call) Return(_a0 *mongo.BulkWriteResult, _a1 error) *Collection_BulkWrite_Call
  • func (_c *Collection_BulkWrite_Call) Run(run func(ctx context.Context, models []mongo.WriteModel, ...)) *Collection_BulkWrite_Call
  • func (_c *Collection_BulkWrite_Call) RunAndReturn(...) *Collection_BulkWrite_Call
• type Collection_Clone_Call
  • func (_c *Collection_Clone_Call) Return(_a0 mongoifc.Collection, _a1 error) *Collection_Clone_Call
  • func (_c *Collection_Clone_Call) Run(run func(opts ...*options.CollectionOptions)) *Collection_Clone_Call
  • func (_c *Collection_Clone_Call) RunAndReturn(run func(...*options.CollectionOptions) (mongoifc.Collection, error)) *Collection_Clone_Call
• type Collection_CountDocuments_Call
  • func (_c *Collection_CountDocuments_Call) Return(_a0 int64, _a1 error) *Collection_CountDocuments_Call
  • func (_c *Collection_CountDocuments_Call) Run(...) *Collection_CountDocuments_Call
  • func (_c *Collection_CountDocuments_Call) RunAndReturn(...) *Collection_CountDocuments_Call
• type Collection_Database_Call
  • func (_c *Collection_Database_Call) Return(_a0 mongoifc.Database) *Collection_Database_Call
  • func (_c *Collection_Database_Call) Run(run func()) *Collection_Database_Call
  • func (_c *Collection_Database_Call) RunAndReturn(run func() mongoifc.Database) *Collection_Database_Call
• type Collection_DeleteMany_Call
  • func (_c *Collection_DeleteMany_Call) Return(_a0 *mongo.DeleteResult, _a1 error) *Collection_DeleteMany_Call
  • func (_c *Collection_DeleteMany_Call) Run(...) *Collection_DeleteMany_Call
  • func (_c *Collection_DeleteMany_Call) RunAndReturn(...) *Collection_DeleteMany_Call
• type Collection_DeleteOne_Call
  • func (_c *Collection_DeleteOne_Call) Return(_a0 *mongo.DeleteResult, _a1 error) *Collection_DeleteOne_Call
  • func (_c *Collection_DeleteOne_Call) Run(...) *Collection_DeleteOne_Call
  • func (_c *Collection_DeleteOne_Call) RunAndReturn(...) *Collection_DeleteOne_Call
• type Collection_Distinct_Call
  • func (_c *Collection_Distinct_Call) Return(_a0 []interface{}, _a1 error) *Collection_Distinct_Call
  • func (_c *Collection_Distinct_Call) Run(run func(ctx context.Context, fieldName string, filter interface{}, ...)) *Collection_Distinct_Call
  • func (_c *Collection_Distinct_Call) RunAndReturn(...) *Collection_Distinct_Call
• type Collection_Drop_Call
  • func (_c *Collection_Drop_Call) Return(_a0 error) *Collection_Drop_Call
  • func (_c *Collection_Drop_Call) Run(run func(ctx context.Context)) *Collection_Drop_Call
  • func (_c *Collection_Drop_Call) RunAndReturn(run func(context.Context) error) *Collection_Drop_Call
• type Collection_EstimatedDocumentCount_Call
  • func (_c *Collection_EstimatedDocumentCount_Call) Return(_a0 int64, _a1 error) *Collection_EstimatedDocumentCount_Call
  • func (_c *Collection_EstimatedDocumentCount_Call) Run(run func(ctx context.Context, opts ...*options.EstimatedDocumentCountOptions)) *Collection_EstimatedDocumentCount_Call
  • func (_c *Collection_EstimatedDocumentCount_Call) RunAndReturn(...) *Collection_EstimatedDocumentCount_Call
• type Collection_Expecter
  • func (_e *Collection_Expecter) Aggregate(ctx interface{}, pipeline interface{}, opts ...interface{}) *Collection_Aggregate_Call
  • func (_e *Collection_Expecter) BulkWrite(ctx interface{}, models interface{}, opts ...interface{}) *Collection_BulkWrite_Call
  • func (_e *Collection_Expecter) Clone(opts ...interface{}) *Collection_Clone_Call
  • func (_e *Collection_Expecter) CountDocuments(ctx interface{}, filter interface{}, opts ...interface{}) *Collection_CountDocuments_Call
  • func (_e *Collection_Expecter) Database() *Collection_Database_Call
  • func (_e *Collection_Expecter) DeleteMany(ctx interface{}, filter interface{}, opts ...interface{}) *Collection_DeleteMany_Call
  • func (_e *Collection_Expecter) DeleteOne(ctx interface{}, filter interface{}, opts ...interface{}) *Collection_DeleteOne_Call
  • func (_e *Collection_Expecter) Distinct(ctx interface{}, fieldName interface{}, filter interface{}, ...) *Collection_Distinct_Call
  • func (_e *Collection_Expecter) Drop(ctx interface{}) *Collection_Drop_Call
  • func (_e *Collection_Expecter) EstimatedDocumentCount(ctx interface{}, opts ...interface{}) *Collection_EstimatedDocumentCount_Call
  • func (_e *Collection_Expecter) Find(ctx interface{}, filter interface{}, opts ...interface{}) *Collection_Find_Call
  • func (_e *Collection_Expecter) FindOne(ctx interface{}, filter interface{}, opts ...interface{}) *Collection_FindOne_Call
  • func (_e *Collection_Expecter) FindOneAndDelete(ctx interface{}, filter interface{}, opts ...interface{}) *Collection_FindOneAndDelete_Call
  • func (_e *Collection_Expecter) FindOneAndReplace(ctx interface{}, filter interface{}, replacement interface{}, ...) *Collection_FindOneAndReplace_Call
  • func (_e *Collection_Expecter) FindOneAndUpdate(ctx interface{}, filter interface{}, update interface{}, opts ...interface{}) *Collection_FindOneAndUpdate_Call
  • func (_e *Collection_Expecter) Indexes() *Collection_Indexes_Call
  • func (_e *Collection_Expecter) InsertMany(ctx interface{}, documents interface{}, opts ...interface{}) *Collection_InsertMany_Call
  • func (_e *Collection_Expecter) InsertOne(ctx interface{}, document interface{}, opts ...interface{}) *Collection_InsertOne_Call
  • func (_e *Collection_Expecter) Name() *Collection_Name_Call
  • func (_e *Collection_Expecter) ReplaceOne(ctx interface{}, filter interface{}, replacement interface{}, ...) *Collection_ReplaceOne_Call
  • func (_e *Collection_Expecter) SearchIndexes() *Collection_SearchIndexes_Call
  • func (_e *Collection_Expecter) UpdateByID(ctx interface{}, id interface{}, update interface{}, opts ...interface{}) *Collection_UpdateByID_Call
  • func (_e *Collection_Expecter) UpdateMany(ctx interface{}, filter interface{}, update interface{}, opts ...interface{}) *Collection_UpdateMany_Call
  • func (_e *Collection_Expecter) UpdateOne(ctx interface{}, filter interface{}, update interface{}, opts ...interface{}) *Collection_UpdateOne_Call
  • func (_e *Collection_Expecter) Watch(ctx interface{}, pipeline interface{}, opts ...interface{}) *Collection_Watch_Call
• type Collection_FindOneAndDelete_Call
  • func (_c *Collection_FindOneAndDelete_Call) Return(_a0 mongoifc.SingleResult) *Collection_FindOneAndDelete_Call
  • func (_c *Collection_FindOneAndDelete_Call) Run(run func(ctx context.Context, filter interface{}, ...)) *Collection_FindOneAndDelete_Call
  • func (_c *Collection_FindOneAndDelete_Call) RunAndReturn(...) *Collection_FindOneAndDelete_Call
• type Collection_FindOneAndReplace_Call
  • func (_c *Collection_FindOneAndReplace_Call) Return(_a0 mongoifc.SingleResult) *Collection_FindOneAndReplace_Call
  • func (_c *Collection_FindOneAndReplace_Call) Run(...) *Collection_FindOneAndReplace_Call
  • func (_c *Collection_FindOneAndReplace_Call) RunAndReturn(run func(context.Context, interface{}, interface{}, ...) mongoifc.SingleResult) *Collection_FindOneAndReplace_Call
• type Collection_FindOneAndUpdate_Call
  • func (_c *Collection_FindOneAndUpdate_Call) Return(_a0 mongoifc.SingleResult) *Collection_FindOneAndUpdate_Call
  • func (_c *Collection_FindOneAndUpdate_Call) Run(run func(ctx context.Context, filter interface{}, update interface{}, ...)) *Collection_FindOneAndUpdate_Call
  • func (_c *Collection_FindOneAndUpdate_Call) RunAndReturn(...) *Collection_FindOneAndUpdate_Call
• type Collection_FindOne_Call
  • func (_c *Collection_FindOne_Call) Return(_a0 mongoifc.SingleResult) *Collection_FindOne_Call
  • func (_c *Collection_FindOne_Call) Run(...) *Collection_FindOne_Call
  • func (_c *Collection_FindOne_Call) RunAndReturn(...) *Collection_FindOne_Call
• type Collection_Find_Call
  • func (_c *Collection_Find_Call) Return(_a0 mongoifc.Cursor, _a1 error) *Collection_Find_Call
  • func (_c *Collection_Find_Call) Run(...) *Collection_Find_Call
  • func (_c *Collection_Find_Call) RunAndReturn(...) *Collection_Find_Call
• type Collection_Indexes_Call
  • func (_c *Collection_Indexes_Call) Return(_a0 mongoifc.IndexView) *Collection_Indexes_Call
  • func (_c *Collection_Indexes_Call) Run(run func()) *Collection_Indexes_Call
  • func (_c *Collection_Indexes_Call) RunAndReturn(run func() mongoifc.IndexView) *Collection_Indexes_Call
• type Collection_InsertMany_Call
  • func (_c *Collection_InsertMany_Call) Return(_a0 *mongo.InsertManyResult, _a1 error) *Collection_InsertMany_Call
  • func (_c *Collection_InsertMany_Call) Run(run func(ctx context.Context, documents []interface{}, ...)) *Collection_InsertMany_Call
  • func (_c *Collection_InsertMany_Call) RunAndReturn(...) *Collection_InsertMany_Call
• type Collection_InsertOne_Call
  • func (_c *Collection_InsertOne_Call) Return(_a0 *mongo.InsertOneResult, _a1 error) *Collection_InsertOne_Call
  • func (_c *Collection_InsertOne_Call) Run(...) *Collection_InsertOne_Call
  • func (_c *Collection_InsertOne_Call) RunAndReturn(...) *Collection_InsertOne_Call
• type Collection_Name_Call
  • func (_c *Collection_Name_Call) Return(_a0 string) *Collection_Name_Call
  • func (_c *Collection_Name_Call) Run(run func()) *Collection_Name_Call
  • func (_c *Collection_Name_Call) RunAndReturn(run func() string) *Collection_Name_Call
• type Collection_ReplaceOne_Call
  • func (_c *Collection_ReplaceOne_Call) Return(_a0 *mongo.UpdateResult, _a1 error) *Collection_ReplaceOne_Call
  • func (_c *Collection_ReplaceOne_Call) Run(...) *Collection_ReplaceOne_Call
  • func (_c *Collection_ReplaceOne_Call) RunAndReturn(...) *Collection_ReplaceOne_Call
• type Collection_SearchIndexes_Call
  • func (_c *Collection_SearchIndexes_Call) Return(_a0 mongoifc.SearchIndexView) *Collection_SearchIndexes_Call
  • func (_c *Collection_SearchIndexes_Call) Run(run func()) *Collection_SearchIndexes_Call
  • func (_c *Collection_SearchIndexes_Call) RunAndReturn(run func() mongoifc.SearchIndexView) *Collection_SearchIndexes_Call
• type Collection_UpdateByID_Call
  • func (_c *Collection_UpdateByID_Call) Return(_a0 *mongo.UpdateResult, _a1 error) *Collection_UpdateByID_Call
  • func (_c *Collection_UpdateByID_Call) Run(run func(ctx context.Context, id interface{}, update interface{}, ...)) *Collection_UpdateByID_Call
  • func (_c *Collection_UpdateByID_Call) RunAndReturn(...) *Collection_UpdateByID_Call
• type Collection_UpdateMany_Call
  • func (_c *Collection_UpdateMany_Call) Return(_a0 *mongo.UpdateResult, _a1 error) *Collection_UpdateMany_Call
  • func (_c *Collection_UpdateMany_Call) Run(run func(ctx context.Context, filter interface{}, update interface{}, ...)) *Collection_UpdateMany_Call
  • func (_c *Collection_UpdateMany_Call) RunAndReturn(...) *Collection_UpdateMany_Call
• type Collection_UpdateOne_Call
  • func (_c *Collection_UpdateOne_Call) Return(_a0 *mongo.UpdateResult, _a1 error) *Collection_UpdateOne_Call
  • func (_c *Collection_UpdateOne_Call) Run(run func(ctx context.Context, filter interface{}, update interface{}, ...)) *Collection_UpdateOne_Call
  • func (_c *Collection_UpdateOne_Call) RunAndReturn(...) *Collection_UpdateOne_Call
• type Collection_Watch_Call
  • func (_c *Collection_Watch_Call) Return(_a0 mongoifc.ChangeStream, _a1 error) *Collection_Watch_Call
  • func (_c *Collection_Watch_Call) Run(run func(ctx context.Context, pipeline interface{}, ...)) *Collection_Watch_Call
  • func (_c *Collection_Watch_Call) RunAndReturn(...) *Collection_Watch_Call
• type Cursor
  • func NewCursor(t interface{ ... }) *Cursor
  • func (_m *Cursor) All(ctx context.Context, results interface{}) error
  • func (_m *Cursor) Close(ctx context.Context) error
  • func (_m *Cursor) Current() bson.Raw
  • func (_m *Cursor) Decode(val interface{}) error
  • func (_m *Cursor) EXPECT() *Cursor_Expecter
  • func (_m *Cursor) Err() error
  • func (_m *Cursor) ID() int64
  • func (_m *Cursor) Next(ctx context.Context) bool
  • func (_m *Cursor) RemainingBatchLength() int
  • func (_m *Cursor) SetBatchSize(batchSize int32)
  • func (_m *Cursor) SetComment(comment interface{})
  • func (_m *Cursor) SetMaxTime(dur time.Duration)
  • func (_m *Cursor) TryNext(ctx context.Context) bool
• type Cursor_All_Call
  • func (_c *Cursor_All_Call) Return(_a0 error) *Cursor_All_Call
  • func (_c *Cursor_All_Call) Run(run func(ctx context.Context, results interface{})) *Cursor_All_Call
  • func (_c *Cursor_All_Call) RunAndReturn(run func(context.Context, interface{}) error) *Cursor_All_Call
• type Cursor_Close_Call
  • func (_c *Cursor_Close_Call) Return(_a0 error) *Cursor_Close_Call
  • func (_c *Cursor_Close_Call) Run(run func(ctx context.Context)) *Cursor_Close_Call
  • func (_c *Cursor_Close_Call) RunAndReturn(run func(context.Context) error) *Cursor_Close_Call
• type Cursor_Current_Call
  • func (_c *Cursor_Current_Call) Return(_a0 bson.Raw) *Cursor_Current_Call
  • func (_c *Cursor_Current_Call) Run(run func()) *Cursor_Current_Call
  • func (_c *Cursor_Current_Call) RunAndReturn(run func() bson.Raw) *Cursor_Current_Call
• type Cursor_Decode_Call
  • func (_c *Cursor_Decode_Call) Return(_a0 error) *Cursor_Decode_Call
  • func (_c *Cursor_Decode_Call) Run(run func(val interface{})) *Cursor_Decode_Call
  • func (_c *Cursor_Decode_Call) RunAndReturn(run func(interface{}) error) *Cursor_Decode_Call
• type Cursor_Err_Call
  • func (_c *Cursor_Err_Call) Return(_a0 error) *Cursor_Err_Call
  • func (_c *Cursor_Err_Call) Run(run func()) *Cursor_Err_Call
  • func (_c *Cursor_Err_Call) RunAndReturn(run func() error) *Cursor_Err_Call
• type Cursor_Expecter
  • func (_e *Cursor_Expecter) All(ctx interface{}, results interface{}) *Cursor_All_Call
  • func (_e *Cursor_Expecter) Close(ctx interface{}) *Cursor_Close_Call
  • func (_e *Cursor_Expecter) Current() *Cursor_Current_Call
  • func (_e *Cursor_Expecter) Decode(val interface{}) *Cursor_Decode_Call
  • func (_e *Cursor_Expecter) Err() *Cursor_Err_Call
  • func (_e *Cursor_Expecter) ID() *Cursor_ID_Call
  • func (_e *Cursor_Expecter) Next(ctx interface{}) *Cursor_Next_Call
  • func (_e *Cursor_Expecter) RemainingBatchLength() *Cursor_RemainingBatchLength_Call
  • func (_e *Cursor_Expecter) SetBatchSize(batchSize interface{}) *Cursor_SetBatchSize_Call
  • func (_e *Cursor_Expecter) SetComment(comment interface{}) *Cursor_SetComment_Call
  • func (_e *Cursor_Expecter) SetMaxTime(dur interface{}) *Cursor_SetMaxTime_Call
  • func (_e *Cursor_Expecter) TryNext(ctx interface{}) *Cursor_TryNext_Call
• type Cursor_ID_Call
  • func (_c *Cursor_ID_Call) Return(_a0 int64) *Cursor_ID_Call
  • func (_c *Cursor_ID_Call) Run(run func()) *Cursor_ID_Call
  • func (_c *Cursor_ID_Call) RunAndReturn(run func() int64) *Cursor_ID_Call
• type Cursor_Next_Call
  • func (_c *Cursor_Next_Call) Return(_a0 bool) *Cursor_Next_Call
  • func (_c *Cursor_Next_Call) Run(run func(ctx context.Context)) *Cursor_Next_Call
  • func (_c *Cursor_Next_Call) RunAndReturn(run func(context.Context) bool) *Cursor_Next_Call
• type Cursor_RemainingBatchLength_Call
  • func (_c *Cursor_RemainingBatchLength_Call) Return(_a0 int) *Cursor_RemainingBatchLength_Call
  • func (_c *Cursor_RemainingBatchLength_Call) Run(run func()) *Cursor_RemainingBatchLength_Call
  • func (_c *Cursor_RemainingBatchLength_Call) RunAndReturn(run func() int) *Cursor_RemainingBatchLength_Call
• type Cursor_SetBatchSize_Call
  • func (_c *Cursor_SetBatchSize_Call) Return() *Cursor_SetBatchSize_Call
  • func (_c *Cursor_SetBatchSize_Call) Run(run func(batchSize int32)) *Cursor_SetBatchSize_Call
  • func (_c *Cursor_SetBatchSize_Call) RunAndReturn(run func(int32)) *Cursor_SetBatchSize_Call
• type Cursor_SetComment_Call
  • func (_c *Cursor_SetComment_Call) Return() *Cursor_SetComment_Call
  • func (_c *Cursor_SetComment_Call) Run(run func(comment interface{})) *Cursor_SetComment_Call
  • func (_c *Cursor_SetComment_Call) RunAndReturn(run func(interface{})) *Cursor_SetComment_Call
• type Cursor_SetMaxTime_Call
  • func (_c *Cursor_SetMaxTime_Call) Return() *Cursor_SetMaxTime_Call
  • func (_c *Cursor_SetMaxTime_Call) Run(run func(dur time.Duration)) *Cursor_SetMaxTime_Call
  • func (_c *Cursor_SetMaxTime_Call) RunAndReturn(run func(time.Duration)) *Cursor_SetMaxTime_Call
• type Cursor_TryNext_Call
  • func (_c *Cursor_TryNext_Call) Return(_a0 bool) *Cursor_TryNext_Call
  • func (_c *Cursor_TryNext_Call) Run(run func(ctx context.Context)) *Cursor_TryNext_Call
  • func (_c *Cursor_TryNext_Call) RunAndReturn(run func(context.Context) bool) *Cursor_TryNext_Call
• type Database
  • func NewDatabase(t interface{ ... }) *Database
  • func (_m *Database) Aggregate(ctx context.Context, pipeline interface{}, opts ...*options.AggregateOptions) (mongoifc.Cursor, error)
  • func (_m *Database) Client() mongoifc.Client
  • func (_m *Database) Collection(name string, opts ...*options.CollectionOptions) mongoifc.Collection
  • func (_m *Database) CreateCollection(ctx context.Context, name string, opts ...*options.CreateCollectionOptions) error
  • func (_m *Database) CreateView(ctx context.Context, viewName string, viewOn string, pipeline interface{}, ...) error
  • func (_m *Database) Drop(ctx context.Context) error
  • func (_m *Database) EXPECT() *Database_Expecter
  • func (_m *Database) ListCollectionNames(ctx context.Context, filter interface{}, ...) ([]string, error)
  • func (_m *Database) ListCollectionSpecifications(ctx context.Context, filter interface{}, ...) ([]*mongo.CollectionSpecification, error)
  • func (_m *Database) ListCollections(ctx context.Context, filter interface{}, ...) (mongoifc.Cursor, error)
  • func (_m *Database) Name() string
  • func (_m *Database) ReadConcern() *readconcern.ReadConcern
  • func (_m *Database) ReadPreference() *readpref.ReadPref
  • func (_m *Database) RunCommand(ctx context.Context, runCommand interface{}, opts ...*options.RunCmdOptions) mongoifc.SingleResult
  • func (_m *Database) RunCommandCursor(ctx context.Context, runCommand interface{}, opts ...*options.RunCmdOptions) (mongoifc.Cursor, error)
  • func (_m *Database) Watch(ctx context.Context, pipeline interface{}, ...) (mongoifc.ChangeStream, error)
  • func (_m *Database) WriteConcern() *writeconcern.WriteConcern
• type Database_Aggregate_Call
  • func (_c *Database_Aggregate_Call) Return(_a0 mongoifc.Cursor, _a1 error) *Database_Aggregate_Call
  • func (_c *Database_Aggregate_Call) Run(...) *Database_Aggregate_Call
  • func (_c *Database_Aggregate_Call) RunAndReturn(...) *Database_Aggregate_Call
• type Database_Client_Call
  • func (_c *Database_Client_Call) Return(_a0 mongoifc.Client) *Database_Client_Call
  • func (_c *Database_Client_Call) Run(run func()) *Database_Client_Call
  • func (_c *Database_Client_Call) RunAndReturn(run func() mongoifc.Client) *Database_Client_Call
• type Database_Collection_Call
  • func (_c *Database_Collection_Call) Return(_a0 mongoifc.Collection) *Database_Collection_Call
  • func (_c *Database_Collection_Call) Run(run func(name string, opts ...*options.CollectionOptions)) *Database_Collection_Call
  • func (_c *Database_Collection_Call) RunAndReturn(run func(string, ...*options.CollectionOptions) mongoifc.Collection) *Database_Collection_Call
• type Database_CreateCollection_Call
  • func (_c *Database_CreateCollection_Call) Return(_a0 error) *Database_CreateCollection_Call
  • func (_c *Database_CreateCollection_Call) Run(...) *Database_CreateCollection_Call
  • func (_c *Database_CreateCollection_Call) RunAndReturn(run func(context.Context, string, ...*options.CreateCollectionOptions) error) *Database_CreateCollection_Call
• type Database_CreateView_Call
  • func (_c *Database_CreateView_Call) Return(_a0 error) *Database_CreateView_Call
  • func (_c *Database_CreateView_Call) Run(...) *Database_CreateView_Call
  • func (_c *Database_CreateView_Call) RunAndReturn(...) *Database_CreateView_Call
• type Database_Drop_Call
  • func (_c *Database_Drop_Call) Return(_a0 error) *Database_Drop_Call
  • func (_c *Database_Drop_Call) Run(run func(ctx context.Context)) *Database_Drop_Call
  • func (_c *Database_Drop_Call) RunAndReturn(run func(context.Context) error) *Database_Drop_Call
• type Database_Expecter
  • func (_e *Database_Expecter) Aggregate(ctx interface{}, pipeline interface{}, opts ...interface{}) *Database_Aggregate_Call
  • func (_e *Database_Expecter) Client() *Database_Client_Call
  • func (_e *Database_Expecter) Collection(name interface{}, opts ...interface{}) *Database_Collection_Call
  • func (_e *Database_Expecter) CreateCollection(ctx interface{}, name interface{}, opts ...interface{}) *Database_CreateCollection_Call
  • func (_e *Database_Expecter) CreateView(ctx interface{}, viewName interface{}, viewOn interface{}, ...) *Database_CreateView_Call
  • func (_e *Database_Expecter) Drop(ctx interface{}) *Database_Drop_Call
  • func (_e *Database_Expecter) ListCollectionNames(ctx interface{}, filter interface{}, opts ...interface{}) *Database_ListCollectionNames_Call
  • func (_e *Database_Expecter) ListCollectionSpecifications(ctx interface{}, filter interface{}, opts ...interface{}) *Database_ListCollectionSpecifications_Call
  • func (_e *Database_Expecter) ListCollections(ctx interface{}, filter interface{}, opts ...interface{}) *Database_ListCollections_Call
  • func (_e *Database_Expecter) Name() *Database_Name_Call
  • func (_e *Database_Expecter) ReadConcern() *Database_ReadConcern_Call
  • func (_e *Database_Expecter) ReadPreference() *Database_ReadPreference_Call
  • func (_e *Database_Expecter) RunCommand(ctx interface{}, runCommand interface{}, opts ...interface{}) *Database_RunCommand_Call
  • func (_e *Database_Expecter) RunCommandCursor(ctx interface{}, runCommand interface{}, opts ...interface{}) *Database_RunCommandCursor_Call
  • func (_e *Database_Expecter) Watch(ctx interface{}, pipeline interface{}, opts ...interface{}) *Database_Watch_Call
  • func (_e *Database_Expecter) WriteConcern() *Database_WriteConcern_Call
• type Database_ListCollectionNames_Call
  • func (_c *Database_ListCollectionNames_Call) Return(_a0 []string, _a1 error) *Database_ListCollectionNames_Call
  • func (_c *Database_ListCollectionNames_Call) Run(run func(ctx context.Context, filter interface{}, ...)) *Database_ListCollectionNames_Call
  • func (_c *Database_ListCollectionNames_Call) RunAndReturn(...) *Database_ListCollectionNames_Call
• type Database_ListCollectionSpecifications_Call
  • func (_c *Database_ListCollectionSpecifications_Call) Return(_a0 []*mongo.CollectionSpecification, _a1 error) *Database_ListCollectionSpecifications_Call
  • func (_c *Database_ListCollectionSpecifications_Call) Run(run func(ctx context.Context, filter interface{}, ...)) *Database_ListCollectionSpecifications_Call
  • func (_c *Database_ListCollectionSpecifications_Call) RunAndReturn(...) *Database_ListCollectionSpecifications_Call
• type Database_ListCollections_Call
  • func (_c *Database_ListCollections_Call) Return(_a0 mongoifc.Cursor, _a1 error) *Database_ListCollections_Call
  • func (_c *Database_ListCollections_Call) Run(run func(ctx context.Context, filter interface{}, ...)) *Database_ListCollections_Call
  • func (_c *Database_ListCollections_Call) RunAndReturn(...) *Database_ListCollections_Call
• type Database_Name_Call
  • func (_c *Database_Name_Call) Return(_a0 string) *Database_Name_Call
  • func (_c *Database_Name_Call) Run(run func()) *Database_Name_Call
  • func (_c *Database_Name_Call) RunAndReturn(run func() string) *Database_Name_Call
• type Database_ReadConcern_Call
  • func (_c *Database_ReadConcern_Call) Return(_a0 *readconcern.ReadConcern) *Database_ReadConcern_Call
  • func (_c *Database_ReadConcern_Call) Run(run func()) *Database_ReadConcern_Call
  • func (_c *Database_ReadConcern_Call) RunAndReturn(run func() *readconcern.ReadConcern) *Database_ReadConcern_Call
• type Database_ReadPreference_Call
  • func (_c *Database_ReadPreference_Call) Return(_a0 *readpref.ReadPref) *Database_ReadPreference_Call
  • func (_c *Database_ReadPreference_Call) Run(run func()) *Database_ReadPreference_Call
  • func (_c *Database_ReadPreference_Call) RunAndReturn(run func() *readpref.ReadPref) *Database_ReadPreference_Call
• type Database_RunCommandCursor_Call
  • func (_c *Database_RunCommandCursor_Call) Return(_a0 mongoifc.Cursor, _a1 error) *Database_RunCommandCursor_Call
  • func (_c *Database_RunCommandCursor_Call) Run(...) *Database_RunCommandCursor_Call
  • func (_c *Database_RunCommandCursor_Call) RunAndReturn(...) *Database_RunCommandCursor_Call
• type Database_RunCommand_Call
  • func (_c *Database_RunCommand_Call) Return(_a0 mongoifc.SingleResult) *Database_RunCommand_Call
  • func (_c *Database_RunCommand_Call) Run(...) *Database_RunCommand_Call
  • func (_c *Database_RunCommand_Call) RunAndReturn(...) *Database_RunCommand_Call
• type Database_Watch_Call
  • func (_c *Database_Watch_Call) Return(_a0 mongoifc.ChangeStream, _a1 error) *Database_Watch_Call
  • func (_c *Database_Watch_Call) Run(run func(ctx context.Context, pipeline interface{}, ...)) *Database_Watch_Call
  • func (_c *Database_Watch_Call) RunAndReturn(...) *Database_Watch_Call
• type Database_WriteConcern_Call
  • func (_c *Database_WriteConcern_Call) Return(_a0 *writeconcern.WriteConcern) *Database_WriteConcern_Call
  • func (_c *Database_WriteConcern_Call) Run(run func()) *Database_WriteConcern_Call
  • func (_c *Database_WriteConcern_Call) RunAndReturn(run func() *writeconcern.WriteConcern) *Database_WriteConcern_Call
• type IndexView
  • func NewIndexView(t interface{ ... }) *IndexView
  • func (_m *IndexView) CreateMany(ctx context.Context, models []mongo.IndexModel, ...) ([]string, error)
  • func (_m *IndexView) CreateOne(ctx context.Context, model mongo.IndexModel, ...) (string, error)
  • func (_m *IndexView) DropAll(ctx context.Context, opts ...*options.DropIndexesOptions) (bson.Raw, error)
  • func (_m *IndexView) DropOne(ctx context.Context, name string, opts ...*options.DropIndexesOptions) (bson.Raw, error)
  • func (_m *IndexView) DropOneWithKey(ctx context.Context, keySpecDocument interface{}, ...) (bson.Raw, error)
  • func (_m *IndexView) EXPECT() *IndexView_Expecter
  • func (_m *IndexView) List(ctx context.Context, opts ...*options.ListIndexesOptions) (mongoifc.Cursor, error)
  • func (_m *IndexView) ListSpecifications(ctx context.Context, opts ...*options.ListIndexesOptions) ([]*mongo.IndexSpecification, error)
• type IndexView_CreateMany_Call
  • func (_c *IndexView_CreateMany_Call) Return(_a0 []string, _a1 error) *IndexView_CreateMany_Call
  • func (_c *IndexView_CreateMany_Call) Run(run func(ctx context.Context, models []mongo.IndexModel, ...)) *IndexView_CreateMany_Call
  • func (_c *IndexView_CreateMany_Call) RunAndReturn(...) *IndexView_CreateMany_Call
• type IndexView_CreateOne_Call
  • func (_c *IndexView_CreateOne_Call) Return(_a0 string, _a1 error) *IndexView_CreateOne_Call
  • func (_c *IndexView_CreateOne_Call) Run(run func(ctx context.Context, model mongo.IndexModel, ...)) *IndexView_CreateOne_Call
  • func (_c *IndexView_CreateOne_Call) RunAndReturn(...) *IndexView_CreateOne_Call
• type IndexView_DropAll_Call
  • func (_c *IndexView_DropAll_Call) Return(_a0 bson.Raw, _a1 error) *IndexView_DropAll_Call
  • func (_c *IndexView_DropAll_Call) Run(run func(ctx context.Context, opts ...*options.DropIndexesOptions)) *IndexView_DropAll_Call
  • func (_c *IndexView_DropAll_Call) RunAndReturn(run func(context.Context, ...*options.DropIndexesOptions) (bson.Raw, error)) *IndexView_DropAll_Call
• type IndexView_DropOneWithKey_Call
  • func (_c *IndexView_DropOneWithKey_Call) Return(_a0 bson.Raw, _a1 error) *IndexView_DropOneWithKey_Call
  • func (_c *IndexView_DropOneWithKey_Call) Run(run func(ctx context.Context, keySpecDocument interface{}, ...)) *IndexView_DropOneWithKey_Call
  • func (_c *IndexView_DropOneWithKey_Call) RunAndReturn(...) *IndexView_DropOneWithKey_Call
• type IndexView_DropOne_Call
  • func (_c *IndexView_DropOne_Call) Return(_a0 bson.Raw, _a1 error) *IndexView_DropOne_Call
  • func (_c *IndexView_DropOne_Call) Run(...) *IndexView_DropOne_Call
  • func (_c *IndexView_DropOne_Call) RunAndReturn(...) *IndexView_DropOne_Call
• type IndexView_Expecter
  • func (_e *IndexView_Expecter) CreateMany(ctx interface{}, models interface{}, opts ...interface{}) *IndexView_CreateMany_Call
  • func (_e *IndexView_Expecter) CreateOne(ctx interface{}, model interface{}, opts ...interface{}) *IndexView_CreateOne_Call
  • func (_e *IndexView_Expecter) DropAll(ctx interface{}, opts ...interface{}) *IndexView_DropAll_Call
  • func (_e *IndexView_Expecter) DropOne(ctx interface{}, name interface{}, opts ...interface{}) *IndexView_DropOne_Call
  • func (_e *IndexView_Expecter) DropOneWithKey(ctx interface{}, keySpecDocument interface{}, opts ...interface{}) *IndexView_DropOneWithKey_Call
  • func (_e *IndexView_Expecter) List(ctx interface{}, opts ...interface{}) *IndexView_List_Call
  • func (_e *IndexView_Expecter) ListSpecifications(ctx interface{}, opts ...interface{}) *IndexView_ListSpecifications_Call
• type IndexView_ListSpecifications_Call
  • func (_c *IndexView_ListSpecifications_Call) Return(_a0 []*mongo.IndexSpecification, _a1 error) *IndexView_ListSpecifications_Call
  • func (_c *IndexView_ListSpecifications_Call) Run(run func(ctx context.Context, opts ...*options.ListIndexesOptions)) *IndexView_ListSpecifications_Call
  • func (_c *IndexView_ListSpecifications_Call) RunAndReturn(...) *IndexView_ListSpecifications_Call
• type IndexView_List_Call
  • func (_c *IndexView_List_Call) Return(_a0 mongoifc.Cursor, _a1 error) *IndexView_List_Call
  • func (_c *IndexView_List_Call) Run(run func(ctx context.Context, opts ...*options.ListIndexesOptions)) *IndexView_List_Call
  • func (_c *IndexView_List_Call) RunAndReturn(...) *IndexView_List_Call
• type SearchIndexView
  • func NewSearchIndexView(t interface{ ... }) *SearchIndexView
  • func (_m *SearchIndexView) CreateMany(ctx context.Context, models []mongo.SearchIndexModel, ...) ([]string, error)
  • func (_m *SearchIndexView) CreateOne(ctx context.Context, model mongo.SearchIndexModel, ...) (string, error)
  • func (_m *SearchIndexView) DropOne(ctx context.Context, name string, opts ...*options.DropSearchIndexOptions) error
  • func (_m *SearchIndexView) EXPECT() *SearchIndexView_Expecter
  • func (_m *SearchIndexView) List(ctx context.Context, searchIdxOpts *options.SearchIndexesOptions, ...) (mongoifc.Cursor, error)
  • func (_m *SearchIndexView) UpdateOne(ctx context.Context, name string, definition interface{}, ...) error
• type SearchIndexView_CreateMany_Call
  • func (_c *SearchIndexView_CreateMany_Call) Return(_a0 []string, _a1 error) *SearchIndexView_CreateMany_Call
  • func (_c *SearchIndexView_CreateMany_Call) Run(run func(ctx context.Context, models []mongo.SearchIndexModel, ...)) *SearchIndexView_CreateMany_Call
  • func (_c *SearchIndexView_CreateMany_Call) RunAndReturn(run func(context.Context, []mongo.SearchIndexModel, ...) ([]string, error)) *SearchIndexView_CreateMany_Call
• type SearchIndexView_CreateOne_Call
  • func (_c *SearchIndexView_CreateOne_Call) Return(_a0 string, _a1 error) *SearchIndexView_CreateOne_Call
  • func (_c *SearchIndexView_CreateOne_Call) Run(run func(ctx context.Context, model mongo.SearchIndexModel, ...)) *SearchIndexView_CreateOne_Call
  • func (_c *SearchIndexView_CreateOne_Call) RunAndReturn(run func(context.Context, mongo.SearchIndexModel, ...) (string, error)) *SearchIndexView_CreateOne_Call
• type SearchIndexView_DropOne_Call
  • func (_c *SearchIndexView_DropOne_Call) Return(_a0 error) *SearchIndexView_DropOne_Call
  • func (_c *SearchIndexView_DropOne_Call) Run(...) *SearchIndexView_DropOne_Call
  • func (_c *SearchIndexView_DropOne_Call) RunAndReturn(run func(context.Context, string, ...*options.DropSearchIndexOptions) error) *SearchIndexView_DropOne_Call
• type SearchIndexView_Expecter
  • func (_e *SearchIndexView_Expecter) CreateMany(ctx interface{}, models interface{}, opts ...interface{}) *SearchIndexView_CreateMany_Call
  • func (_e *SearchIndexView_Expecter) CreateOne(ctx interface{}, model interface{}, opts ...interface{}) *SearchIndexView_CreateOne_Call
  • func (_e *SearchIndexView_Expecter) DropOne(ctx interface{}, name interface{}, opts ...interface{}) *SearchIndexView_DropOne_Call
  • func (_e *SearchIndexView_Expecter) List(ctx interface{}, searchIdxOpts interface{}, opts ...interface{}) *SearchIndexView_List_Call
  • func (_e *SearchIndexView_Expecter) UpdateOne(ctx interface{}, name interface{}, definition interface{}, opts ...interface{}) *SearchIndexView_UpdateOne_Call
• type SearchIndexView_List_Call
  • func (_c *SearchIndexView_List_Call) Return(_a0 mongoifc.Cursor, _a1 error) *SearchIndexView_List_Call
  • func (_c *SearchIndexView_List_Call) Run(...) *SearchIndexView_List_Call
  • func (_c *SearchIndexView_List_Call) RunAndReturn(...) *SearchIndexView_List_Call
• type SearchIndexView_UpdateOne_Call
  • func (_c *SearchIndexView_UpdateOne_Call) Return(_a0 error) *SearchIndexView_UpdateOne_Call
  • func (_c *SearchIndexView_UpdateOne_Call) Run(run func(ctx context.Context, name string, definition interface{}, ...)) *SearchIndexView_UpdateOne_Call
  • func (_c *SearchIndexView_UpdateOne_Call) RunAndReturn(...) *SearchIndexView_UpdateOne_Call
• type Session
  • func NewSession(t interface{ ... }) *Session
  • func (_m *Session) AbortTransaction(ctx context.Context) error
  • func (_m *Session) AdvanceClusterTime(_a0 bson.Raw) error
  • func (_m *Session) AdvanceOperationTime(_a0 *primitive.Timestamp) error
  • func (_m *Session) Client() mongoifc.Client
  • func (_m *Session) ClusterTime() bson.Raw
  • func (_m *Session) CommitTransaction(ctx context.Context) error
  • func (_m *Session) EXPECT() *Session_Expecter
  • func (_m *Session) EndSession(ctx context.Context)
  • func (_m *Session) ID() bson.Raw
  • func (_m *Session) OperationTime() *primitive.Timestamp
  • func (_m *Session) StartTransaction(opts ...*options.TransactionOptions) error
  • func (_m *Session) WithTransaction(ctx context.Context, fn func(mongoifc.SessionContext) (interface{}, error), ...) (interface{}, error)
• type SessionContext
  • func NewSessionContext(t interface{ ... }) *SessionContext
  • func (_m *SessionContext) AbortTransaction(ctx context.Context) error
  • func (_m *SessionContext) AdvanceClusterTime(_a0 bson.Raw) error
  • func (_m *SessionContext) AdvanceOperationTime(_a0 *primitive.Timestamp) error
  • func (_m *SessionContext) Client() mongoifc.Client
  • func (_m *SessionContext) ClusterTime() bson.Raw
  • func (_m *SessionContext) CommitTransaction(ctx context.Context) error
  • func (_m *SessionContext) Deadline() (time.Time, bool)
  • func (_m *SessionContext) Done() <-chan struct{}
  • func (_m *SessionContext) EXPECT() *SessionContext_Expecter
  • func (_m *SessionContext) EndSession(ctx context.Context)
  • func (_m *SessionContext) Err() error
  • func (_m *SessionContext) ID() bson.Raw
  • func (_m *SessionContext) OperationTime() *primitive.Timestamp
  • func (_m *SessionContext) StartTransaction(opts ...*options.TransactionOptions) error
  • func (_m *SessionContext) Value(key interface{}) interface{}
  • func (_m *SessionContext) WithTransaction(ctx context.Context, fn func(mongoifc.SessionContext) (interface{}, error), ...) (interface{}, error)
• type SessionContext_AbortTransaction_Call
  • func (_c *SessionContext_AbortTransaction_Call) Return(_a0 error) *SessionContext_AbortTransaction_Call
  • func (_c *SessionContext_AbortTransaction_Call) Run(run func(ctx context.Context)) *SessionContext_AbortTransaction_Call
  • func (_c *SessionContext_AbortTransaction_Call) RunAndReturn(run func(context.Context) error) *SessionContext_AbortTransaction_Call
• type SessionContext_AdvanceClusterTime_Call
  • func (_c *SessionContext_AdvanceClusterTime_Call) Return(_a0 error) *SessionContext_AdvanceClusterTime_Call
  • func (_c *SessionContext_AdvanceClusterTime_Call) Run(run func(_a0 bson.Raw)) *SessionContext_AdvanceClusterTime_Call
  • func (_c *SessionContext_AdvanceClusterTime_Call) RunAndReturn(run func(bson.Raw) error) *SessionContext_AdvanceClusterTime_Call
• type SessionContext_AdvanceOperationTime_Call
  • func (_c *SessionContext_AdvanceOperationTime_Call) Return(_a0 error) *SessionContext_AdvanceOperationTime_Call
  • func (_c *SessionContext_AdvanceOperationTime_Call) Run(run func(_a0 *primitive.Timestamp)) *SessionContext_AdvanceOperationTime_Call
  • func (_c *SessionContext_AdvanceOperationTime_Call) RunAndReturn(run func(*primitive.Timestamp) error) *SessionContext_AdvanceOperationTime_Call
• type SessionContext_Client_Call
  • func (_c *SessionContext_Client_Call) Return(_a0 mongoifc.Client) *SessionContext_Client_Call
  • func (_c *SessionContext_Client_Call) Run(run func()) *SessionContext_Client_Call
  • func (_c *SessionContext_Client_Call) RunAndReturn(run func() mongoifc.Client) *SessionContext_Client_Call
• type SessionContext_ClusterTime_Call
  • func (_c *SessionContext_ClusterTime_Call) Return(_a0 bson.Raw) *SessionContext_ClusterTime_Call
  • func (_c *SessionContext_ClusterTime_Call) Run(run func()) *SessionContext_ClusterTime_Call
  • func (_c *SessionContext_ClusterTime_Call) RunAndReturn(run func() bson.Raw) *SessionContext_ClusterTime_Call
• type SessionContext_CommitTransaction_Call
  • func (_c *SessionContext_CommitTransaction_Call) Return(_a0 error) *SessionContext_CommitTransaction_Call
  • func (_c *SessionContext_CommitTransaction_Call) Run(run func(ctx context.Context)) *SessionContext_CommitTransaction_Call
  • func (_c *SessionContext_CommitTransaction_Call) RunAndReturn(run func(context.Context) error) *SessionContext_CommitTransaction_Call
• type SessionContext_Deadline_Call
  • func (_c *SessionContext_Deadline_Call) Return(deadline time.Time, ok bool) *SessionContext_Deadline_Call
  • func (_c *SessionContext_Deadline_Call) Run(run func()) *SessionContext_Deadline_Call
  • func (_c *SessionContext_Deadline_Call) RunAndReturn(run func() (time.Time, bool)) *SessionContext_Deadline_Call
• type SessionContext_Done_Call
  • func (_c *SessionContext_Done_Call) Return(_a0 <-chan struct{}) *SessionContext_Done_Call
  • func (_c *SessionContext_Done_Call) Run(run func()) *SessionContext_Done_Call
  • func (_c *SessionContext_Done_Call) RunAndReturn(run func() <-chan struct{}) *SessionContext_Done_Call
• type SessionContext_EndSession_Call
  • func (_c *SessionContext_EndSession_Call) Return() *SessionContext_EndSession_Call
  • func (_c *SessionContext_EndSession_Call) Run(run func(ctx context.Context)) *SessionContext_EndSession_Call
  • func (_c *SessionContext_EndSession_Call) RunAndReturn(run func(context.Context)) *SessionContext_EndSession_Call
• type SessionContext_Err_Call
  • func (_c *SessionContext_Err_Call) Return(_a0 error) *SessionContext_Err_Call
  • func (_c *SessionContext_Err_Call) Run(run func()) *SessionContext_Err_Call
  • func (_c *SessionContext_Err_Call) RunAndReturn(run func() error) *SessionContext_Err_Call
• type SessionContext_Expecter
  • func (_e *SessionContext_Expecter) AbortTransaction(ctx interface{}) *SessionContext_AbortTransaction_Call
  • func (_e *SessionContext_Expecter) AdvanceClusterTime(_a0 interface{}) *SessionContext_AdvanceClusterTime_Call
  • func (_e *SessionContext_Expecter) AdvanceOperationTime(_a0 interface{}) *SessionContext_AdvanceOperationTime_Call
  • func (_e *SessionContext_Expecter) Client() *SessionContext_Client_Call
  • func (_e *SessionContext_Expecter) ClusterTime() *SessionContext_ClusterTime_Call
  • func (_e *SessionContext_Expecter) CommitTransaction(ctx interface{}) *SessionContext_CommitTransaction_Call
  • func (_e *SessionContext_Expecter) Deadline() *SessionContext_Deadline_Call
  • func (_e *SessionContext_Expecter) Done() *SessionContext_Done_Call
  • func (_e *SessionContext_Expecter) EndSession(ctx interface{}) *SessionContext_EndSession_Call
  • func (_e *SessionContext_Expecter) Err() *SessionContext_Err_Call
  • func (_e *SessionContext_Expecter) ID() *SessionContext_ID_Call
  • func (_e *SessionContext_Expecter) OperationTime() *SessionContext_OperationTime_Call
  • func (_e *SessionContext_Expecter) StartTransaction(opts ...interface{}) *SessionContext_StartTransaction_Call
  • func (_e *SessionContext_Expecter) Value(key interface{}) *SessionContext_Value_Call
  • func (_e *SessionContext_Expecter) WithTransaction(ctx interface{}, fn interface{}, opts ...interface{}) *SessionContext_WithTransaction_Call
• type SessionContext_ID_Call
  • func (_c *SessionContext_ID_Call) Return(_a0 bson.Raw) *SessionContext_ID_Call
  • func (_c *SessionContext_ID_Call) Run(run func()) *SessionContext_ID_Call
  • func (_c *SessionContext_ID_Call) RunAndReturn(run func() bson.Raw) *SessionContext_ID_Call
• type SessionContext_OperationTime_Call
  • func (_c *SessionContext_OperationTime_Call) Return(_a0 *primitive.Timestamp) *SessionContext_OperationTime_Call
  • func (_c *SessionContext_OperationTime_Call) Run(run func()) *SessionContext_OperationTime_Call
  • func (_c *SessionContext_OperationTime_Call) RunAndReturn(run func() *primitive.Timestamp) *SessionContext_OperationTime_Call
• type SessionContext_StartTransaction_Call
  • func (_c *SessionContext_StartTransaction_Call) Return(_a0 error) *SessionContext_StartTransaction_Call
  • func (_c *SessionContext_StartTransaction_Call) Run(run func(opts ...*options.TransactionOptions)) *SessionContext_StartTransaction_Call
  • func (_c *SessionContext_StartTransaction_Call) RunAndReturn(run func(...*options.TransactionOptions) error) *SessionContext_StartTransaction_Call
• type SessionContext_Value_Call
  • func (_c *SessionContext_Value_Call) Return(_a0 interface{}) *SessionContext_Value_Call
  • func (_c *SessionContext_Value_Call) Run(run func(key interface{})) *SessionContext_Value_Call
  • func (_c *SessionContext_Value_Call) RunAndReturn(run func(interface{}) interface{}) *SessionContext_Value_Call
• type SessionContext_WithTransaction_Call
  • func (_c *SessionContext_WithTransaction_Call) Return(_a0 interface{}, _a1 error) *SessionContext_WithTransaction_Call
  • func (_c *SessionContext_WithTransaction_Call) Run(...) *SessionContext_WithTransaction_Call
  • func (_c *SessionContext_WithTransaction_Call) RunAndReturn(...) *SessionContext_WithTransaction_Call
• type Session_AbortTransaction_Call
  • func (_c *Session_AbortTransaction_Call) Return(_a0 error) *Session_AbortTransaction_Call
  • func (_c *Session_AbortTransaction_Call) Run(run func(ctx context.Context)) *Session_AbortTransaction_Call
  • func (_c *Session_AbortTransaction_Call) RunAndReturn(run func(context.Context) error) *Session_AbortTransaction_Call
• type Session_AdvanceClusterTime_Call
  • func (_c *Session_AdvanceClusterTime_Call) Return(_a0 error) *Session_AdvanceClusterTime_Call
  • func (_c *Session_AdvanceClusterTime_Call) Run(run func(_a0 bson.Raw)) *Session_AdvanceClusterTime_Call
  • func (_c *Session_AdvanceClusterTime_Call) RunAndReturn(run func(bson.Raw) error) *Session_AdvanceClusterTime_Call
• type Session_AdvanceOperationTime_Call
  • func (_c *Session_AdvanceOperationTime_Call) Return(_a0 error) *Session_AdvanceOperationTime_Call
  • func (_c *Session_AdvanceOperationTime_Call) Run(run func(_a0 *primitive.Timestamp)) *Session_AdvanceOperationTime_Call
  • func (_c *Session_AdvanceOperationTime_Call) RunAndReturn(run func(*primitive.Timestamp) error) *Session_AdvanceOperationTime_Call
• type Session_Client_Call
  • func (_c *Session_Client_Call) Return(_a0 mongoifc.Client) *Session_Client_Call
  • func (_c *Session_Client_Call) Run(run func()) *Session_Client_Call
  • func (_c *Session_Client_Call) RunAndReturn(run func() mongoifc.Client) *Session_Client_Call
• type Session_ClusterTime_Call
  • func (_c *Session_ClusterTime_Call) Return(_a0 bson.Raw) *Session_ClusterTime_Call
  • func (_c *Session_ClusterTime_Call) Run(run func()) *Session_ClusterTime_Call
  • func (_c *Session_ClusterTime_Call) RunAndReturn(run func() bson.Raw) *Session_ClusterTime_Call
• type Session_CommitTransaction_Call
  • func (_c *Session_CommitTransaction_Call) Return(_a0 error) *Session_CommitTransaction_Call
  • func (_c *Session_CommitTransaction_Call) Run(run func(ctx context.Context)) *Session_CommitTransaction_Call
  • func (_c *Session_CommitTransaction_Call) RunAndReturn(run func(context.Context) error) *Session_CommitTransaction_Call
• type Session_EndSession_Call
  • func (_c *Session_EndSession_Call) Return() *Session_EndSession_Call
  • func (_c *Session_EndSession_Call) Run(run func(ctx context.Context)) *Session_EndSession_Call
  • func (_c *Session_EndSession_Call) RunAndReturn(run func(context.Context)) *Session_EndSession_Call
• type Session_Expecter
  • func (_e *Session_Expecter) AbortTransaction(ctx interface{}) *Session_AbortTransaction_Call
  • func (_e *Session_Expecter) AdvanceClusterTime(_a0 interface{}) *Session_AdvanceClusterTime_Call
  • func (_e *Session_Expecter) AdvanceOperationTime(_a0 interface{}) *Session_AdvanceOperationTime_Call
  • func (_e *Session_Expecter) Client() *Session_Client_Call
  • func (_e *Session_Expecter) ClusterTime() *Session_ClusterTime_Call
  • func (_e *Session_Expecter) CommitTransaction(ctx interface{}) *Session_CommitTransaction_Call
  • func (_e *Session_Expecter) EndSession(ctx interface{}) *Session_EndSession_Call
  • func (_e *Session_Expecter) ID() *Session_ID_Call
  • func (_e *Session_Expecter) OperationTime() *Session_OperationTime_Call
  • func (_e *Session_Expecter) StartTransaction(opts ...interface{}) *Session_StartTransaction_Call
  • func (_e *Session_Expecter) WithTransaction(ctx interface{}, fn interface{}, opts ...interface{}) *Session_WithTransaction_Call
• type Session_ID_Call
  • func (_c *Session_ID_Call) Return(_a0 bson.Raw) *Session_ID_Call
  • func (_c *Session_ID_Call) Run(run func()) *Session_ID_Call
  • func (_c *Session_ID_Call) RunAndReturn(run func() bson.Raw) *Session_ID_Call
• type Session_OperationTime_Call
  • func (_c *Session_OperationTime_Call) Return(_a0 *primitive.Timestamp) *Session_OperationTime_Call
  • func (_c *Session_OperationTime_Call) Run(run func()) *Session_OperationTime_Call
  • func (_c *Session_OperationTime_Call) RunAndReturn(run func() *primitive.Timestamp) *Session_OperationTime_Call
• type Session_StartTransaction_Call
  • func (_c *Session_StartTransaction_Call) Return(_a0 error) *Session_StartTransaction_Call
  • func (_c *Session_StartTransaction_Call) Run(run func(opts ...*options.TransactionOptions)) *Session_StartTransaction_Call
  • func (_c *Session_StartTransaction_Call) RunAndReturn(run func(...*options.TransactionOptions) error) *Session_StartTransaction_Call
• type Session_WithTransaction_Call
  • func (_c *Session_WithTransaction_Call) Return(_a0 interface{}, _a1 error) *Session_WithTransaction_Call
  • func (_c *Session_WithTransaction_Call) Run(...) *Session_WithTransaction_Call
  • func (_c *Session_WithTransaction_Call) RunAndReturn(...) *Session_WithTransaction_Call
• type SingleResult
  • func NewSingleResult(t interface{ ... }) *SingleResult
  • func (_m *SingleResult) Decode(v interface{}) error
  • func (_m *SingleResult) DecodeBytes() (bson.Raw, error)
  • func (_m *SingleResult) EXPECT() *SingleResult_Expecter
  • func (_m *SingleResult) Err() error
  • func (_m *SingleResult) Raw() (bson.Raw, error)
• type SingleResult_DecodeBytes_Call
  • func (_c *SingleResult_DecodeBytes_Call) Return(_a0 bson.Raw, _a1 error) *SingleResult_DecodeBytes_Call
  • func (_c *SingleResult_DecodeBytes_Call) Run(run func()) *SingleResult_DecodeBytes_Call
  • func (_c *SingleResult_DecodeBytes_Call) RunAndReturn(run func() (bson.Raw, error)) *SingleResult_DecodeBytes_Call
• type SingleResult_Decode_Call
  • func (_c *SingleResult_Decode_Call) Return(_a0 error) *SingleResult_Decode_Call
  • func (_c *SingleResult_Decode_Call) Run(run func(v interface{})) *SingleResult_Decode_Call
  • func (_c *SingleResult_Decode_Call) RunAndReturn(run func(interface{}) error) *SingleResult_Decode_Call
• type SingleResult_Err_Call
  • func (_c *SingleResult_Err_Call) Return(_a0 error) *SingleResult_Err_Call
  • func (_c *SingleResult_Err_Call) Run(run func()) *SingleResult_Err_Call
  • func (_c *SingleResult_Err_Call) RunAndReturn(run func() error) *SingleResult_Err_Call
• type SingleResult_Expecter
  • func (_e *SingleResult_Expecter) Decode(v interface{}) *SingleResult_Decode_Call
  • func (_e *SingleResult_Expecter) DecodeBytes() *SingleResult_DecodeBytes_Call
  • func (_e *SingleResult_Expecter) Err() *SingleResult_Err_Call
  • func (_e *SingleResult_Expecter) Raw() *SingleResult_Raw_Call
• type SingleResult_Raw_Call
  • func (_c *SingleResult_Raw_Call) Return(_a0 bson.Raw, _a1 error) *SingleResult_Raw_Call
  • func (_c *SingleResult_Raw_Call) Run(run func()) *SingleResult_Raw_Call
  • func (_c *SingleResult_Raw_Call) RunAndReturn(run func() (bson.Raw, error)) *SingleResult_Raw_Call

Types

type ChangeStream

type ChangeStream struct {
	mock.Mock
}

ChangeStream is an autogenerated mock type for the ChangeStream type

func NewChangeStream

func NewChangeStream(t interface {
	mock.TestingT
	Cleanup(func())
}) *ChangeStream

NewChangeStream creates a new instance of ChangeStream. 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 (*ChangeStream) Close

func (_m *ChangeStream) Close(ctx context.Context) error

Close provides a mock function with given fields: ctx

func (*ChangeStream) Current

func (_m *ChangeStream) Current() bson.Raw

Current provides a mock function with given fields:

func (*ChangeStream) Decode

func (_m *ChangeStream) Decode(val interface{}) error

Decode provides a mock function with given fields: val

func (*ChangeStream) EXPECT

func (_m *ChangeStream) EXPECT() *ChangeStream_Expecter

func (*ChangeStream) Err

func (_m *ChangeStream) Err() error

Err provides a mock function with given fields:

func (*ChangeStream) ID

func (_m *ChangeStream) ID() int64

ID provides a mock function with given fields:

func (*ChangeStream) Next

func (_m *ChangeStream) Next(ctx context.Context) bool

Next provides a mock function with given fields: ctx

func (*ChangeStream) ResumeToken

func (_m *ChangeStream) ResumeToken() bson.Raw

ResumeToken provides a mock function with given fields:

func (*ChangeStream) SetBatchSize

func (_m *ChangeStream) SetBatchSize(size int32)

SetBatchSize provides a mock function with given fields: size

func (*ChangeStream) TryNext

func (_m *ChangeStream) TryNext(ctx context.Context) bool

TryNext provides a mock function with given fields: ctx

type ChangeStream_Close_Call

type ChangeStream_Close_Call struct {
	*mock.Call
}

ChangeStream_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'

func (*ChangeStream_Close_Call) Return

func (_c *ChangeStream_Close_Call) Return(_a0 error) *ChangeStream_Close_Call

func (*ChangeStream_Close_Call) Run

func (_c *ChangeStream_Close_Call) Run(run func(ctx context.Context)) *ChangeStream_Close_Call

func (*ChangeStream_Close_Call) RunAndReturn

func (_c *ChangeStream_Close_Call) RunAndReturn(run func(context.Context) error) *ChangeStream_Close_Call

type ChangeStream_Current_Call

type ChangeStream_Current_Call struct {
	*mock.Call
}

ChangeStream_Current_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Current'

func (*ChangeStream_Current_Call) Return

func (_c *ChangeStream_Current_Call) Return(_a0 bson.Raw) *ChangeStream_Current_Call

func (*ChangeStream_Current_Call) Run

func (_c *ChangeStream_Current_Call) Run(run func()) *ChangeStream_Current_Call

func (*ChangeStream_Current_Call) RunAndReturn

func (_c *ChangeStream_Current_Call) RunAndReturn(run func() bson.Raw) *ChangeStream_Current_Call

type ChangeStream_Decode_Call

type ChangeStream_Decode_Call struct {
	*mock.Call
}

ChangeStream_Decode_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Decode'

func (*ChangeStream_Decode_Call) Return

func (_c *ChangeStream_Decode_Call) Return(_a0 error) *ChangeStream_Decode_Call

func (*ChangeStream_Decode_Call) Run

func (_c *ChangeStream_Decode_Call) Run(run func(val interface{})) *ChangeStream_Decode_Call

func (*ChangeStream_Decode_Call) RunAndReturn

func (_c *ChangeStream_Decode_Call) RunAndReturn(run func(interface{}) error) *ChangeStream_Decode_Call

type ChangeStream_Err_Call

type ChangeStream_Err_Call struct {
	*mock.Call
}

ChangeStream_Err_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Err'

func (*ChangeStream_Err_Call) Return

func (_c *ChangeStream_Err_Call) Return(_a0 error) *ChangeStream_Err_Call

func (*ChangeStream_Err_Call) Run

func (_c *ChangeStream_Err_Call) Run(run func()) *ChangeStream_Err_Call

func (*ChangeStream_Err_Call) RunAndReturn

func (_c *ChangeStream_Err_Call) RunAndReturn(run func() error) *ChangeStream_Err_Call

type ChangeStream_Expecter

type ChangeStream_Expecter struct {
	// contains filtered or unexported fields
}

func (*ChangeStream_Expecter) Close

func (_e *ChangeStream_Expecter) Close(ctx interface{}) *ChangeStream_Close_Call

Close is a helper method to define mock.On call

• ctx context.Context

func (*ChangeStream_Expecter) Current

func (_e *ChangeStream_Expecter) Current() *ChangeStream_Current_Call

Current is a helper method to define mock.On call

func (*ChangeStream_Expecter) Decode

func (_e *ChangeStream_Expecter) Decode(val interface{}) *ChangeStream_Decode_Call

Decode is a helper method to define mock.On call

• val interface{}

func (*ChangeStream_Expecter) Err

func (_e *ChangeStream_Expecter) Err() *ChangeStream_Err_Call

Err is a helper method to define mock.On call

func (*ChangeStream_Expecter) ID

func (_e *ChangeStream_Expecter) ID() *ChangeStream_ID_Call

ID is a helper method to define mock.On call

func (*ChangeStream_Expecter) Next

func (_e *ChangeStream_Expecter) Next(ctx interface{}) *ChangeStream_Next_Call

Next is a helper method to define mock.On call

• ctx context.Context

func (*ChangeStream_Expecter) ResumeToken

func (_e *ChangeStream_Expecter) ResumeToken() *ChangeStream_ResumeToken_Call

ResumeToken is a helper method to define mock.On call

func (*ChangeStream_Expecter) SetBatchSize

func (_e *ChangeStream_Expecter) SetBatchSize(size interface{}) *ChangeStream_SetBatchSize_Call

SetBatchSize is a helper method to define mock.On call

• size int32

func (*ChangeStream_Expecter) TryNext

func (_e *ChangeStream_Expecter) TryNext(ctx interface{}) *ChangeStream_TryNext_Call

TryNext is a helper method to define mock.On call

• ctx context.Context

type ChangeStream_ID_Call

type ChangeStream_ID_Call struct {
	*mock.Call
}

ChangeStream_ID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ID'

func (*ChangeStream_ID_Call) Return

func (_c *ChangeStream_ID_Call) Return(_a0 int64) *ChangeStream_ID_Call

func (*ChangeStream_ID_Call) Run

func (_c *ChangeStream_ID_Call) Run(run func()) *ChangeStream_ID_Call

func (*ChangeStream_ID_Call) RunAndReturn

func (_c *ChangeStream_ID_Call) RunAndReturn(run func() int64) *ChangeStream_ID_Call

type ChangeStream_Next_Call

type ChangeStream_Next_Call struct {
	*mock.Call
}

ChangeStream_Next_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Next'

func (*ChangeStream_Next_Call) Return

func (_c *ChangeStream_Next_Call) Return(_a0 bool) *ChangeStream_Next_Call

func (*ChangeStream_Next_Call) Run

func (_c *ChangeStream_Next_Call) Run(run func(ctx context.Context)) *ChangeStream_Next_Call

func (*ChangeStream_Next_Call) RunAndReturn

func (_c *ChangeStream_Next_Call) RunAndReturn(run func(context.Context) bool) *ChangeStream_Next_Call

type ChangeStream_ResumeToken_Call

type ChangeStream_ResumeToken_Call struct {
	*mock.Call
}

ChangeStream_ResumeToken_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ResumeToken'

func (*ChangeStream_ResumeToken_Call) Return

func (_c *ChangeStream_ResumeToken_Call) Return(_a0 bson.Raw) *ChangeStream_ResumeToken_Call

func (*ChangeStream_ResumeToken_Call) Run

func (_c *ChangeStream_ResumeToken_Call) Run(run func()) *ChangeStream_ResumeToken_Call

func (*ChangeStream_ResumeToken_Call) RunAndReturn

func (_c *ChangeStream_ResumeToken_Call) RunAndReturn(run func() bson.Raw) *ChangeStream_ResumeToken_Call

type ChangeStream_SetBatchSize_Call

type ChangeStream_SetBatchSize_Call struct {
	*mock.Call
}

ChangeStream_SetBatchSize_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetBatchSize'

func (*ChangeStream_SetBatchSize_Call) Return

func (_c *ChangeStream_SetBatchSize_Call) Return() *ChangeStream_SetBatchSize_Call

func (*ChangeStream_SetBatchSize_Call) Run

func (_c *ChangeStream_SetBatchSize_Call) Run(run func(size int32)) *ChangeStream_SetBatchSize_Call

func (*ChangeStream_SetBatchSize_Call) RunAndReturn

func (_c *ChangeStream_SetBatchSize_Call) RunAndReturn(run func(int32)) *ChangeStream_SetBatchSize_Call

type ChangeStream_TryNext_Call

type ChangeStream_TryNext_Call struct {
	*mock.Call
}

ChangeStream_TryNext_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TryNext'

func (*ChangeStream_TryNext_Call) Return

func (_c *ChangeStream_TryNext_Call) Return(_a0 bool) *ChangeStream_TryNext_Call

func (*ChangeStream_TryNext_Call) Run

func (_c *ChangeStream_TryNext_Call) Run(run func(ctx context.Context)) *ChangeStream_TryNext_Call

func (*ChangeStream_TryNext_Call) RunAndReturn

func (_c *ChangeStream_TryNext_Call) RunAndReturn(run func(context.Context) bool) *ChangeStream_TryNext_Call

type Client

type Client struct {
	mock.Mock
}

Client is an autogenerated mock type for the Client type

func NewClient

func NewClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *Client

NewClient creates a new instance of Client. 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 (*Client) Connect

func (_m *Client) Connect(ctx context.Context) error

Connect provides a mock function with given fields: ctx

func (*Client) Database

func (_m *Client) Database(name string, opts ...*options.DatabaseOptions) mongoifc.Database

Database provides a mock function with given fields: name, opts

func (*Client) Disconnect

func (_m *Client) Disconnect(ctx context.Context) error

Disconnect provides a mock function with given fields: ctx

func (*Client) EXPECT

func (_m *Client) EXPECT() *Client_Expecter

func (*Client) ListDatabaseNames

func (_m *Client) ListDatabaseNames(ctx context.Context, filter interface{}, opts ...*options.ListDatabasesOptions) ([]string, error)

ListDatabaseNames provides a mock function with given fields: ctx, filter, opts

func (*Client) ListDatabases

func (_m *Client) ListDatabases(ctx context.Context, filter interface{}, opts ...*options.ListDatabasesOptions) (mongo.ListDatabasesResult, error)

ListDatabases provides a mock function with given fields: ctx, filter, opts

func (*Client) NumberSessionsInProgress

func (_m *Client) NumberSessionsInProgress() int

NumberSessionsInProgress provides a mock function with given fields:

func (*Client) Ping

func (_m *Client) Ping(ctx context.Context, rp *readpref.ReadPref) error

Ping provides a mock function with given fields: ctx, rp

func (*Client) StartSession

func (_m *Client) StartSession(opts ...*options.SessionOptions) (mongoifc.Session, error)

StartSession provides a mock function with given fields: opts

func (*Client) Timeout

func (_m *Client) Timeout() *time.Duration

Timeout provides a mock function with given fields:

func (*Client) UseSession

func (_m *Client) UseSession(ctx context.Context, fn func(mongoifc.SessionContext) error) error

UseSession provides a mock function with given fields: ctx, fn

func (*Client) UseSessionWithOptions

func (_m *Client) UseSessionWithOptions(ctx context.Context, opts *options.SessionOptions, fn func(mongoifc.SessionContext) error) error

UseSessionWithOptions provides a mock function with given fields: ctx, opts, fn

func (*Client) Watch

func (_m *Client) Watch(ctx context.Context, pipeline interface{}, opts ...*options.ChangeStreamOptions) (mongoifc.ChangeStream, error)

Watch provides a mock function with given fields: ctx, pipeline, opts

type ClientEncryption

type ClientEncryption struct {
	mock.Mock
}

ClientEncryption is an autogenerated mock type for the ClientEncryption type

func NewClientEncryption

func NewClientEncryption(t interface {
	mock.TestingT
	Cleanup(func())
}) *ClientEncryption

NewClientEncryption creates a new instance of ClientEncryption. 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 (*ClientEncryption) AddKeyAltName

func (_m *ClientEncryption) AddKeyAltName(ctx context.Context, id primitive.Binary, keyAltName string) mongoifc.SingleResult

AddKeyAltName provides a mock function with given fields: ctx, id, keyAltName

func (*ClientEncryption) Close

func (_m *ClientEncryption) Close(ctx context.Context) error

Close provides a mock function with given fields: ctx

func (*ClientEncryption) CreateDataKey

func (_m *ClientEncryption) CreateDataKey(ctx context.Context, kmsProvider string, opts ...*options.DataKeyOptions) (primitive.Binary, error)

CreateDataKey provides a mock function with given fields: ctx, kmsProvider, opts

func (*ClientEncryption) CreateEncryptedCollection

func (_m *ClientEncryption) CreateEncryptedCollection(ctx context.Context, db mongoifc.Database, coll string, createOpts *options.CreateCollectionOptions, kmsProvider string, masterKey interface{}) (mongoifc.Collection, primitive.M, error)

CreateEncryptedCollection provides a mock function with given fields: ctx, db, coll, createOpts, kmsProvider, masterKey

func (*ClientEncryption) Decrypt

func (_m *ClientEncryption) Decrypt(ctx context.Context, val primitive.Binary) (bson.RawValue, error)

Decrypt provides a mock function with given fields: ctx, val

func (*ClientEncryption) DeleteKey

func (_m *ClientEncryption) DeleteKey(ctx context.Context, id primitive.Binary) (*mongo.DeleteResult, error)

DeleteKey provides a mock function with given fields: ctx, id

func (*ClientEncryption) EXPECT

func (_m *ClientEncryption) EXPECT() *ClientEncryption_Expecter

func (*ClientEncryption) Encrypt

func (_m *ClientEncryption) Encrypt(ctx context.Context, val bson.RawValue, opts ...*options.EncryptOptions) (primitive.Binary, error)

Encrypt provides a mock function with given fields: ctx, val, opts

func (*ClientEncryption) EncryptExpression

func (_m *ClientEncryption) EncryptExpression(ctx context.Context, expr interface{}, result interface{}, opts ...*options.EncryptOptions) error

EncryptExpression provides a mock function with given fields: ctx, expr, result, opts

func (*ClientEncryption) GetKey

func (_m *ClientEncryption) GetKey(ctx context.Context, id primitive.Binary) mongoifc.SingleResult

GetKey provides a mock function with given fields: ctx, id

func (*ClientEncryption) GetKeyByAltName

func (_m *ClientEncryption) GetKeyByAltName(ctx context.Context, keyAltName string) mongoifc.SingleResult

GetKeyByAltName provides a mock function with given fields: ctx, keyAltName

func (*ClientEncryption) GetKeys

func (_m *ClientEncryption) GetKeys(ctx context.Context) (mongoifc.Cursor, error)

GetKeys provides a mock function with given fields: ctx

func (*ClientEncryption) RemoveKeyAltName

func (_m *ClientEncryption) RemoveKeyAltName(ctx context.Context, id primitive.Binary, keyAltName string) mongoifc.SingleResult

RemoveKeyAltName provides a mock function with given fields: ctx, id, keyAltName

func (*ClientEncryption) RewrapManyDataKey

func (_m *ClientEncryption) RewrapManyDataKey(ctx context.Context, filter interface{}, opts ...*options.RewrapManyDataKeyOptions) (*mongo.RewrapManyDataKeyResult, error)

RewrapManyDataKey provides a mock function with given fields: ctx, filter, opts

type ClientEncryption_AddKeyAltName_Call

type ClientEncryption_AddKeyAltName_Call struct {
	*mock.Call
}

ClientEncryption_AddKeyAltName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AddKeyAltName'

func (*ClientEncryption_AddKeyAltName_Call) Return

func (_c *ClientEncryption_AddKeyAltName_Call) Return(_a0 mongoifc.SingleResult) *ClientEncryption_AddKeyAltName_Call

func (*ClientEncryption_AddKeyAltName_Call) Run

func (_c *ClientEncryption_AddKeyAltName_Call) Run(run func(ctx context.Context, id primitive.Binary, keyAltName string)) *ClientEncryption_AddKeyAltName_Call

func (*ClientEncryption_AddKeyAltName_Call) RunAndReturn

func (_c *ClientEncryption_AddKeyAltName_Call) RunAndReturn(run func(context.Context, primitive.Binary, string) mongoifc.SingleResult) *ClientEncryption_AddKeyAltName_Call

type ClientEncryption_Close_Call

type ClientEncryption_Close_Call struct {
	*mock.Call
}

ClientEncryption_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'

func (*ClientEncryption_Close_Call) Return

func (_c *ClientEncryption_Close_Call) Return(_a0 error) *ClientEncryption_Close_Call

func (*ClientEncryption_Close_Call) Run

func (_c *ClientEncryption_Close_Call) Run(run func(ctx context.Context)) *ClientEncryption_Close_Call

func (*ClientEncryption_Close_Call) RunAndReturn

func (_c *ClientEncryption_Close_Call) RunAndReturn(run func(context.Context) error) *ClientEncryption_Close_Call

type ClientEncryption_CreateDataKey_Call

type ClientEncryption_CreateDataKey_Call struct {
	*mock.Call
}

ClientEncryption_CreateDataKey_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateDataKey'

func (*ClientEncryption_CreateDataKey_Call) Return

func (_c *ClientEncryption_CreateDataKey_Call) Return(_a0 primitive.Binary, _a1 error) *ClientEncryption_CreateDataKey_Call

func (*ClientEncryption_CreateDataKey_Call) Run

func (_c *ClientEncryption_CreateDataKey_Call) Run(run func(ctx context.Context, kmsProvider string, opts ...*options.DataKeyOptions)) *ClientEncryption_CreateDataKey_Call

func (*ClientEncryption_CreateDataKey_Call) RunAndReturn

func (_c *ClientEncryption_CreateDataKey_Call) RunAndReturn(run func(context.Context, string, ...*options.DataKeyOptions) (primitive.Binary, error)) *ClientEncryption_CreateDataKey_Call

type ClientEncryption_CreateEncryptedCollection_Call

type ClientEncryption_CreateEncryptedCollection_Call struct {
	*mock.Call
}

ClientEncryption_CreateEncryptedCollection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateEncryptedCollection'

func (*ClientEncryption_CreateEncryptedCollection_Call) Return

func (_c *ClientEncryption_CreateEncryptedCollection_Call) Return(_a0 mongoifc.Collection, _a1 primitive.M, _a2 error) *ClientEncryption_CreateEncryptedCollection_Call

func (*ClientEncryption_CreateEncryptedCollection_Call) Run

func (_c *ClientEncryption_CreateEncryptedCollection_Call) Run(run func(ctx context.Context, db mongoifc.Database, coll string, createOpts *options.CreateCollectionOptions, kmsProvider string, masterKey interface{})) *ClientEncryption_CreateEncryptedCollection_Call

func (*ClientEncryption_CreateEncryptedCollection_Call) RunAndReturn

func (_c *ClientEncryption_CreateEncryptedCollection_Call) RunAndReturn(run func(context.Context, mongoifc.Database, string, *options.CreateCollectionOptions, string, interface{}) (mongoifc.Collection, primitive.M, error)) *ClientEncryption_CreateEncryptedCollection_Call

type ClientEncryption_Decrypt_Call

type ClientEncryption_Decrypt_Call struct {
	*mock.Call
}

ClientEncryption_Decrypt_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Decrypt'

func (*ClientEncryption_Decrypt_Call) Return

func (_c *ClientEncryption_Decrypt_Call) Return(_a0 bson.RawValue, _a1 error) *ClientEncryption_Decrypt_Call

func (*ClientEncryption_Decrypt_Call) Run

func (_c *ClientEncryption_Decrypt_Call) Run(run func(ctx context.Context, val primitive.Binary)) *ClientEncryption_Decrypt_Call

func (*ClientEncryption_Decrypt_Call) RunAndReturn

func (_c *ClientEncryption_Decrypt_Call) RunAndReturn(run func(context.Context, primitive.Binary) (bson.RawValue, error)) *ClientEncryption_Decrypt_Call

type ClientEncryption_DeleteKey_Call

type ClientEncryption_DeleteKey_Call struct {
	*mock.Call
}

ClientEncryption_DeleteKey_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteKey'

func (*ClientEncryption_DeleteKey_Call) Return

func (_c *ClientEncryption_DeleteKey_Call) Return(_a0 *mongo.DeleteResult, _a1 error) *ClientEncryption_DeleteKey_Call

func (*ClientEncryption_DeleteKey_Call) Run

func (_c *ClientEncryption_DeleteKey_Call) Run(run func(ctx context.Context, id primitive.Binary)) *ClientEncryption_DeleteKey_Call

func (*ClientEncryption_DeleteKey_Call) RunAndReturn

func (_c *ClientEncryption_DeleteKey_Call) RunAndReturn(run func(context.Context, primitive.Binary) (*mongo.DeleteResult, error)) *ClientEncryption_DeleteKey_Call

type ClientEncryption_EncryptExpression_Call

type ClientEncryption_EncryptExpression_Call struct {
	*mock.Call
}

ClientEncryption_EncryptExpression_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'EncryptExpression'

func (*ClientEncryption_EncryptExpression_Call) Return

func (_c *ClientEncryption_EncryptExpression_Call) Return(_a0 error) *ClientEncryption_EncryptExpression_Call

func (*ClientEncryption_EncryptExpression_Call) Run

func (_c *ClientEncryption_EncryptExpression_Call) Run(run func(ctx context.Context, expr interface{}, result interface{}, opts ...*options.EncryptOptions)) *ClientEncryption_EncryptExpression_Call

func (*ClientEncryption_EncryptExpression_Call) RunAndReturn

func (_c *ClientEncryption_EncryptExpression_Call) RunAndReturn(run func(context.Context, interface{}, interface{}, ...*options.EncryptOptions) error) *ClientEncryption_EncryptExpression_Call

type ClientEncryption_Encrypt_Call

type ClientEncryption_Encrypt_Call struct {
	*mock.Call
}

ClientEncryption_Encrypt_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Encrypt'

func (*ClientEncryption_Encrypt_Call) Return

func (_c *ClientEncryption_Encrypt_Call) Return(_a0 primitive.Binary, _a1 error) *ClientEncryption_Encrypt_Call

func (*ClientEncryption_Encrypt_Call) Run

func (_c *ClientEncryption_Encrypt_Call) Run(run func(ctx context.Context, val bson.RawValue, opts ...*options.EncryptOptions)) *ClientEncryption_Encrypt_Call

func (*ClientEncryption_Encrypt_Call) RunAndReturn

func (_c *ClientEncryption_Encrypt_Call) RunAndReturn(run func(context.Context, bson.RawValue, ...*options.EncryptOptions) (primitive.Binary, error)) *ClientEncryption_Encrypt_Call

type ClientEncryption_Expecter

type ClientEncryption_Expecter struct {
	// contains filtered or unexported fields
}

func (*ClientEncryption_Expecter) AddKeyAltName

func (_e *ClientEncryption_Expecter) AddKeyAltName(ctx interface{}, id interface{}, keyAltName interface{}) *ClientEncryption_AddKeyAltName_Call

AddKeyAltName is a helper method to define mock.On call

• ctx context.Context
• id primitive.Binary
• keyAltName string

func (*ClientEncryption_Expecter) Close

func (_e *ClientEncryption_Expecter) Close(ctx interface{}) *ClientEncryption_Close_Call

Close is a helper method to define mock.On call

• ctx context.Context

func (*ClientEncryption_Expecter) CreateDataKey

func (_e *ClientEncryption_Expecter) CreateDataKey(ctx interface{}, kmsProvider interface{}, opts ...interface{}) *ClientEncryption_CreateDataKey_Call

CreateDataKey is a helper method to define mock.On call

• ctx context.Context
• kmsProvider string
• opts ...*options.DataKeyOptions

func (*ClientEncryption_Expecter) CreateEncryptedCollection

func (_e *ClientEncryption_Expecter) CreateEncryptedCollection(ctx interface{}, db interface{}, coll interface{}, createOpts interface{}, kmsProvider interface{}, masterKey interface{}) *ClientEncryption_CreateEncryptedCollection_Call

CreateEncryptedCollection is a helper method to define mock.On call

• ctx context.Context
• db mongoifc.Database
• coll string
• createOpts *options.CreateCollectionOptions
• kmsProvider string
• masterKey interface{}

func (*ClientEncryption_Expecter) Decrypt

func (_e *ClientEncryption_Expecter) Decrypt(ctx interface{}, val interface{}) *ClientEncryption_Decrypt_Call

Decrypt is a helper method to define mock.On call

• ctx context.Context
• val primitive.Binary

func (*ClientEncryption_Expecter) DeleteKey

func (_e *ClientEncryption_Expecter) DeleteKey(ctx interface{}, id interface{}) *ClientEncryption_DeleteKey_Call

DeleteKey is a helper method to define mock.On call

• ctx context.Context
• id primitive.Binary

func (*ClientEncryption_Expecter) Encrypt

func (_e *ClientEncryption_Expecter) Encrypt(ctx interface{}, val interface{}, opts ...interface{}) *ClientEncryption_Encrypt_Call

Encrypt is a helper method to define mock.On call

• ctx context.Context
• val bson.RawValue
• opts ...*options.EncryptOptions

func (*ClientEncryption_Expecter) EncryptExpression

func (_e *ClientEncryption_Expecter) EncryptExpression(ctx interface{}, expr interface{}, result interface{}, opts ...interface{}) *ClientEncryption_EncryptExpression_Call

EncryptExpression is a helper method to define mock.On call

• ctx context.Context
• expr interface{}
• result interface{}
• opts ...*options.EncryptOptions

func (*ClientEncryption_Expecter) GetKey

func (_e *ClientEncryption_Expecter) GetKey(ctx interface{}, id interface{}) *ClientEncryption_GetKey_Call

GetKey is a helper method to define mock.On call

• ctx context.Context
• id primitive.Binary

func (*ClientEncryption_Expecter) GetKeyByAltName

func (_e *ClientEncryption_Expecter) GetKeyByAltName(ctx interface{}, keyAltName interface{}) *ClientEncryption_GetKeyByAltName_Call

GetKeyByAltName is a helper method to define mock.On call

• ctx context.Context
• keyAltName string

func (*ClientEncryption_Expecter) GetKeys

func (_e *ClientEncryption_Expecter) GetKeys(ctx interface{}) *ClientEncryption_GetKeys_Call

GetKeys is a helper method to define mock.On call

• ctx context.Context

func (*ClientEncryption_Expecter) RemoveKeyAltName

func (_e *ClientEncryption_Expecter) RemoveKeyAltName(ctx interface{}, id interface{}, keyAltName interface{}) *ClientEncryption_RemoveKeyAltName_Call

RemoveKeyAltName is a helper method to define mock.On call

• ctx context.Context
• id primitive.Binary
• keyAltName string

func (*ClientEncryption_Expecter) RewrapManyDataKey

func (_e *ClientEncryption_Expecter) RewrapManyDataKey(ctx interface{}, filter interface{}, opts ...interface{}) *ClientEncryption_RewrapManyDataKey_Call

RewrapManyDataKey is a helper method to define mock.On call

• ctx context.Context
• filter interface{}
• opts ...*options.RewrapManyDataKeyOptions

type ClientEncryption_GetKeyByAltName_Call

type ClientEncryption_GetKeyByAltName_Call struct {
	*mock.Call
}

ClientEncryption_GetKeyByAltName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetKeyByAltName'

func (*ClientEncryption_GetKeyByAltName_Call) Return

func (_c *ClientEncryption_GetKeyByAltName_Call) Return(_a0 mongoifc.SingleResult) *ClientEncryption_GetKeyByAltName_Call

func (*ClientEncryption_GetKeyByAltName_Call) Run

func (_c *ClientEncryption_GetKeyByAltName_Call) Run(run func(ctx context.Context, keyAltName string)) *ClientEncryption_GetKeyByAltName_Call

func (*ClientEncryption_GetKeyByAltName_Call) RunAndReturn

func (_c *ClientEncryption_GetKeyByAltName_Call) RunAndReturn(run func(context.Context, string) mongoifc.SingleResult) *ClientEncryption_GetKeyByAltName_Call

type ClientEncryption_GetKey_Call

type ClientEncryption_GetKey_Call struct {
	*mock.Call
}

ClientEncryption_GetKey_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetKey'

func (*ClientEncryption_GetKey_Call) Return

func (_c *ClientEncryption_GetKey_Call) Return(_a0 mongoifc.SingleResult) *ClientEncryption_GetKey_Call

func (*ClientEncryption_GetKey_Call) Run

func (_c *ClientEncryption_GetKey_Call) Run(run func(ctx context.Context, id primitive.Binary)) *ClientEncryption_GetKey_Call

func (*ClientEncryption_GetKey_Call) RunAndReturn

func (_c *ClientEncryption_GetKey_Call) RunAndReturn(run func(context.Context, primitive.Binary) mongoifc.SingleResult) *ClientEncryption_GetKey_Call

type ClientEncryption_GetKeys_Call

type ClientEncryption_GetKeys_Call struct {
	*mock.Call
}

ClientEncryption_GetKeys_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetKeys'

func (*ClientEncryption_GetKeys_Call) Return

func (_c *ClientEncryption_GetKeys_Call) Return(_a0 mongoifc.Cursor, _a1 error) *ClientEncryption_GetKeys_Call

func (*ClientEncryption_GetKeys_Call) Run

func (_c *ClientEncryption_GetKeys_Call) Run(run func(ctx context.Context)) *ClientEncryption_GetKeys_Call

func (*ClientEncryption_GetKeys_Call) RunAndReturn

func (_c *ClientEncryption_GetKeys_Call) RunAndReturn(run func(context.Context) (mongoifc.Cursor, error)) *ClientEncryption_GetKeys_Call

type ClientEncryption_RemoveKeyAltName_Call

type ClientEncryption_RemoveKeyAltName_Call struct {
	*mock.Call
}

ClientEncryption_RemoveKeyAltName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RemoveKeyAltName'

func (*ClientEncryption_RemoveKeyAltName_Call) Return

func (_c *ClientEncryption_RemoveKeyAltName_Call) Return(_a0 mongoifc.SingleResult) *ClientEncryption_RemoveKeyAltName_Call

func (*ClientEncryption_RemoveKeyAltName_Call) Run

func (_c *ClientEncryption_RemoveKeyAltName_Call) Run(run func(ctx context.Context, id primitive.Binary, keyAltName string)) *ClientEncryption_RemoveKeyAltName_Call

func (*ClientEncryption_RemoveKeyAltName_Call) RunAndReturn

func (_c *ClientEncryption_RemoveKeyAltName_Call) RunAndReturn(run func(context.Context, primitive.Binary, string) mongoifc.SingleResult) *ClientEncryption_RemoveKeyAltName_Call

type ClientEncryption_RewrapManyDataKey_Call

type ClientEncryption_RewrapManyDataKey_Call struct {
	*mock.Call
}

ClientEncryption_RewrapManyDataKey_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RewrapManyDataKey'

func (*ClientEncryption_RewrapManyDataKey_Call) Return

func (_c *ClientEncryption_RewrapManyDataKey_Call) Return(_a0 *mongo.RewrapManyDataKeyResult, _a1 error) *ClientEncryption_RewrapManyDataKey_Call

func (*ClientEncryption_RewrapManyDataKey_Call) Run

func (_c *ClientEncryption_RewrapManyDataKey_Call) Run(run func(ctx context.Context, filter interface{}, opts ...*options.RewrapManyDataKeyOptions)) *ClientEncryption_RewrapManyDataKey_Call

func (*ClientEncryption_RewrapManyDataKey_Call) RunAndReturn

func (_c *ClientEncryption_RewrapManyDataKey_Call) RunAndReturn(run func(context.Context, interface{}, ...*options.RewrapManyDataKeyOptions) (*mongo.RewrapManyDataKeyResult, error)) *ClientEncryption_RewrapManyDataKey_Call

type Client_Connect_Call

type Client_Connect_Call struct {
	*mock.Call
}

Client_Connect_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Connect'

func (*Client_Connect_Call) Return

func (_c *Client_Connect_Call) Return(_a0 error) *Client_Connect_Call

func (*Client_Connect_Call) Run

func (_c *Client_Connect_Call) Run(run func(ctx context.Context)) *Client_Connect_Call

func (*Client_Connect_Call) RunAndReturn

func (_c *Client_Connect_Call) RunAndReturn(run func(context.Context) error) *Client_Connect_Call

type Client_Database_Call

type Client_Database_Call struct {
	*mock.Call
}

Client_Database_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Database'

func (*Client_Database_Call) Return

func (_c *Client_Database_Call) Return(_a0 mongoifc.Database) *Client_Database_Call

func (*Client_Database_Call) Run

func (_c *Client_Database_Call) Run(run func(name string, opts ...*options.DatabaseOptions)) *Client_Database_Call

func (*Client_Database_Call) RunAndReturn

func (_c *Client_Database_Call) RunAndReturn(run func(string, ...*options.DatabaseOptions) mongoifc.Database) *Client_Database_Call

type Client_Disconnect_Call

type Client_Disconnect_Call struct {
	*mock.Call
}

Client_Disconnect_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Disconnect'

func (*Client_Disconnect_Call) Return

func (_c *Client_Disconnect_Call) Return(_a0 error) *Client_Disconnect_Call

func (*Client_Disconnect_Call) Run

func (_c *Client_Disconnect_Call) Run(run func(ctx context.Context)) *Client_Disconnect_Call

func (*Client_Disconnect_Call) RunAndReturn

func (_c *Client_Disconnect_Call) RunAndReturn(run func(context.Context) error) *Client_Disconnect_Call

type Client_Expecter

type Client_Expecter struct {
	// contains filtered or unexported fields
}

func (*Client_Expecter) Connect

func (_e *Client_Expecter) Connect(ctx interface{}) *Client_Connect_Call

Connect is a helper method to define mock.On call

• ctx context.Context

func (*Client_Expecter) Database

func (_e *Client_Expecter) Database(name interface{}, opts ...interface{}) *Client_Database_Call

Database is a helper method to define mock.On call

• name string
• opts ...*options.DatabaseOptions

func (*Client_Expecter) Disconnect

func (_e *Client_Expecter) Disconnect(ctx interface{}) *Client_Disconnect_Call

Disconnect is a helper method to define mock.On call

• ctx context.Context

func (*Client_Expecter) ListDatabaseNames

func (_e *Client_Expecter) ListDatabaseNames(ctx interface{}, filter interface{}, opts ...interface{}) *Client_ListDatabaseNames_Call

ListDatabaseNames is a helper method to define mock.On call

• ctx context.Context
• filter interface{}
• opts ...*options.ListDatabasesOptions

func (*Client_Expecter) ListDatabases

func (_e *Client_Expecter) ListDatabases(ctx interface{}, filter interface{}, opts ...interface{}) *Client_ListDatabases_Call

ListDatabases is a helper method to define mock.On call

• ctx context.Context
• filter interface{}
• opts ...*options.ListDatabasesOptions

func (*Client_Expecter) NumberSessionsInProgress

func (_e *Client_Expecter) NumberSessionsInProgress() *Client_NumberSessionsInProgress_Call

NumberSessionsInProgress is a helper method to define mock.On call

func (*Client_Expecter) Ping

func (_e *Client_Expecter) Ping(ctx interface{}, rp interface{}) *Client_Ping_Call

Ping is a helper method to define mock.On call

• ctx context.Context
• rp *readpref.ReadPref

func (*Client_Expecter) StartSession

func (_e *Client_Expecter) StartSession(opts ...interface{}) *Client_StartSession_Call

StartSession is a helper method to define mock.On call

• opts ...*options.SessionOptions

func (*Client_Expecter) Timeout

func (_e *Client_Expecter) Timeout() *Client_Timeout_Call

Timeout is a helper method to define mock.On call

func (*Client_Expecter) UseSession

func (_e *Client_Expecter) UseSession(ctx interface{}, fn interface{}) *Client_UseSession_Call

UseSession is a helper method to define mock.On call

• ctx context.Context
• fn func(mongoifc.SessionContext) error

func (*Client_Expecter) UseSessionWithOptions

func (_e *Client_Expecter) UseSessionWithOptions(ctx interface{}, opts interface{}, fn interface{}) *Client_UseSessionWithOptions_Call

UseSessionWithOptions is a helper method to define mock.On call

• ctx context.Context
• opts *options.SessionOptions
• fn func(mongoifc.SessionContext) error

func (*Client_Expecter) Watch

func (_e *Client_Expecter) Watch(ctx interface{}, pipeline interface{}, opts ...interface{}) *Client_Watch_Call

Watch is a helper method to define mock.On call

• ctx context.Context
• pipeline interface{}
• opts ...*options.ChangeStreamOptions

type Client_ListDatabaseNames_Call

type Client_ListDatabaseNames_Call struct {
	*mock.Call
}

Client_ListDatabaseNames_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListDatabaseNames'

func (*Client_ListDatabaseNames_Call) Return

func (_c *Client_ListDatabaseNames_Call) Return(_a0 []string, _a1 error) *Client_ListDatabaseNames_Call

func (*Client_ListDatabaseNames_Call) Run

func (_c *Client_ListDatabaseNames_Call) Run(run func(ctx context.Context, filter interface{}, opts ...*options.ListDatabasesOptions)) *Client_ListDatabaseNames_Call

func (*Client_ListDatabaseNames_Call) RunAndReturn

func (_c *Client_ListDatabaseNames_Call) RunAndReturn(run func(context.Context, interface{}, ...*options.ListDatabasesOptions) ([]string, error)) *Client_ListDatabaseNames_Call

type Client_ListDatabases_Call

type Client_ListDatabases_Call struct {
	*mock.Call
}

Client_ListDatabases_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListDatabases'

func (*Client_ListDatabases_Call) Return

func (_c *Client_ListDatabases_Call) Return(_a0 mongo.ListDatabasesResult, _a1 error) *Client_ListDatabases_Call

func (*Client_ListDatabases_Call) Run

func (_c *Client_ListDatabases_Call) Run(run func(ctx context.Context, filter interface{}, opts ...*options.ListDatabasesOptions)) *Client_ListDatabases_Call

func (*Client_ListDatabases_Call) RunAndReturn

func (_c *Client_ListDatabases_Call) RunAndReturn(run func(context.Context, interface{}, ...*options.ListDatabasesOptions) (mongo.ListDatabasesResult, error)) *Client_ListDatabases_Call

type Client_NumberSessionsInProgress_Call

type Client_NumberSessionsInProgress_Call struct {
	*mock.Call
}

Client_NumberSessionsInProgress_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NumberSessionsInProgress'

func (*Client_NumberSessionsInProgress_Call) Return

func (_c *Client_NumberSessionsInProgress_Call) Return(_a0 int) *Client_NumberSessionsInProgress_Call

func (*Client_NumberSessionsInProgress_Call) Run

func (_c *Client_NumberSessionsInProgress_Call) Run(run func()) *Client_NumberSessionsInProgress_Call

func (*Client_NumberSessionsInProgress_Call) RunAndReturn

func (_c *Client_NumberSessionsInProgress_Call) RunAndReturn(run func() int) *Client_NumberSessionsInProgress_Call

type Client_Ping_Call

type Client_Ping_Call struct {
	*mock.Call
}

Client_Ping_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ping'

func (*Client_Ping_Call) Return

func (_c *Client_Ping_Call) Return(_a0 error) *Client_Ping_Call

func (*Client_Ping_Call) Run

func (_c *Client_Ping_Call) Run(run func(ctx context.Context, rp *readpref.ReadPref)) *Client_Ping_Call

func (*Client_Ping_Call) RunAndReturn

func (_c *Client_Ping_Call) RunAndReturn(run func(context.Context, *readpref.ReadPref) error) *Client_Ping_Call

type Client_StartSession_Call

type Client_StartSession_Call struct {
	*mock.Call
}

Client_StartSession_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StartSession'

func (*Client_StartSession_Call) Return

func (_c *Client_StartSession_Call) Return(_a0 mongoifc.Session, _a1 error) *Client_StartSession_Call

func (*Client_StartSession_Call) Run

func (_c *Client_StartSession_Call) Run(run func(opts ...*options.SessionOptions)) *Client_StartSession_Call

func (*Client_StartSession_Call) RunAndReturn

func (_c *Client_StartSession_Call) RunAndReturn(run func(...*options.SessionOptions) (mongoifc.Session, error)) *Client_StartSession_Call

type Client_Timeout_Call

type Client_Timeout_Call struct {
	*mock.Call
}

Client_Timeout_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Timeout'

func (*Client_Timeout_Call) Return

func (_c *Client_Timeout_Call) Return(_a0 *time.Duration) *Client_Timeout_Call

func (*Client_Timeout_Call) Run

func (_c *Client_Timeout_Call) Run(run func()) *Client_Timeout_Call

func (*Client_Timeout_Call) RunAndReturn

func (_c *Client_Timeout_Call) RunAndReturn(run func() *time.Duration) *Client_Timeout_Call

type Client_UseSessionWithOptions_Call

type Client_UseSessionWithOptions_Call struct {
	*mock.Call
}

Client_UseSessionWithOptions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UseSessionWithOptions'

func (*Client_UseSessionWithOptions_Call) Return

func (_c *Client_UseSessionWithOptions_Call) Return(_a0 error) *Client_UseSessionWithOptions_Call

func (*Client_UseSessionWithOptions_Call) Run

func (_c *Client_UseSessionWithOptions_Call) Run(run func(ctx context.Context, opts *options.SessionOptions, fn func(mongoifc.SessionContext) error)) *Client_UseSessionWithOptions_Call

func (*Client_UseSessionWithOptions_Call) RunAndReturn

func (_c *Client_UseSessionWithOptions_Call) RunAndReturn(run func(context.Context, *options.SessionOptions, func(mongoifc.SessionContext) error) error) *Client_UseSessionWithOptions_Call

type Client_UseSession_Call

type Client_UseSession_Call struct {
	*mock.Call
}

Client_UseSession_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UseSession'

func (*Client_UseSession_Call) Return

func (_c *Client_UseSession_Call) Return(_a0 error) *Client_UseSession_Call

func (*Client_UseSession_Call) Run

func (_c *Client_UseSession_Call) Run(run func(ctx context.Context, fn func(mongoifc.SessionContext) error)) *Client_UseSession_Call

func (*Client_UseSession_Call) RunAndReturn

func (_c *Client_UseSession_Call) RunAndReturn(run func(context.Context, func(mongoifc.SessionContext) error) error) *Client_UseSession_Call

type Client_Watch_Call

type Client_Watch_Call struct {
	*mock.Call
}

Client_Watch_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Watch'

func (*Client_Watch_Call) Return

func (_c *Client_Watch_Call) Return(_a0 mongoifc.ChangeStream, _a1 error) *Client_Watch_Call

func (*Client_Watch_Call) Run

func (_c *Client_Watch_Call) Run(run func(ctx context.Context, pipeline interface{}, opts ...*options.ChangeStreamOptions)) *Client_Watch_Call

func (*Client_Watch_Call) RunAndReturn

func (_c *Client_Watch_Call) RunAndReturn(run func(context.Context, interface{}, ...*options.ChangeStreamOptions) (mongoifc.ChangeStream, error)) *Client_Watch_Call

type Collection

type Collection struct {
	mock.Mock
}

Collection is an autogenerated mock type for the Collection type

func NewCollection

func NewCollection(t interface {
	mock.TestingT
	Cleanup(func())
}) *Collection

NewCollection creates a new instance of Collection. 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 (*Collection) Aggregate

func (_m *Collection) Aggregate(ctx context.Context, pipeline interface{}, opts ...*options.AggregateOptions) (mongoifc.Cursor, error)

Aggregate provides a mock function with given fields: ctx, pipeline, opts

func (*Collection) BulkWrite

func (_m *Collection) BulkWrite(ctx context.Context, models []mongo.WriteModel, opts ...*options.BulkWriteOptions) (*mongo.BulkWriteResult, error)

BulkWrite provides a mock function with given fields: ctx, models, opts

func (*Collection) Clone

func (_m *Collection) Clone(opts ...*options.CollectionOptions) (mongoifc.Collection, error)

Clone provides a mock function with given fields: opts

func (*Collection) CountDocuments

func (_m *Collection) CountDocuments(ctx context.Context, filter interface{}, opts ...*options.CountOptions) (int64, error)

CountDocuments provides a mock function with given fields: ctx, filter, opts

func (*Collection) Database

func (_m *Collection) Database() mongoifc.Database

Database provides a mock function with given fields:

func (*Collection) DeleteMany

func (_m *Collection) DeleteMany(ctx context.Context, filter interface{}, opts ...*options.DeleteOptions) (*mongo.DeleteResult, error)

DeleteMany provides a mock function with given fields: ctx, filter, opts

func (*Collection) DeleteOne

func (_m *Collection) DeleteOne(ctx context.Context, filter interface{}, opts ...*options.DeleteOptions) (*mongo.DeleteResult, error)

DeleteOne provides a mock function with given fields: ctx, filter, opts

func (*Collection) Distinct

func (_m *Collection) Distinct(ctx context.Context, fieldName string, filter interface{}, opts ...*options.DistinctOptions) ([]interface{}, error)

Distinct provides a mock function with given fields: ctx, fieldName, filter, opts

func (*Collection) Drop

func (_m *Collection) Drop(ctx context.Context) error

Drop provides a mock function with given fields: ctx

func (*Collection) EXPECT

func (_m *Collection) EXPECT() *Collection_Expecter

func (*Collection) EstimatedDocumentCount

func (_m *Collection) EstimatedDocumentCount(ctx context.Context, opts ...*options.EstimatedDocumentCountOptions) (int64, error)

EstimatedDocumentCount provides a mock function with given fields: ctx, opts

func (*Collection) Find

func (_m *Collection) Find(ctx context.Context, filter interface{}, opts ...*options.FindOptions) (mongoifc.Cursor, error)

Find provides a mock function with given fields: ctx, filter, opts

func (*Collection) FindOne

func (_m *Collection) FindOne(ctx context.Context, filter interface{}, opts ...*options.FindOneOptions) mongoifc.SingleResult

FindOne provides a mock function with given fields: ctx, filter, opts

func (*Collection) FindOneAndDelete

func (_m *Collection) FindOneAndDelete(ctx context.Context, filter interface{}, opts ...*options.FindOneAndDeleteOptions) mongoifc.SingleResult

FindOneAndDelete provides a mock function with given fields: ctx, filter, opts

func (*Collection) FindOneAndReplace

func (_m *Collection) FindOneAndReplace(ctx context.Context, filter interface{}, replacement interface{}, opts ...*options.FindOneAndReplaceOptions) mongoifc.SingleResult

FindOneAndReplace provides a mock function with given fields: ctx, filter, replacement, opts

func (*Collection) FindOneAndUpdate

func (_m *Collection) FindOneAndUpdate(ctx context.Context, filter interface{}, update interface{}, opts ...*options.FindOneAndUpdateOptions) mongoifc.SingleResult

FindOneAndUpdate provides a mock function with given fields: ctx, filter, update, opts

func (*Collection) Indexes

func (_m *Collection) Indexes() mongoifc.IndexView

Indexes provides a mock function with given fields:

func (*Collection) InsertMany

func (_m *Collection) InsertMany(ctx context.Context, documents []interface{}, opts ...*options.InsertManyOptions) (*mongo.InsertManyResult, error)

InsertMany provides a mock function with given fields: ctx, documents, opts

func (*Collection) InsertOne

func (_m *Collection) InsertOne(ctx context.Context, document interface{}, opts ...*options.InsertOneOptions) (*mongo.InsertOneResult, error)

InsertOne provides a mock function with given fields: ctx, document, opts

func (*Collection) Name

func (_m *Collection) Name() string

Name provides a mock function with given fields:

func (*Collection) ReplaceOne

func (_m *Collection) ReplaceOne(ctx context.Context, filter interface{}, replacement interface{}, opts ...*options.ReplaceOptions) (*mongo.UpdateResult, error)

ReplaceOne provides a mock function with given fields: ctx, filter, replacement, opts

func (*Collection) SearchIndexes

func (_m *Collection) SearchIndexes() mongoifc.SearchIndexView

SearchIndexes provides a mock function with given fields:

func (*Collection) UpdateByID

func (_m *Collection) UpdateByID(ctx context.Context, id interface{}, update interface{}, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error)

UpdateByID provides a mock function with given fields: ctx, id, update, opts

func (*Collection) UpdateMany

func (_m *Collection) UpdateMany(ctx context.Context, filter interface{}, update interface{}, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error)

UpdateMany provides a mock function with given fields: ctx, filter, update, opts

func (*Collection) UpdateOne

func (_m *Collection) UpdateOne(ctx context.Context, filter interface{}, update interface{}, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error)

UpdateOne provides a mock function with given fields: ctx, filter, update, opts

func (*Collection) Watch

func (_m *Collection) Watch(ctx context.Context, pipeline interface{}, opts ...*options.ChangeStreamOptions) (mongoifc.ChangeStream, error)

Watch provides a mock function with given fields: ctx, pipeline, opts

type Collection_Aggregate_Call

type Collection_Aggregate_Call struct {
	*mock.Call
}

Collection_Aggregate_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Aggregate'

func (*Collection_Aggregate_Call) Return

func (_c *Collection_Aggregate_Call) Return(_a0 mongoifc.Cursor, _a1 error) *Collection_Aggregate_Call

func (*Collection_Aggregate_Call) Run

func (_c *Collection_Aggregate_Call) Run(run func(ctx context.Context, pipeline interface{}, opts ...*options.AggregateOptions)) *Collection_Aggregate_Call

func (*Collection_Aggregate_Call) RunAndReturn

func (_c *Collection_Aggregate_Call) RunAndReturn(run func(context.Context, interface{}, ...*options.AggregateOptions) (mongoifc.Cursor, error)) *Collection_Aggregate_Call

type Collection_BulkWrite_Call

type Collection_BulkWrite_Call struct {
	*mock.Call
}

Collection_BulkWrite_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'BulkWrite'

func (*Collection_BulkWrite_Call) Return

func (_c *Collection_BulkWrite_Call) Return(_a0 *mongo.BulkWriteResult, _a1 error) *Collection_BulkWrite_Call

func (*Collection_BulkWrite_Call) Run

func (_c *Collection_BulkWrite_Call) Run(run func(ctx context.Context, models []mongo.WriteModel, opts ...*options.BulkWriteOptions)) *Collection_BulkWrite_Call

func (*Collection_BulkWrite_Call) RunAndReturn

func (_c *Collection_BulkWrite_Call) RunAndReturn(run func(context.Context, []mongo.WriteModel, ...*options.BulkWriteOptions) (*mongo.BulkWriteResult, error)) *Collection_BulkWrite_Call

type Collection_Clone_Call

type Collection_Clone_Call struct {
	*mock.Call
}

Collection_Clone_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Clone'

func (*Collection_Clone_Call) Return

func (_c *Collection_Clone_Call) Return(_a0 mongoifc.Collection, _a1 error) *Collection_Clone_Call

func (*Collection_Clone_Call) Run

func (_c *Collection_Clone_Call) Run(run func(opts ...*options.CollectionOptions)) *Collection_Clone_Call

func (*Collection_Clone_Call) RunAndReturn

func (_c *Collection_Clone_Call) RunAndReturn(run func(...*options.CollectionOptions) (mongoifc.Collection, error)) *Collection_Clone_Call

type Collection_CountDocuments_Call

type Collection_CountDocuments_Call struct {
	*mock.Call
}

Collection_CountDocuments_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CountDocuments'

func (*Collection_CountDocuments_Call) Return

func (_c *Collection_CountDocuments_Call) Return(_a0 int64, _a1 error) *Collection_CountDocuments_Call

func (*Collection_CountDocuments_Call) Run

func (_c *Collection_CountDocuments_Call) Run(run func(ctx context.Context, filter interface{}, opts ...*options.CountOptions)) *Collection_CountDocuments_Call

func (*Collection_CountDocuments_Call) RunAndReturn

func (_c *Collection_CountDocuments_Call) RunAndReturn(run func(context.Context, interface{}, ...*options.CountOptions) (int64, error)) *Collection_CountDocuments_Call

type Collection_Database_Call

type Collection_Database_Call struct {
	*mock.Call
}

Collection_Database_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Database'

func (*Collection_Database_Call) Return

func (_c *Collection_Database_Call) Return(_a0 mongoifc.Database) *Collection_Database_Call

func (*Collection_Database_Call) Run

func (_c *Collection_Database_Call) Run(run func()) *Collection_Database_Call

func (*Collection_Database_Call) RunAndReturn

func (_c *Collection_Database_Call) RunAndReturn(run func() mongoifc.Database) *Collection_Database_Call

type Collection_DeleteMany_Call

type Collection_DeleteMany_Call struct {
	*mock.Call
}

Collection_DeleteMany_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteMany'

func (*Collection_DeleteMany_Call) Return

func (_c *Collection_DeleteMany_Call) Return(_a0 *mongo.DeleteResult, _a1 error) *Collection_DeleteMany_Call

func (*Collection_DeleteMany_Call) Run

func (_c *Collection_DeleteMany_Call) Run(run func(ctx context.Context, filter interface{}, opts ...*options.DeleteOptions)) *Collection_DeleteMany_Call

func (*Collection_DeleteMany_Call) RunAndReturn

func (_c *Collection_DeleteMany_Call) RunAndReturn(run func(context.Context, interface{}, ...*options.DeleteOptions) (*mongo.DeleteResult, error)) *Collection_DeleteMany_Call

type Collection_DeleteOne_Call

type Collection_DeleteOne_Call struct {
	*mock.Call
}

Collection_DeleteOne_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteOne'

func (*Collection_DeleteOne_Call) Return

func (_c *Collection_DeleteOne_Call) Return(_a0 *mongo.DeleteResult, _a1 error) *Collection_DeleteOne_Call

func (*Collection_DeleteOne_Call) Run

func (_c *Collection_DeleteOne_Call) Run(run func(ctx context.Context, filter interface{}, opts ...*options.DeleteOptions)) *Collection_DeleteOne_Call

func (*Collection_DeleteOne_Call) RunAndReturn

func (_c *Collection_DeleteOne_Call) RunAndReturn(run func(context.Context, interface{}, ...*options.DeleteOptions) (*mongo.DeleteResult, error)) *Collection_DeleteOne_Call

type Collection_Distinct_Call

type Collection_Distinct_Call struct {
	*mock.Call
}

Collection_Distinct_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Distinct'

func (*Collection_Distinct_Call) Return

func (_c *Collection_Distinct_Call) Return(_a0 []interface{}, _a1 error) *Collection_Distinct_Call

func (*Collection_Distinct_Call) Run

func (_c *Collection_Distinct_Call) Run(run func(ctx context.Context, fieldName string, filter interface{}, opts ...*options.DistinctOptions)) *Collection_Distinct_Call

func (*Collection_Distinct_Call) RunAndReturn

func (_c *Collection_Distinct_Call) RunAndReturn(run func(context.Context, string, interface{}, ...*options.DistinctOptions) ([]interface{}, error)) *Collection_Distinct_Call

type Collection_Drop_Call

type Collection_Drop_Call struct {
	*mock.Call
}

Collection_Drop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Drop'

func (*Collection_Drop_Call) Return

func (_c *Collection_Drop_Call) Return(_a0 error) *Collection_Drop_Call

func (*Collection_Drop_Call) Run

func (_c *Collection_Drop_Call) Run(run func(ctx context.Context)) *Collection_Drop_Call

func (*Collection_Drop_Call) RunAndReturn

func (_c *Collection_Drop_Call) RunAndReturn(run func(context.Context) error) *Collection_Drop_Call

type Collection_EstimatedDocumentCount_Call

type Collection_EstimatedDocumentCount_Call struct {
	*mock.Call
}

Collection_EstimatedDocumentCount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'EstimatedDocumentCount'

func (*Collection_EstimatedDocumentCount_Call) Return

func (_c *Collection_EstimatedDocumentCount_Call) Return(_a0 int64, _a1 error) *Collection_EstimatedDocumentCount_Call

func (*Collection_EstimatedDocumentCount_Call) Run

func (_c *Collection_EstimatedDocumentCount_Call) Run(run func(ctx context.Context, opts ...*options.EstimatedDocumentCountOptions)) *Collection_EstimatedDocumentCount_Call

func (*Collection_EstimatedDocumentCount_Call) RunAndReturn

func (_c *Collection_EstimatedDocumentCount_Call) RunAndReturn(run func(context.Context, ...*options.EstimatedDocumentCountOptions) (int64, error)) *Collection_EstimatedDocumentCount_Call

type Collection_Expecter

type Collection_Expecter struct {
	// contains filtered or unexported fields
}

func (*Collection_Expecter) Aggregate

func (_e *Collection_Expecter) Aggregate(ctx interface{}, pipeline interface{}, opts ...interface{}) *Collection_Aggregate_Call

Aggregate is a helper method to define mock.On call

• ctx context.Context
• pipeline interface{}
• opts ...*options.AggregateOptions

func (*Collection_Expecter) BulkWrite

func (_e *Collection_Expecter) BulkWrite(ctx interface{}, models interface{}, opts ...interface{}) *Collection_BulkWrite_Call

BulkWrite is a helper method to define mock.On call

• ctx context.Context
• models []mongo.WriteModel
• opts ...*options.BulkWriteOptions

func (*Collection_Expecter) Clone

func (_e *Collection_Expecter) Clone(opts ...interface{}) *Collection_Clone_Call

Clone is a helper method to define mock.On call

• opts ...*options.CollectionOptions

func (*Collection_Expecter) CountDocuments

func (_e *Collection_Expecter) CountDocuments(ctx interface{}, filter interface{}, opts ...interface{}) *Collection_CountDocuments_Call

CountDocuments is a helper method to define mock.On call

• ctx context.Context
• filter interface{}
• opts ...*options.CountOptions

func (*Collection_Expecter) Database

func (_e *Collection_Expecter) Database() *Collection_Database_Call

Database is a helper method to define mock.On call

func (*Collection_Expecter) DeleteMany

func (_e *Collection_Expecter) DeleteMany(ctx interface{}, filter interface{}, opts ...interface{}) *Collection_DeleteMany_Call

DeleteMany is a helper method to define mock.On call

• ctx context.Context
• filter interface{}
• opts ...*options.DeleteOptions

func (*Collection_Expecter) DeleteOne

func (_e *Collection_Expecter) DeleteOne(ctx interface{}, filter interface{}, opts ...interface{}) *Collection_DeleteOne_Call

DeleteOne is a helper method to define mock.On call

• ctx context.Context
• filter interface{}
• opts ...*options.DeleteOptions

func (*Collection_Expecter) Distinct

func (_e *Collection_Expecter) Distinct(ctx interface{}, fieldName interface{}, filter interface{}, opts ...interface{}) *Collection_Distinct_Call

Distinct is a helper method to define mock.On call

• ctx context.Context
• fieldName string
• filter interface{}
• opts ...*options.DistinctOptions

func (*Collection_Expecter) Drop

func (_e *Collection_Expecter) Drop(ctx interface{}) *Collection_Drop_Call

Drop is a helper method to define mock.On call

• ctx context.Context

func (*Collection_Expecter) EstimatedDocumentCount

func (_e *Collection_Expecter) EstimatedDocumentCount(ctx interface{}, opts ...interface{}) *Collection_EstimatedDocumentCount_Call

EstimatedDocumentCount is a helper method to define mock.On call

• ctx context.Context
• opts ...*options.EstimatedDocumentCountOptions

func (*Collection_Expecter) Find

func (_e *Collection_Expecter) Find(ctx interface{}, filter interface{}, opts ...interface{}) *Collection_Find_Call

Find is a helper method to define mock.On call

• ctx context.Context
• filter interface{}
• opts ...*options.FindOptions

func (*Collection_Expecter) FindOne

func (_e *Collection_Expecter) FindOne(ctx interface{}, filter interface{}, opts ...interface{}) *Collection_FindOne_Call

FindOne is a helper method to define mock.On call

• ctx context.Context
• filter interface{}
• opts ...*options.FindOneOptions

func (*Collection_Expecter) FindOneAndDelete

func (_e *Collection_Expecter) FindOneAndDelete(ctx interface{}, filter interface{}, opts ...interface{}) *Collection_FindOneAndDelete_Call

FindOneAndDelete is a helper method to define mock.On call

• ctx context.Context
• filter interface{}
• opts ...*options.FindOneAndDeleteOptions

func (*Collection_Expecter) FindOneAndReplace

func (_e *Collection_Expecter) FindOneAndReplace(ctx interface{}, filter interface{}, replacement interface{}, opts ...interface{}) *Collection_FindOneAndReplace_Call

FindOneAndReplace is a helper method to define mock.On call

• ctx context.Context
• filter interface{}
• replacement interface{}
• opts ...*options.FindOneAndReplaceOptions

func (*Collection_Expecter) FindOneAndUpdate

func (_e *Collection_Expecter) FindOneAndUpdate(ctx interface{}, filter interface{}, update interface{}, opts ...interface{}) *Collection_FindOneAndUpdate_Call

FindOneAndUpdate is a helper method to define mock.On call

• ctx context.Context
• filter interface{}
• update interface{}
• opts ...*options.FindOneAndUpdateOptions

func (*Collection_Expecter) Indexes

func (_e *Collection_Expecter) Indexes() *Collection_Indexes_Call

Indexes is a helper method to define mock.On call

func (*Collection_Expecter) InsertMany

func (_e *Collection_Expecter) InsertMany(ctx interface{}, documents interface{}, opts ...interface{}) *Collection_InsertMany_Call

InsertMany is a helper method to define mock.On call

• ctx context.Context
• documents []interface{}
• opts ...*options.InsertManyOptions

func (*Collection_Expecter) InsertOne

func (_e *Collection_Expecter) InsertOne(ctx interface{}, document interface{}, opts ...interface{}) *Collection_InsertOne_Call

InsertOne is a helper method to define mock.On call

• ctx context.Context
• document interface{}
• opts ...*options.InsertOneOptions

func (*Collection_Expecter) Name

func (_e *Collection_Expecter) Name() *Collection_Name_Call

Name is a helper method to define mock.On call

func (*Collection_Expecter) ReplaceOne

func (_e *Collection_Expecter) ReplaceOne(ctx interface{}, filter interface{}, replacement interface{}, opts ...interface{}) *Collection_ReplaceOne_Call

ReplaceOne is a helper method to define mock.On call

• ctx context.Context
• filter interface{}
• replacement interface{}
• opts ...*options.ReplaceOptions

func (*Collection_Expecter) SearchIndexes

func (_e *Collection_Expecter) SearchIndexes() *Collection_SearchIndexes_Call

SearchIndexes is a helper method to define mock.On call

func (*Collection_Expecter) UpdateByID

func (_e *Collection_Expecter) UpdateByID(ctx interface{}, id interface{}, update interface{}, opts ...interface{}) *Collection_UpdateByID_Call

UpdateByID is a helper method to define mock.On call

• ctx context.Context
• id interface{}
• update interface{}
• opts ...*options.UpdateOptions

func (*Collection_Expecter) UpdateMany

func (_e *Collection_Expecter) UpdateMany(ctx interface{}, filter interface{}, update interface{}, opts ...interface{}) *Collection_UpdateMany_Call

UpdateMany is a helper method to define mock.On call

• ctx context.Context
• filter interface{}
• update interface{}
• opts ...*options.UpdateOptions

func (*Collection_Expecter) UpdateOne

func (_e *Collection_Expecter) UpdateOne(ctx interface{}, filter interface{}, update interface{}, opts ...interface{}) *Collection_UpdateOne_Call

UpdateOne is a helper method to define mock.On call

• ctx context.Context
• filter interface{}
• update interface{}
• opts ...*options.UpdateOptions

func (*Collection_Expecter) Watch

func (_e *Collection_Expecter) Watch(ctx interface{}, pipeline interface{}, opts ...interface{}) *Collection_Watch_Call

Watch is a helper method to define mock.On call

• ctx context.Context
• pipeline interface{}
• opts ...*options.ChangeStreamOptions

type Collection_FindOneAndDelete_Call

type Collection_FindOneAndDelete_Call struct {
	*mock.Call
}

Collection_FindOneAndDelete_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindOneAndDelete'

func (*Collection_FindOneAndDelete_Call) Return

func (_c *Collection_FindOneAndDelete_Call) Return(_a0 mongoifc.SingleResult) *Collection_FindOneAndDelete_Call

func (*Collection_FindOneAndDelete_Call) Run

func (_c *Collection_FindOneAndDelete_Call) Run(run func(ctx context.Context, filter interface{}, opts ...*options.FindOneAndDeleteOptions)) *Collection_FindOneAndDelete_Call

func (*Collection_FindOneAndDelete_Call) RunAndReturn

func (_c *Collection_FindOneAndDelete_Call) RunAndReturn(run func(context.Context, interface{}, ...*options.FindOneAndDeleteOptions) mongoifc.SingleResult) *Collection_FindOneAndDelete_Call

type Collection_FindOneAndReplace_Call

type Collection_FindOneAndReplace_Call struct {
	*mock.Call
}

Collection_FindOneAndReplace_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindOneAndReplace'

func (*Collection_FindOneAndReplace_Call) Return

func (_c *Collection_FindOneAndReplace_Call) Return(_a0 mongoifc.SingleResult) *Collection_FindOneAndReplace_Call

func (*Collection_FindOneAndReplace_Call) Run

func (_c *Collection_FindOneAndReplace_Call) Run(run func(ctx context.Context, filter interface{}, replacement interface{}, opts ...*options.FindOneAndReplaceOptions)) *Collection_FindOneAndReplace_Call

func (*Collection_FindOneAndReplace_Call) RunAndReturn

func (_c *Collection_FindOneAndReplace_Call) RunAndReturn(run func(context.Context, interface{}, interface{}, ...*options.FindOneAndReplaceOptions) mongoifc.SingleResult) *Collection_FindOneAndReplace_Call

type Collection_FindOneAndUpdate_Call

type Collection_FindOneAndUpdate_Call struct {
	*mock.Call
}

Collection_FindOneAndUpdate_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindOneAndUpdate'

func (*Collection_FindOneAndUpdate_Call) Return

func (_c *Collection_FindOneAndUpdate_Call) Return(_a0 mongoifc.SingleResult) *Collection_FindOneAndUpdate_Call

func (*Collection_FindOneAndUpdate_Call) Run

func (_c *Collection_FindOneAndUpdate_Call) Run(run func(ctx context.Context, filter interface{}, update interface{}, opts ...*options.FindOneAndUpdateOptions)) *Collection_FindOneAndUpdate_Call

func (*Collection_FindOneAndUpdate_Call) RunAndReturn

func (_c *Collection_FindOneAndUpdate_Call) RunAndReturn(run func(context.Context, interface{}, interface{}, ...*options.FindOneAndUpdateOptions) mongoifc.SingleResult) *Collection_FindOneAndUpdate_Call

type Collection_FindOne_Call

type Collection_FindOne_Call struct {
	*mock.Call
}

Collection_FindOne_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindOne'

func (*Collection_FindOne_Call) Return

func (_c *Collection_FindOne_Call) Return(_a0 mongoifc.SingleResult) *Collection_FindOne_Call

func (*Collection_FindOne_Call) Run

func (_c *Collection_FindOne_Call) Run(run func(ctx context.Context, filter interface{}, opts ...*options.FindOneOptions)) *Collection_FindOne_Call

func (*Collection_FindOne_Call) RunAndReturn

func (_c *Collection_FindOne_Call) RunAndReturn(run func(context.Context, interface{}, ...*options.FindOneOptions) mongoifc.SingleResult) *Collection_FindOne_Call

type Collection_Find_Call

type Collection_Find_Call struct {
	*mock.Call
}

Collection_Find_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Find'

func (*Collection_Find_Call) Return

func (_c *Collection_Find_Call) Return(_a0 mongoifc.Cursor, _a1 error) *Collection_Find_Call

func (*Collection_Find_Call) Run

func (_c *Collection_Find_Call) Run(run func(ctx context.Context, filter interface{}, opts ...*options.FindOptions)) *Collection_Find_Call

func (*Collection_Find_Call) RunAndReturn

func (_c *Collection_Find_Call) RunAndReturn(run func(context.Context, interface{}, ...*options.FindOptions) (mongoifc.Cursor, error)) *Collection_Find_Call

type Collection_Indexes_Call

type Collection_Indexes_Call struct {
	*mock.Call
}

Collection_Indexes_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Indexes'

func (*Collection_Indexes_Call) Return

func (_c *Collection_Indexes_Call) Return(_a0 mongoifc.IndexView) *Collection_Indexes_Call

func (*Collection_Indexes_Call) Run

func (_c *Collection_Indexes_Call) Run(run func()) *Collection_Indexes_Call

func (*Collection_Indexes_Call) RunAndReturn

func (_c *Collection_Indexes_Call) RunAndReturn(run func() mongoifc.IndexView) *Collection_Indexes_Call

type Collection_InsertMany_Call

type Collection_InsertMany_Call struct {
	*mock.Call
}

Collection_InsertMany_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InsertMany'

func (*Collection_InsertMany_Call) Return

func (_c *Collection_InsertMany_Call) Return(_a0 *mongo.InsertManyResult, _a1 error) *Collection_InsertMany_Call

func (*Collection_InsertMany_Call) Run

func (_c *Collection_InsertMany_Call) Run(run func(ctx context.Context, documents []interface{}, opts ...*options.InsertManyOptions)) *Collection_InsertMany_Call

func (*Collection_InsertMany_Call) RunAndReturn

func (_c *Collection_InsertMany_Call) RunAndReturn(run func(context.Context, []interface{}, ...*options.InsertManyOptions) (*mongo.InsertManyResult, error)) *Collection_InsertMany_Call

type Collection_InsertOne_Call

type Collection_InsertOne_Call struct {
	*mock.Call
}

Collection_InsertOne_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InsertOne'

func (*Collection_InsertOne_Call) Return

func (_c *Collection_InsertOne_Call) Return(_a0 *mongo.InsertOneResult, _a1 error) *Collection_InsertOne_Call

func (*Collection_InsertOne_Call) Run

func (_c *Collection_InsertOne_Call) Run(run func(ctx context.Context, document interface{}, opts ...*options.InsertOneOptions)) *Collection_InsertOne_Call

func (*Collection_InsertOne_Call) RunAndReturn

func (_c *Collection_InsertOne_Call) RunAndReturn(run func(context.Context, interface{}, ...*options.InsertOneOptions) (*mongo.InsertOneResult, error)) *Collection_InsertOne_Call

type Collection_Name_Call

type Collection_Name_Call struct {
	*mock.Call
}

Collection_Name_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Name'

func (*Collection_Name_Call) Return

func (_c *Collection_Name_Call) Return(_a0 string) *Collection_Name_Call

func (*Collection_Name_Call) Run

func (_c *Collection_Name_Call) Run(run func()) *Collection_Name_Call

func (*Collection_Name_Call) RunAndReturn

func (_c *Collection_Name_Call) RunAndReturn(run func() string) *Collection_Name_Call

type Collection_ReplaceOne_Call

type Collection_ReplaceOne_Call struct {
	*mock.Call
}

Collection_ReplaceOne_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReplaceOne'

func (*Collection_ReplaceOne_Call) Return

func (_c *Collection_ReplaceOne_Call) Return(_a0 *mongo.UpdateResult, _a1 error) *Collection_ReplaceOne_Call

func (*Collection_ReplaceOne_Call) Run

func (_c *Collection_ReplaceOne_Call) Run(run func(ctx context.Context, filter interface{}, replacement interface{}, opts ...*options.ReplaceOptions)) *Collection_ReplaceOne_Call

func (*Collection_ReplaceOne_Call) RunAndReturn

func (_c *Collection_ReplaceOne_Call) RunAndReturn(run func(context.Context, interface{}, interface{}, ...*options.ReplaceOptions) (*mongo.UpdateResult, error)) *Collection_ReplaceOne_Call

type Collection_SearchIndexes_Call

type Collection_SearchIndexes_Call struct {
	*mock.Call
}

Collection_SearchIndexes_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SearchIndexes'

func (*Collection_SearchIndexes_Call) Return

func (_c *Collection_SearchIndexes_Call) Return(_a0 mongoifc.SearchIndexView) *Collection_SearchIndexes_Call

func (*Collection_SearchIndexes_Call) Run

func (_c *Collection_SearchIndexes_Call) Run(run func()) *Collection_SearchIndexes_Call

func (*Collection_SearchIndexes_Call) RunAndReturn

func (_c *Collection_SearchIndexes_Call) RunAndReturn(run func() mongoifc.SearchIndexView) *Collection_SearchIndexes_Call

type Collection_UpdateByID_Call

type Collection_UpdateByID_Call struct {
	*mock.Call
}

Collection_UpdateByID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateByID'

func (*Collection_UpdateByID_Call) Return

func (_c *Collection_UpdateByID_Call) Return(_a0 *mongo.UpdateResult, _a1 error) *Collection_UpdateByID_Call

func (*Collection_UpdateByID_Call) Run

func (_c *Collection_UpdateByID_Call) Run(run func(ctx context.Context, id interface{}, update interface{}, opts ...*options.UpdateOptions)) *Collection_UpdateByID_Call

func (*Collection_UpdateByID_Call) RunAndReturn

func (_c *Collection_UpdateByID_Call) RunAndReturn(run func(context.Context, interface{}, interface{}, ...*options.UpdateOptions) (*mongo.UpdateResult, error)) *Collection_UpdateByID_Call

type Collection_UpdateMany_Call

type Collection_UpdateMany_Call struct {
	*mock.Call
}

Collection_UpdateMany_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateMany'

func (*Collection_UpdateMany_Call) Return

func (_c *Collection_UpdateMany_Call) Return(_a0 *mongo.UpdateResult, _a1 error) *Collection_UpdateMany_Call

func (*Collection_UpdateMany_Call) Run

func (_c *Collection_UpdateMany_Call) Run(run func(ctx context.Context, filter interface{}, update interface{}, opts ...*options.UpdateOptions)) *Collection_UpdateMany_Call

func (*Collection_UpdateMany_Call) RunAndReturn

func (_c *Collection_UpdateMany_Call) RunAndReturn(run func(context.Context, interface{}, interface{}, ...*options.UpdateOptions) (*mongo.UpdateResult, error)) *Collection_UpdateMany_Call

type Collection_UpdateOne_Call

type Collection_UpdateOne_Call struct {
	*mock.Call
}

Collection_UpdateOne_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateOne'

func (*Collection_UpdateOne_Call) Return

func (_c *Collection_UpdateOne_Call) Return(_a0 *mongo.UpdateResult, _a1 error) *Collection_UpdateOne_Call

func (*Collection_UpdateOne_Call) Run

func (_c *Collection_UpdateOne_Call) Run(run func(ctx context.Context, filter interface{}, update interface{}, opts ...*options.UpdateOptions)) *Collection_UpdateOne_Call

func (*Collection_UpdateOne_Call) RunAndReturn

func (_c *Collection_UpdateOne_Call) RunAndReturn(run func(context.Context, interface{}, interface{}, ...*options.UpdateOptions) (*mongo.UpdateResult, error)) *Collection_UpdateOne_Call

type Collection_Watch_Call

type Collection_Watch_Call struct {
	*mock.Call
}

Collection_Watch_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Watch'

func (*Collection_Watch_Call) Return

func (_c *Collection_Watch_Call) Return(_a0 mongoifc.ChangeStream, _a1 error) *Collection_Watch_Call

func (*Collection_Watch_Call) Run

func (_c *Collection_Watch_Call) Run(run func(ctx context.Context, pipeline interface{}, opts ...*options.ChangeStreamOptions)) *Collection_Watch_Call

func (*Collection_Watch_Call) RunAndReturn

func (_c *Collection_Watch_Call) RunAndReturn(run func(context.Context, interface{}, ...*options.ChangeStreamOptions) (mongoifc.ChangeStream, error)) *Collection_Watch_Call

type Cursor

type Cursor struct {
	mock.Mock
}

Cursor is an autogenerated mock type for the Cursor type

func NewCursor

func NewCursor(t interface {
	mock.TestingT
	Cleanup(func())
}) *Cursor

NewCursor creates a new instance of Cursor. 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 (*Cursor) All

func (_m *Cursor) All(ctx context.Context, results interface{}) error

All provides a mock function with given fields: ctx, results

func (*Cursor) Close

func (_m *Cursor) Close(ctx context.Context) error

Close provides a mock function with given fields: ctx

func (*Cursor) Current

func (_m *Cursor) Current() bson.Raw

Current provides a mock function with given fields:

func (*Cursor) Decode

func (_m *Cursor) Decode(val interface{}) error

Decode provides a mock function with given fields: val

func (*Cursor) EXPECT

func (_m *Cursor) EXPECT() *Cursor_Expecter

func (*Cursor) Err

func (_m *Cursor) Err() error

Err provides a mock function with given fields:

func (*Cursor) ID

func (_m *Cursor) ID() int64

ID provides a mock function with given fields:

func (*Cursor) Next

func (_m *Cursor) Next(ctx context.Context) bool

Next provides a mock function with given fields: ctx

func (*Cursor) RemainingBatchLength

func (_m *Cursor) RemainingBatchLength() int

RemainingBatchLength provides a mock function with given fields:

func (*Cursor) SetBatchSize

func (_m *Cursor) SetBatchSize(batchSize int32)

SetBatchSize provides a mock function with given fields: batchSize

func (*Cursor) SetComment

func (_m *Cursor) SetComment(comment interface{})

SetComment provides a mock function with given fields: comment

func (*Cursor) SetMaxTime

func (_m *Cursor) SetMaxTime(dur time.Duration)

SetMaxTime provides a mock function with given fields: dur

func (*Cursor) TryNext

func (_m *Cursor) TryNext(ctx context.Context) bool

TryNext provides a mock function with given fields: ctx

type Cursor_All_Call

type Cursor_All_Call struct {
	*mock.Call
}

Cursor_All_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'All'

func (*Cursor_All_Call) Return

func (_c *Cursor_All_Call) Return(_a0 error) *Cursor_All_Call

func (*Cursor_All_Call) Run

func (_c *Cursor_All_Call) Run(run func(ctx context.Context, results interface{})) *Cursor_All_Call

func (*Cursor_All_Call) RunAndReturn

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

type Cursor_Close_Call

type Cursor_Close_Call struct {
	*mock.Call
}

Cursor_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'

func (*Cursor_Close_Call) Return

func (_c *Cursor_Close_Call) Return(_a0 error) *Cursor_Close_Call

func (*Cursor_Close_Call) Run

func (_c *Cursor_Close_Call) Run(run func(ctx context.Context)) *Cursor_Close_Call

func (*Cursor_Close_Call) RunAndReturn

func (_c *Cursor_Close_Call) RunAndReturn(run func(context.Context) error) *Cursor_Close_Call

type Cursor_Current_Call

type Cursor_Current_Call struct {
	*mock.Call
}

Cursor_Current_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Current'

func (*Cursor_Current_Call) Return

func (_c *Cursor_Current_Call) Return(_a0 bson.Raw) *Cursor_Current_Call

func (*Cursor_Current_Call) Run

func (_c *Cursor_Current_Call) Run(run func()) *Cursor_Current_Call

func (*Cursor_Current_Call) RunAndReturn

func (_c *Cursor_Current_Call) RunAndReturn(run func() bson.Raw) *Cursor_Current_Call

type Cursor_Decode_Call

type Cursor_Decode_Call struct {
	*mock.Call
}

Cursor_Decode_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Decode'

func (*Cursor_Decode_Call) Return

func (_c *Cursor_Decode_Call) Return(_a0 error) *Cursor_Decode_Call

func (*Cursor_Decode_Call) Run

func (_c *Cursor_Decode_Call) Run(run func(val interface{})) *Cursor_Decode_Call

func (*Cursor_Decode_Call) RunAndReturn

func (_c *Cursor_Decode_Call) RunAndReturn(run func(interface{}) error) *Cursor_Decode_Call

type Cursor_Err_Call

type Cursor_Err_Call struct {
	*mock.Call
}

Cursor_Err_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Err'

func (*Cursor_Err_Call) Return

func (_c *Cursor_Err_Call) Return(_a0 error) *Cursor_Err_Call

func (*Cursor_Err_Call) Run

func (_c *Cursor_Err_Call) Run(run func()) *Cursor_Err_Call

func (*Cursor_Err_Call) RunAndReturn

func (_c *Cursor_Err_Call) RunAndReturn(run func() error) *Cursor_Err_Call

type Cursor_Expecter

type Cursor_Expecter struct {
	// contains filtered or unexported fields
}

func (*Cursor_Expecter) All

func (_e *Cursor_Expecter) All(ctx interface{}, results interface{}) *Cursor_All_Call

All is a helper method to define mock.On call

• ctx context.Context
• results interface{}

func (*Cursor_Expecter) Close

func (_e *Cursor_Expecter) Close(ctx interface{}) *Cursor_Close_Call

Close is a helper method to define mock.On call

• ctx context.Context

func (*Cursor_Expecter) Current

func (_e *Cursor_Expecter) Current() *Cursor_Current_Call

Current is a helper method to define mock.On call

func (*Cursor_Expecter) Decode

func (_e *Cursor_Expecter) Decode(val interface{}) *Cursor_Decode_Call

Decode is a helper method to define mock.On call

• val interface{}

func (*Cursor_Expecter) Err

func (_e *Cursor_Expecter) Err() *Cursor_Err_Call

Err is a helper method to define mock.On call

func (*Cursor_Expecter) ID

func (_e *Cursor_Expecter) ID() *Cursor_ID_Call

ID is a helper method to define mock.On call

func (*Cursor_Expecter) Next

func (_e *Cursor_Expecter) Next(ctx interface{}) *Cursor_Next_Call

Next is a helper method to define mock.On call

• ctx context.Context

func (*Cursor_Expecter) RemainingBatchLength

func (_e *Cursor_Expecter) RemainingBatchLength() *Cursor_RemainingBatchLength_Call

RemainingBatchLength is a helper method to define mock.On call

func (*Cursor_Expecter) SetBatchSize

func (_e *Cursor_Expecter) SetBatchSize(batchSize interface{}) *Cursor_SetBatchSize_Call

SetBatchSize is a helper method to define mock.On call

• batchSize int32

func (*Cursor_Expecter) SetComment

func (_e *Cursor_Expecter) SetComment(comment interface{}) *Cursor_SetComment_Call

SetComment is a helper method to define mock.On call

• comment interface{}

func (*Cursor_Expecter) SetMaxTime

func (_e *Cursor_Expecter) SetMaxTime(dur interface{}) *Cursor_SetMaxTime_Call

SetMaxTime is a helper method to define mock.On call

• dur time.Duration

func (*Cursor_Expecter) TryNext

func (_e *Cursor_Expecter) TryNext(ctx interface{}) *Cursor_TryNext_Call

TryNext is a helper method to define mock.On call

• ctx context.Context

type Cursor_ID_Call

type Cursor_ID_Call struct {
	*mock.Call
}

Cursor_ID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ID'

func (*Cursor_ID_Call) Return

func (_c *Cursor_ID_Call) Return(_a0 int64) *Cursor_ID_Call

func (*Cursor_ID_Call) Run

func (_c *Cursor_ID_Call) Run(run func()) *Cursor_ID_Call

func (*Cursor_ID_Call) RunAndReturn

func (_c *Cursor_ID_Call) RunAndReturn(run func() int64) *Cursor_ID_Call

type Cursor_Next_Call

type Cursor_Next_Call struct {
	*mock.Call
}

Cursor_Next_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Next'

func (*Cursor_Next_Call) Return

func (_c *Cursor_Next_Call) Return(_a0 bool) *Cursor_Next_Call

func (*Cursor_Next_Call) Run

func (_c *Cursor_Next_Call) Run(run func(ctx context.Context)) *Cursor_Next_Call

func (*Cursor_Next_Call) RunAndReturn

func (_c *Cursor_Next_Call) RunAndReturn(run func(context.Context) bool) *Cursor_Next_Call

type Cursor_RemainingBatchLength_Call

type Cursor_RemainingBatchLength_Call struct {
	*mock.Call
}

Cursor_RemainingBatchLength_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RemainingBatchLength'

func (*Cursor_RemainingBatchLength_Call) Return

func (_c *Cursor_RemainingBatchLength_Call) Return(_a0 int) *Cursor_RemainingBatchLength_Call

func (*Cursor_RemainingBatchLength_Call) Run

func (_c *Cursor_RemainingBatchLength_Call) Run(run func()) *Cursor_RemainingBatchLength_Call

func (*Cursor_RemainingBatchLength_Call) RunAndReturn

func (_c *Cursor_RemainingBatchLength_Call) RunAndReturn(run func() int) *Cursor_RemainingBatchLength_Call

type Cursor_SetBatchSize_Call

type Cursor_SetBatchSize_Call struct {
	*mock.Call
}

Cursor_SetBatchSize_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetBatchSize'

func (*Cursor_SetBatchSize_Call) Return

func (_c *Cursor_SetBatchSize_Call) Return() *Cursor_SetBatchSize_Call

func (*Cursor_SetBatchSize_Call) Run

func (_c *Cursor_SetBatchSize_Call) Run(run func(batchSize int32)) *Cursor_SetBatchSize_Call

func (*Cursor_SetBatchSize_Call) RunAndReturn

func (_c *Cursor_SetBatchSize_Call) RunAndReturn(run func(int32)) *Cursor_SetBatchSize_Call

type Cursor_SetComment_Call

type Cursor_SetComment_Call struct {
	*mock.Call
}

Cursor_SetComment_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetComment'

func (*Cursor_SetComment_Call) Return

func (_c *Cursor_SetComment_Call) Return() *Cursor_SetComment_Call

func (*Cursor_SetComment_Call) Run

func (_c *Cursor_SetComment_Call) Run(run func(comment interface{})) *Cursor_SetComment_Call

func (*Cursor_SetComment_Call) RunAndReturn

func (_c *Cursor_SetComment_Call) RunAndReturn(run func(interface{})) *Cursor_SetComment_Call

type Cursor_SetMaxTime_Call

type Cursor_SetMaxTime_Call struct {
	*mock.Call
}

Cursor_SetMaxTime_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetMaxTime'

func (*Cursor_SetMaxTime_Call) Return

func (_c *Cursor_SetMaxTime_Call) Return() *Cursor_SetMaxTime_Call

func (*Cursor_SetMaxTime_Call) Run

func (_c *Cursor_SetMaxTime_Call) Run(run func(dur time.Duration)) *Cursor_SetMaxTime_Call

func (*Cursor_SetMaxTime_Call) RunAndReturn

func (_c *Cursor_SetMaxTime_Call) RunAndReturn(run func(time.Duration)) *Cursor_SetMaxTime_Call

type Cursor_TryNext_Call

type Cursor_TryNext_Call struct {
	*mock.Call
}

Cursor_TryNext_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TryNext'

func (*Cursor_TryNext_Call) Return

func (_c *Cursor_TryNext_Call) Return(_a0 bool) *Cursor_TryNext_Call

func (*Cursor_TryNext_Call) Run

func (_c *Cursor_TryNext_Call) Run(run func(ctx context.Context)) *Cursor_TryNext_Call

func (*Cursor_TryNext_Call) RunAndReturn

func (_c *Cursor_TryNext_Call) RunAndReturn(run func(context.Context) bool) *Cursor_TryNext_Call

type Database

type Database struct {
	mock.Mock
}

Database is an autogenerated mock type for the Database type

func NewDatabase

func NewDatabase(t interface {
	mock.TestingT
	Cleanup(func())
}) *Database

NewDatabase creates a new instance of Database. 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 (*Database) Aggregate

func (_m *Database) Aggregate(ctx context.Context, pipeline interface{}, opts ...*options.AggregateOptions) (mongoifc.Cursor, error)

Aggregate provides a mock function with given fields: ctx, pipeline, opts

func (*Database) Client

func (_m *Database) Client() mongoifc.Client

Client provides a mock function with given fields:

func (*Database) Collection

func (_m *Database) Collection(name string, opts ...*options.CollectionOptions) mongoifc.Collection

Collection provides a mock function with given fields: name, opts

func (*Database) CreateCollection

func (_m *Database) CreateCollection(ctx context.Context, name string, opts ...*options.CreateCollectionOptions) error

CreateCollection provides a mock function with given fields: ctx, name, opts

func (*Database) CreateView

func (_m *Database) CreateView(ctx context.Context, viewName string, viewOn string, pipeline interface{}, opts ...*options.CreateViewOptions) error

CreateView provides a mock function with given fields: ctx, viewName, viewOn, pipeline, opts

func (*Database) Drop

func (_m *Database) Drop(ctx context.Context) error

Drop provides a mock function with given fields: ctx

func (*Database) EXPECT

func (_m *Database) EXPECT() *Database_Expecter

func (*Database) ListCollectionNames

func (_m *Database) ListCollectionNames(ctx context.Context, filter interface{}, opts ...*options.ListCollectionsOptions) ([]string, error)

ListCollectionNames provides a mock function with given fields: ctx, filter, opts

func (*Database) ListCollectionSpecifications

func (_m *Database) ListCollectionSpecifications(ctx context.Context, filter interface{}, opts ...*options.ListCollectionsOptions) ([]*mongo.CollectionSpecification, error)

ListCollectionSpecifications provides a mock function with given fields: ctx, filter, opts

func (*Database) ListCollections

func (_m *Database) ListCollections(ctx context.Context, filter interface{}, opts ...*options.ListCollectionsOptions) (mongoifc.Cursor, error)

ListCollections provides a mock function with given fields: ctx, filter, opts

func (*Database) Name

func (_m *Database) Name() string

Name provides a mock function with given fields:

func (*Database) ReadConcern

func (_m *Database) ReadConcern() *readconcern.ReadConcern

ReadConcern provides a mock function with given fields:

func (*Database) ReadPreference

func (_m *Database) ReadPreference() *readpref.ReadPref

ReadPreference provides a mock function with given fields:

func (*Database) RunCommand

func (_m *Database) RunCommand(ctx context.Context, runCommand interface{}, opts ...*options.RunCmdOptions) mongoifc.SingleResult

RunCommand provides a mock function with given fields: ctx, runCommand, opts

func (*Database) RunCommandCursor

func (_m *Database) RunCommandCursor(ctx context.Context, runCommand interface{}, opts ...*options.RunCmdOptions) (mongoifc.Cursor, error)

RunCommandCursor provides a mock function with given fields: ctx, runCommand, opts

func (*Database) Watch

func (_m *Database) Watch(ctx context.Context, pipeline interface{}, opts ...*options.ChangeStreamOptions) (mongoifc.ChangeStream, error)

Watch provides a mock function with given fields: ctx, pipeline, opts

func (*Database) WriteConcern

func (_m *Database) WriteConcern() *writeconcern.WriteConcern

WriteConcern provides a mock function with given fields:

type Database_Aggregate_Call

type Database_Aggregate_Call struct {
	*mock.Call
}

Database_Aggregate_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Aggregate'

func (*Database_Aggregate_Call) Return

func (_c *Database_Aggregate_Call) Return(_a0 mongoifc.Cursor, _a1 error) *Database_Aggregate_Call

func (*Database_Aggregate_Call) Run

func (_c *Database_Aggregate_Call) Run(run func(ctx context.Context, pipeline interface{}, opts ...*options.AggregateOptions)) *Database_Aggregate_Call

func (*Database_Aggregate_Call) RunAndReturn

func (_c *Database_Aggregate_Call) RunAndReturn(run func(context.Context, interface{}, ...*options.AggregateOptions) (mongoifc.Cursor, error)) *Database_Aggregate_Call

type Database_Client_Call

type Database_Client_Call struct {
	*mock.Call
}

Database_Client_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Client'

func (*Database_Client_Call) Return

func (_c *Database_Client_Call) Return(_a0 mongoifc.Client) *Database_Client_Call

func (*Database_Client_Call) Run

func (_c *Database_Client_Call) Run(run func()) *Database_Client_Call

func (*Database_Client_Call) RunAndReturn

func (_c *Database_Client_Call) RunAndReturn(run func() mongoifc.Client) *Database_Client_Call

type Database_Collection_Call

type Database_Collection_Call struct {
	*mock.Call
}

Database_Collection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Collection'

func (*Database_Collection_Call) Return

func (_c *Database_Collection_Call) Return(_a0 mongoifc.Collection) *Database_Collection_Call

func (*Database_Collection_Call) Run

func (_c *Database_Collection_Call) Run(run func(name string, opts ...*options.CollectionOptions)) *Database_Collection_Call

func (*Database_Collection_Call) RunAndReturn

func (_c *Database_Collection_Call) RunAndReturn(run func(string, ...*options.CollectionOptions) mongoifc.Collection) *Database_Collection_Call

type Database_CreateCollection_Call

type Database_CreateCollection_Call struct {
	*mock.Call
}

Database_CreateCollection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateCollection'

func (*Database_CreateCollection_Call) Return

func (_c *Database_CreateCollection_Call) Return(_a0 error) *Database_CreateCollection_Call

func (*Database_CreateCollection_Call) Run

func (_c *Database_CreateCollection_Call) Run(run func(ctx context.Context, name string, opts ...*options.CreateCollectionOptions)) *Database_CreateCollection_Call

func (*Database_CreateCollection_Call) RunAndReturn

func (_c *Database_CreateCollection_Call) RunAndReturn(run func(context.Context, string, ...*options.CreateCollectionOptions) error) *Database_CreateCollection_Call

type Database_CreateView_Call

type Database_CreateView_Call struct {
	*mock.Call
}

Database_CreateView_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateView'

func (*Database_CreateView_Call) Return

func (_c *Database_CreateView_Call) Return(_a0 error) *Database_CreateView_Call

func (*Database_CreateView_Call) Run

func (_c *Database_CreateView_Call) Run(run func(ctx context.Context, viewName string, viewOn string, pipeline interface{}, opts ...*options.CreateViewOptions)) *Database_CreateView_Call

func (*Database_CreateView_Call) RunAndReturn

func (_c *Database_CreateView_Call) RunAndReturn(run func(context.Context, string, string, interface{}, ...*options.CreateViewOptions) error) *Database_CreateView_Call

type Database_Drop_Call

type Database_Drop_Call struct {
	*mock.Call
}

Database_Drop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Drop'

func (*Database_Drop_Call) Return

func (_c *Database_Drop_Call) Return(_a0 error) *Database_Drop_Call

func (*Database_Drop_Call) Run

func (_c *Database_Drop_Call) Run(run func(ctx context.Context)) *Database_Drop_Call

func (*Database_Drop_Call) RunAndReturn

func (_c *Database_Drop_Call) RunAndReturn(run func(context.Context) error) *Database_Drop_Call

type Database_Expecter

type Database_Expecter struct {
	// contains filtered or unexported fields
}

func (*Database_Expecter) Aggregate

func (_e *Database_Expecter) Aggregate(ctx interface{}, pipeline interface{}, opts ...interface{}) *Database_Aggregate_Call

Aggregate is a helper method to define mock.On call

• ctx context.Context
• pipeline interface{}
• opts ...*options.AggregateOptions

func (*Database_Expecter) Client

func (_e *Database_Expecter) Client() *Database_Client_Call

Client is a helper method to define mock.On call

func (*Database_Expecter) Collection

func (_e *Database_Expecter) Collection(name interface{}, opts ...interface{}) *Database_Collection_Call

Collection is a helper method to define mock.On call

• name string
• opts ...*options.CollectionOptions

func (*Database_Expecter) CreateCollection

func (_e *Database_Expecter) CreateCollection(ctx interface{}, name interface{}, opts ...interface{}) *Database_CreateCollection_Call

CreateCollection is a helper method to define mock.On call

• ctx context.Context
• name string
• opts ...*options.CreateCollectionOptions

func (*Database_Expecter) CreateView

func (_e *Database_Expecter) CreateView(ctx interface{}, viewName interface{}, viewOn interface{}, pipeline interface{}, opts ...interface{}) *Database_CreateView_Call

CreateView is a helper method to define mock.On call

• ctx context.Context
• viewName string
• viewOn string
• pipeline interface{}
• opts ...*options.CreateViewOptions

func (*Database_Expecter) Drop

func (_e *Database_Expecter) Drop(ctx interface{}) *Database_Drop_Call

Drop is a helper method to define mock.On call

• ctx context.Context

func (*Database_Expecter) ListCollectionNames

func (_e *Database_Expecter) ListCollectionNames(ctx interface{}, filter interface{}, opts ...interface{}) *Database_ListCollectionNames_Call

ListCollectionNames is a helper method to define mock.On call

• ctx context.Context
• filter interface{}
• opts ...*options.ListCollectionsOptions

func (*Database_Expecter) ListCollectionSpecifications

func (_e *Database_Expecter) ListCollectionSpecifications(ctx interface{}, filter interface{}, opts ...interface{}) *Database_ListCollectionSpecifications_Call

ListCollectionSpecifications is a helper method to define mock.On call

• ctx context.Context
• filter interface{}
• opts ...*options.ListCollectionsOptions

func (*Database_Expecter) ListCollections

func (_e *Database_Expecter) ListCollections(ctx interface{}, filter interface{}, opts ...interface{}) *Database_ListCollections_Call

ListCollections is a helper method to define mock.On call

• ctx context.Context
• filter interface{}
• opts ...*options.ListCollectionsOptions

func (*Database_Expecter) Name

func (_e *Database_Expecter) Name() *Database_Name_Call

Name is a helper method to define mock.On call

func (*Database_Expecter) ReadConcern

func (_e *Database_Expecter) ReadConcern() *Database_ReadConcern_Call

ReadConcern is a helper method to define mock.On call

func (*Database_Expecter) ReadPreference

func (_e *Database_Expecter) ReadPreference() *Database_ReadPreference_Call

ReadPreference is a helper method to define mock.On call

func (*Database_Expecter) RunCommand

func (_e *Database_Expecter) RunCommand(ctx interface{}, runCommand interface{}, opts ...interface{}) *Database_RunCommand_Call

RunCommand is a helper method to define mock.On call

• ctx context.Context
• runCommand interface{}
• opts ...*options.RunCmdOptions

func (*Database_Expecter) RunCommandCursor

func (_e *Database_Expecter) RunCommandCursor(ctx interface{}, runCommand interface{}, opts ...interface{}) *Database_RunCommandCursor_Call

RunCommandCursor is a helper method to define mock.On call

• ctx context.Context
• runCommand interface{}
• opts ...*options.RunCmdOptions

func (*Database_Expecter) Watch

func (_e *Database_Expecter) Watch(ctx interface{}, pipeline interface{}, opts ...interface{}) *Database_Watch_Call

Watch is a helper method to define mock.On call

• ctx context.Context
• pipeline interface{}
• opts ...*options.ChangeStreamOptions

func (*Database_Expecter) WriteConcern

func (_e *Database_Expecter) WriteConcern() *Database_WriteConcern_Call

WriteConcern is a helper method to define mock.On call

type Database_ListCollectionNames_Call

type Database_ListCollectionNames_Call struct {
	*mock.Call
}

Database_ListCollectionNames_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListCollectionNames'

func (*Database_ListCollectionNames_Call) Return

func (_c *Database_ListCollectionNames_Call) Return(_a0 []string, _a1 error) *Database_ListCollectionNames_Call

func (*Database_ListCollectionNames_Call) Run

func (_c *Database_ListCollectionNames_Call) Run(run func(ctx context.Context, filter interface{}, opts ...*options.ListCollectionsOptions)) *Database_ListCollectionNames_Call

func (*Database_ListCollectionNames_Call) RunAndReturn

func (_c *Database_ListCollectionNames_Call) RunAndReturn(run func(context.Context, interface{}, ...*options.ListCollectionsOptions) ([]string, error)) *Database_ListCollectionNames_Call

type Database_ListCollectionSpecifications_Call

type Database_ListCollectionSpecifications_Call struct {
	*mock.Call
}

Database_ListCollectionSpecifications_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListCollectionSpecifications'

func (*Database_ListCollectionSpecifications_Call) Return

func (_c *Database_ListCollectionSpecifications_Call) Return(_a0 []*mongo.CollectionSpecification, _a1 error) *Database_ListCollectionSpecifications_Call

func (*Database_ListCollectionSpecifications_Call) Run

func (_c *Database_ListCollectionSpecifications_Call) Run(run func(ctx context.Context, filter interface{}, opts ...*options.ListCollectionsOptions)) *Database_ListCollectionSpecifications_Call

func (*Database_ListCollectionSpecifications_Call) RunAndReturn

func (_c *Database_ListCollectionSpecifications_Call) RunAndReturn(run func(context.Context, interface{}, ...*options.ListCollectionsOptions) ([]*mongo.CollectionSpecification, error)) *Database_ListCollectionSpecifications_Call

type Database_ListCollections_Call

type Database_ListCollections_Call struct {
	*mock.Call
}

Database_ListCollections_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListCollections'

func (*Database_ListCollections_Call) Return

func (_c *Database_ListCollections_Call) Return(_a0 mongoifc.Cursor, _a1 error) *Database_ListCollections_Call

func (*Database_ListCollections_Call) Run

func (_c *Database_ListCollections_Call) Run(run func(ctx context.Context, filter interface{}, opts ...*options.ListCollectionsOptions)) *Database_ListCollections_Call

func (*Database_ListCollections_Call) RunAndReturn

func (_c *Database_ListCollections_Call) RunAndReturn(run func(context.Context, interface{}, ...*options.ListCollectionsOptions) (mongoifc.Cursor, error)) *Database_ListCollections_Call

type Database_Name_Call

type Database_Name_Call struct {
	*mock.Call
}

Database_Name_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Name'

func (*Database_Name_Call) Return

func (_c *Database_Name_Call) Return(_a0 string) *Database_Name_Call

func (*Database_Name_Call) Run

func (_c *Database_Name_Call) Run(run func()) *Database_Name_Call

func (*Database_Name_Call) RunAndReturn

func (_c *Database_Name_Call) RunAndReturn(run func() string) *Database_Name_Call

type Database_ReadConcern_Call

type Database_ReadConcern_Call struct {
	*mock.Call
}

Database_ReadConcern_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReadConcern'

func (*Database_ReadConcern_Call) Return

func (_c *Database_ReadConcern_Call) Return(_a0 *readconcern.ReadConcern) *Database_ReadConcern_Call

func (*Database_ReadConcern_Call) Run

func (_c *Database_ReadConcern_Call) Run(run func()) *Database_ReadConcern_Call

func (*Database_ReadConcern_Call) RunAndReturn

func (_c *Database_ReadConcern_Call) RunAndReturn(run func() *readconcern.ReadConcern) *Database_ReadConcern_Call

type Database_ReadPreference_Call

type Database_ReadPreference_Call struct {
	*mock.Call
}

Database_ReadPreference_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReadPreference'

func (*Database_ReadPreference_Call) Return

func (_c *Database_ReadPreference_Call) Return(_a0 *readpref.ReadPref) *Database_ReadPreference_Call

func (*Database_ReadPreference_Call) Run

func (_c *Database_ReadPreference_Call) Run(run func()) *Database_ReadPreference_Call

func (*Database_ReadPreference_Call) RunAndReturn

func (_c *Database_ReadPreference_Call) RunAndReturn(run func() *readpref.ReadPref) *Database_ReadPreference_Call

type Database_RunCommandCursor_Call

type Database_RunCommandCursor_Call struct {
	*mock.Call
}

Database_RunCommandCursor_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RunCommandCursor'

func (*Database_RunCommandCursor_Call) Return

func (_c *Database_RunCommandCursor_Call) Return(_a0 mongoifc.Cursor, _a1 error) *Database_RunCommandCursor_Call

func (*Database_RunCommandCursor_Call) Run

func (_c *Database_RunCommandCursor_Call) Run(run func(ctx context.Context, runCommand interface{}, opts ...*options.RunCmdOptions)) *Database_RunCommandCursor_Call

func (*Database_RunCommandCursor_Call) RunAndReturn

func (_c *Database_RunCommandCursor_Call) RunAndReturn(run func(context.Context, interface{}, ...*options.RunCmdOptions) (mongoifc.Cursor, error)) *Database_RunCommandCursor_Call

type Database_RunCommand_Call

type Database_RunCommand_Call struct {
	*mock.Call
}

Database_RunCommand_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RunCommand'

func (*Database_RunCommand_Call) Return

func (_c *Database_RunCommand_Call) Return(_a0 mongoifc.SingleResult) *Database_RunCommand_Call

func (*Database_RunCommand_Call) Run

func (_c *Database_RunCommand_Call) Run(run func(ctx context.Context, runCommand interface{}, opts ...*options.RunCmdOptions)) *Database_RunCommand_Call

func (*Database_RunCommand_Call) RunAndReturn

func (_c *Database_RunCommand_Call) RunAndReturn(run func(context.Context, interface{}, ...*options.RunCmdOptions) mongoifc.SingleResult) *Database_RunCommand_Call

type Database_Watch_Call

type Database_Watch_Call struct {
	*mock.Call
}

Database_Watch_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Watch'

func (*Database_Watch_Call) Return

func (_c *Database_Watch_Call) Return(_a0 mongoifc.ChangeStream, _a1 error) *Database_Watch_Call

func (*Database_Watch_Call) Run

func (_c *Database_Watch_Call) Run(run func(ctx context.Context, pipeline interface{}, opts ...*options.ChangeStreamOptions)) *Database_Watch_Call

func (*Database_Watch_Call) RunAndReturn

func (_c *Database_Watch_Call) RunAndReturn(run func(context.Context, interface{}, ...*options.ChangeStreamOptions) (mongoifc.ChangeStream, error)) *Database_Watch_Call

type Database_WriteConcern_Call

type Database_WriteConcern_Call struct {
	*mock.Call
}

Database_WriteConcern_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WriteConcern'

func (*Database_WriteConcern_Call) Return

func (_c *Database_WriteConcern_Call) Return(_a0 *writeconcern.WriteConcern) *Database_WriteConcern_Call

func (*Database_WriteConcern_Call) Run

func (_c *Database_WriteConcern_Call) Run(run func()) *Database_WriteConcern_Call

func (*Database_WriteConcern_Call) RunAndReturn

func (_c *Database_WriteConcern_Call) RunAndReturn(run func() *writeconcern.WriteConcern) *Database_WriteConcern_Call

type IndexView

type IndexView struct {
	mock.Mock
}

IndexView is an autogenerated mock type for the IndexView type

func NewIndexView

func NewIndexView(t interface {
	mock.TestingT
	Cleanup(func())
}) *IndexView

NewIndexView creates a new instance of IndexView. 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 (*IndexView) CreateMany

func (_m *IndexView) CreateMany(ctx context.Context, models []mongo.IndexModel, opts ...*options.CreateIndexesOptions) ([]string, error)

CreateMany provides a mock function with given fields: ctx, models, opts

func (*IndexView) CreateOne

func (_m *IndexView) CreateOne(ctx context.Context, model mongo.IndexModel, opts ...*options.CreateIndexesOptions) (string, error)

CreateOne provides a mock function with given fields: ctx, model, opts

func (*IndexView) DropAll

func (_m *IndexView) DropAll(ctx context.Context, opts ...*options.DropIndexesOptions) (bson.Raw, error)

DropAll provides a mock function with given fields: ctx, opts

func (*IndexView) DropOne

func (_m *IndexView) DropOne(ctx context.Context, name string, opts ...*options.DropIndexesOptions) (bson.Raw, error)

DropOne provides a mock function with given fields: ctx, name, opts

func (*IndexView) DropOneWithKey

func (_m *IndexView) DropOneWithKey(ctx context.Context, keySpecDocument interface{}, opts ...*options.DropIndexesOptions) (bson.Raw, error)

DropOneWithKey provides a mock function with given fields: ctx, keySpecDocument, opts

func (*IndexView) EXPECT

func (_m *IndexView) EXPECT() *IndexView_Expecter

func (*IndexView) List

func (_m *IndexView) List(ctx context.Context, opts ...*options.ListIndexesOptions) (mongoifc.Cursor, error)

List provides a mock function with given fields: ctx, opts

func (*IndexView) ListSpecifications

func (_m *IndexView) ListSpecifications(ctx context.Context, opts ...*options.ListIndexesOptions) ([]*mongo.IndexSpecification, error)

ListSpecifications provides a mock function with given fields: ctx, opts

type IndexView_CreateMany_Call

type IndexView_CreateMany_Call struct {
	*mock.Call
}

IndexView_CreateMany_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateMany'

func (*IndexView_CreateMany_Call) Return

func (_c *IndexView_CreateMany_Call) Return(_a0 []string, _a1 error) *IndexView_CreateMany_Call

func (*IndexView_CreateMany_Call) Run

func (_c *IndexView_CreateMany_Call) Run(run func(ctx context.Context, models []mongo.IndexModel, opts ...*options.CreateIndexesOptions)) *IndexView_CreateMany_Call

func (*IndexView_CreateMany_Call) RunAndReturn

func (_c *IndexView_CreateMany_Call) RunAndReturn(run func(context.Context, []mongo.IndexModel, ...*options.CreateIndexesOptions) ([]string, error)) *IndexView_CreateMany_Call

type IndexView_CreateOne_Call

type IndexView_CreateOne_Call struct {
	*mock.Call
}

IndexView_CreateOne_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateOne'

func (*IndexView_CreateOne_Call) Return

func (_c *IndexView_CreateOne_Call) Return(_a0 string, _a1 error) *IndexView_CreateOne_Call

func (*IndexView_CreateOne_Call) Run

func (_c *IndexView_CreateOne_Call) Run(run func(ctx context.Context, model mongo.IndexModel, opts ...*options.CreateIndexesOptions)) *IndexView_CreateOne_Call

func (*IndexView_CreateOne_Call) RunAndReturn

func (_c *IndexView_CreateOne_Call) RunAndReturn(run func(context.Context, mongo.IndexModel, ...*options.CreateIndexesOptions) (string, error)) *IndexView_CreateOne_Call

type IndexView_DropAll_Call

type IndexView_DropAll_Call struct {
	*mock.Call
}

IndexView_DropAll_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DropAll'

func (*IndexView_DropAll_Call) Return

func (_c *IndexView_DropAll_Call) Return(_a0 bson.Raw, _a1 error) *IndexView_DropAll_Call

func (*IndexView_DropAll_Call) Run

func (_c *IndexView_DropAll_Call) Run(run func(ctx context.Context, opts ...*options.DropIndexesOptions)) *IndexView_DropAll_Call

func (*IndexView_DropAll_Call) RunAndReturn

func (_c *IndexView_DropAll_Call) RunAndReturn(run func(context.Context, ...*options.DropIndexesOptions) (bson.Raw, error)) *IndexView_DropAll_Call

type IndexView_DropOneWithKey_Call

type IndexView_DropOneWithKey_Call struct {
	*mock.Call
}

IndexView_DropOneWithKey_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DropOneWithKey'

func (*IndexView_DropOneWithKey_Call) Return

func (_c *IndexView_DropOneWithKey_Call) Return(_a0 bson.Raw, _a1 error) *IndexView_DropOneWithKey_Call

func (*IndexView_DropOneWithKey_Call) Run

func (_c *IndexView_DropOneWithKey_Call) Run(run func(ctx context.Context, keySpecDocument interface{}, opts ...*options.DropIndexesOptions)) *IndexView_DropOneWithKey_Call

func (*IndexView_DropOneWithKey_Call) RunAndReturn

func (_c *IndexView_DropOneWithKey_Call) RunAndReturn(run func(context.Context, interface{}, ...*options.DropIndexesOptions) (bson.Raw, error)) *IndexView_DropOneWithKey_Call

type IndexView_DropOne_Call

type IndexView_DropOne_Call struct {
	*mock.Call
}

IndexView_DropOne_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DropOne'

func (*IndexView_DropOne_Call) Return

func (_c *IndexView_DropOne_Call) Return(_a0 bson.Raw, _a1 error) *IndexView_DropOne_Call

func (*IndexView_DropOne_Call) Run

func (_c *IndexView_DropOne_Call) Run(run func(ctx context.Context, name string, opts ...*options.DropIndexesOptions)) *IndexView_DropOne_Call

func (*IndexView_DropOne_Call) RunAndReturn

func (_c *IndexView_DropOne_Call) RunAndReturn(run func(context.Context, string, ...*options.DropIndexesOptions) (bson.Raw, error)) *IndexView_DropOne_Call

type IndexView_Expecter

type IndexView_Expecter struct {
	// contains filtered or unexported fields
}

func (*IndexView_Expecter) CreateMany

func (_e *IndexView_Expecter) CreateMany(ctx interface{}, models interface{}, opts ...interface{}) *IndexView_CreateMany_Call

CreateMany is a helper method to define mock.On call

• ctx context.Context
• models []mongo.IndexModel
• opts ...*options.CreateIndexesOptions

func (*IndexView_Expecter) CreateOne

func (_e *IndexView_Expecter) CreateOne(ctx interface{}, model interface{}, opts ...interface{}) *IndexView_CreateOne_Call

CreateOne is a helper method to define mock.On call

• ctx context.Context
• model mongo.IndexModel
• opts ...*options.CreateIndexesOptions

func (*IndexView_Expecter) DropAll

func (_e *IndexView_Expecter) DropAll(ctx interface{}, opts ...interface{}) *IndexView_DropAll_Call

DropAll is a helper method to define mock.On call

• ctx context.Context
• opts ...*options.DropIndexesOptions

func (*IndexView_Expecter) DropOne

func (_e *IndexView_Expecter) DropOne(ctx interface{}, name interface{}, opts ...interface{}) *IndexView_DropOne_Call

DropOne is a helper method to define mock.On call

• ctx context.Context
• name string
• opts ...*options.DropIndexesOptions

func (*IndexView_Expecter) DropOneWithKey

func (_e *IndexView_Expecter) DropOneWithKey(ctx interface{}, keySpecDocument interface{}, opts ...interface{}) *IndexView_DropOneWithKey_Call

DropOneWithKey is a helper method to define mock.On call

• ctx context.Context
• keySpecDocument interface{}
• opts ...*options.DropIndexesOptions

func (*IndexView_Expecter) List

func (_e *IndexView_Expecter) List(ctx interface{}, opts ...interface{}) *IndexView_List_Call

List is a helper method to define mock.On call

• ctx context.Context
• opts ...*options.ListIndexesOptions

func (*IndexView_Expecter) ListSpecifications

func (_e *IndexView_Expecter) ListSpecifications(ctx interface{}, opts ...interface{}) *IndexView_ListSpecifications_Call

ListSpecifications is a helper method to define mock.On call

• ctx context.Context
• opts ...*options.ListIndexesOptions

type IndexView_ListSpecifications_Call

type IndexView_ListSpecifications_Call struct {
	*mock.Call
}

IndexView_ListSpecifications_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListSpecifications'

func (*IndexView_ListSpecifications_Call) Return

func (_c *IndexView_ListSpecifications_Call) Return(_a0 []*mongo.IndexSpecification, _a1 error) *IndexView_ListSpecifications_Call

func (*IndexView_ListSpecifications_Call) Run

func (_c *IndexView_ListSpecifications_Call) Run(run func(ctx context.Context, opts ...*options.ListIndexesOptions)) *IndexView_ListSpecifications_Call

func (*IndexView_ListSpecifications_Call) RunAndReturn

func (_c *IndexView_ListSpecifications_Call) RunAndReturn(run func(context.Context, ...*options.ListIndexesOptions) ([]*mongo.IndexSpecification, error)) *IndexView_ListSpecifications_Call

type IndexView_List_Call

type IndexView_List_Call struct {
	*mock.Call
}

IndexView_List_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'List'

func (*IndexView_List_Call) Return

func (_c *IndexView_List_Call) Return(_a0 mongoifc.Cursor, _a1 error) *IndexView_List_Call

func (*IndexView_List_Call) Run

func (_c *IndexView_List_Call) Run(run func(ctx context.Context, opts ...*options.ListIndexesOptions)) *IndexView_List_Call

func (*IndexView_List_Call) RunAndReturn

func (_c *IndexView_List_Call) RunAndReturn(run func(context.Context, ...*options.ListIndexesOptions) (mongoifc.Cursor, error)) *IndexView_List_Call

type SearchIndexView

type SearchIndexView struct {
	mock.Mock
}

SearchIndexView is an autogenerated mock type for the SearchIndexView type

func NewSearchIndexView

func NewSearchIndexView(t interface {
	mock.TestingT
	Cleanup(func())
}) *SearchIndexView

NewSearchIndexView creates a new instance of SearchIndexView. 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 (*SearchIndexView) CreateMany

func (_m *SearchIndexView) CreateMany(ctx context.Context, models []mongo.SearchIndexModel, opts ...*options.CreateSearchIndexesOptions) ([]string, error)

CreateMany provides a mock function with given fields: ctx, models, opts

func (*SearchIndexView) CreateOne

func (_m *SearchIndexView) CreateOne(ctx context.Context, model mongo.SearchIndexModel, opts ...*options.CreateSearchIndexesOptions) (string, error)

CreateOne provides a mock function with given fields: ctx, model, opts

func (*SearchIndexView) DropOne

func (_m *SearchIndexView) DropOne(ctx context.Context, name string, opts ...*options.DropSearchIndexOptions) error

DropOne provides a mock function with given fields: ctx, name, opts

func (*SearchIndexView) EXPECT

func (_m *SearchIndexView) EXPECT() *SearchIndexView_Expecter

func (*SearchIndexView) List

func (_m *SearchIndexView) List(ctx context.Context, searchIdxOpts *options.SearchIndexesOptions, opts ...*options.ListSearchIndexesOptions) (mongoifc.Cursor, error)

List provides a mock function with given fields: ctx, searchIdxOpts, opts

func (*SearchIndexView) UpdateOne

func (_m *SearchIndexView) UpdateOne(ctx context.Context, name string, definition interface{}, opts ...*options.UpdateSearchIndexOptions) error

UpdateOne provides a mock function with given fields: ctx, name, definition, opts

type SearchIndexView_CreateMany_Call

type SearchIndexView_CreateMany_Call struct {
	*mock.Call
}

SearchIndexView_CreateMany_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateMany'

func (*SearchIndexView_CreateMany_Call) Return

func (_c *SearchIndexView_CreateMany_Call) Return(_a0 []string, _a1 error) *SearchIndexView_CreateMany_Call

func (*SearchIndexView_CreateMany_Call) Run

func (_c *SearchIndexView_CreateMany_Call) Run(run func(ctx context.Context, models []mongo.SearchIndexModel, opts ...*options.CreateSearchIndexesOptions)) *SearchIndexView_CreateMany_Call

func (*SearchIndexView_CreateMany_Call) RunAndReturn

func (_c *SearchIndexView_CreateMany_Call) RunAndReturn(run func(context.Context, []mongo.SearchIndexModel, ...*options.CreateSearchIndexesOptions) ([]string, error)) *SearchIndexView_CreateMany_Call

type SearchIndexView_CreateOne_Call

type SearchIndexView_CreateOne_Call struct {
	*mock.Call
}

SearchIndexView_CreateOne_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateOne'

func (*SearchIndexView_CreateOne_Call) Return

func (_c *SearchIndexView_CreateOne_Call) Return(_a0 string, _a1 error) *SearchIndexView_CreateOne_Call

func (*SearchIndexView_CreateOne_Call) Run

func (_c *SearchIndexView_CreateOne_Call) Run(run func(ctx context.Context, model mongo.SearchIndexModel, opts ...*options.CreateSearchIndexesOptions)) *SearchIndexView_CreateOne_Call

func (*SearchIndexView_CreateOne_Call) RunAndReturn

func (_c *SearchIndexView_CreateOne_Call) RunAndReturn(run func(context.Context, mongo.SearchIndexModel, ...*options.CreateSearchIndexesOptions) (string, error)) *SearchIndexView_CreateOne_Call

type SearchIndexView_DropOne_Call

type SearchIndexView_DropOne_Call struct {
	*mock.Call
}

SearchIndexView_DropOne_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DropOne'

func (*SearchIndexView_DropOne_Call) Return

func (_c *SearchIndexView_DropOne_Call) Return(_a0 error) *SearchIndexView_DropOne_Call

func (*SearchIndexView_DropOne_Call) Run

func (_c *SearchIndexView_DropOne_Call) Run(run func(ctx context.Context, name string, opts ...*options.DropSearchIndexOptions)) *SearchIndexView_DropOne_Call

func (*SearchIndexView_DropOne_Call) RunAndReturn

func (_c *SearchIndexView_DropOne_Call) RunAndReturn(run func(context.Context, string, ...*options.DropSearchIndexOptions) error) *SearchIndexView_DropOne_Call

type SearchIndexView_Expecter

type SearchIndexView_Expecter struct {
	// contains filtered or unexported fields
}

func (*SearchIndexView_Expecter) CreateMany

func (_e *SearchIndexView_Expecter) CreateMany(ctx interface{}, models interface{}, opts ...interface{}) *SearchIndexView_CreateMany_Call

CreateMany is a helper method to define mock.On call

• ctx context.Context
• models []mongo.SearchIndexModel
• opts ...*options.CreateSearchIndexesOptions

func (*SearchIndexView_Expecter) CreateOne

func (_e *SearchIndexView_Expecter) CreateOne(ctx interface{}, model interface{}, opts ...interface{}) *SearchIndexView_CreateOne_Call

CreateOne is a helper method to define mock.On call

• ctx context.Context
• model mongo.SearchIndexModel
• opts ...*options.CreateSearchIndexesOptions

func (*SearchIndexView_Expecter) DropOne

func (_e *SearchIndexView_Expecter) DropOne(ctx interface{}, name interface{}, opts ...interface{}) *SearchIndexView_DropOne_Call

DropOne is a helper method to define mock.On call

• ctx context.Context
• name string
• opts ...*options.DropSearchIndexOptions

func (*SearchIndexView_Expecter) List

func (_e *SearchIndexView_Expecter) List(ctx interface{}, searchIdxOpts interface{}, opts ...interface{}) *SearchIndexView_List_Call

List is a helper method to define mock.On call

• ctx context.Context
• searchIdxOpts *options.SearchIndexesOptions
• opts ...*options.ListSearchIndexesOptions

func (*SearchIndexView_Expecter) UpdateOne

func (_e *SearchIndexView_Expecter) UpdateOne(ctx interface{}, name interface{}, definition interface{}, opts ...interface{}) *SearchIndexView_UpdateOne_Call

UpdateOne is a helper method to define mock.On call

• ctx context.Context
• name string
• definition interface{}
• opts ...*options.UpdateSearchIndexOptions

type SearchIndexView_List_Call

type SearchIndexView_List_Call struct {
	*mock.Call
}

SearchIndexView_List_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'List'

func (*SearchIndexView_List_Call) Return

func (_c *SearchIndexView_List_Call) Return(_a0 mongoifc.Cursor, _a1 error) *SearchIndexView_List_Call

func (*SearchIndexView_List_Call) Run

func (_c *SearchIndexView_List_Call) Run(run func(ctx context.Context, searchIdxOpts *options.SearchIndexesOptions, opts ...*options.ListSearchIndexesOptions)) *SearchIndexView_List_Call

func (*SearchIndexView_List_Call) RunAndReturn

func (_c *SearchIndexView_List_Call) RunAndReturn(run func(context.Context, *options.SearchIndexesOptions, ...*options.ListSearchIndexesOptions) (mongoifc.Cursor, error)) *SearchIndexView_List_Call

type SearchIndexView_UpdateOne_Call

type SearchIndexView_UpdateOne_Call struct {
	*mock.Call
}

SearchIndexView_UpdateOne_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateOne'

func (*SearchIndexView_UpdateOne_Call) Return

func (_c *SearchIndexView_UpdateOne_Call) Return(_a0 error) *SearchIndexView_UpdateOne_Call

func (*SearchIndexView_UpdateOne_Call) Run

func (_c *SearchIndexView_UpdateOne_Call) Run(run func(ctx context.Context, name string, definition interface{}, opts ...*options.UpdateSearchIndexOptions)) *SearchIndexView_UpdateOne_Call

func (*SearchIndexView_UpdateOne_Call) RunAndReturn

func (_c *SearchIndexView_UpdateOne_Call) RunAndReturn(run func(context.Context, string, interface{}, ...*options.UpdateSearchIndexOptions) error) *SearchIndexView_UpdateOne_Call

type Session

type Session struct {
	mock.Mock
}

Session is an autogenerated mock type for the Session type

func NewSession

func NewSession(t interface {
	mock.TestingT
	Cleanup(func())
}) *Session

NewSession creates a new instance of Session. 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 (*Session) AbortTransaction

func (_m *Session) AbortTransaction(ctx context.Context) error

AbortTransaction provides a mock function with given fields: ctx

func (*Session) AdvanceClusterTime

func (_m *Session) AdvanceClusterTime(_a0 bson.Raw) error

AdvanceClusterTime provides a mock function with given fields: _a0

func (*Session) AdvanceOperationTime

func (_m *Session) AdvanceOperationTime(_a0 *primitive.Timestamp) error

AdvanceOperationTime provides a mock function with given fields: _a0

func (*Session) Client

func (_m *Session) Client() mongoifc.Client

Client provides a mock function with given fields:

func (*Session) ClusterTime

func (_m *Session) ClusterTime() bson.Raw

ClusterTime provides a mock function with given fields:

func (*Session) CommitTransaction

func (_m *Session) CommitTransaction(ctx context.Context) error

CommitTransaction provides a mock function with given fields: ctx

func (*Session) EXPECT

func (_m *Session) EXPECT() *Session_Expecter

func (*Session) EndSession

func (_m *Session) EndSession(ctx context.Context)

EndSession provides a mock function with given fields: ctx

func (*Session) ID

func (_m *Session) ID() bson.Raw

ID provides a mock function with given fields:

func (*Session) OperationTime

func (_m *Session) OperationTime() *primitive.Timestamp

OperationTime provides a mock function with given fields:

func (*Session) StartTransaction

func (_m *Session) StartTransaction(opts ...*options.TransactionOptions) error

StartTransaction provides a mock function with given fields: opts

func (*Session) WithTransaction

func (_m *Session) WithTransaction(ctx context.Context, fn func(mongoifc.SessionContext) (interface{}, error), opts ...*options.TransactionOptions) (interface{}, error)

WithTransaction provides a mock function with given fields: ctx, fn, opts

type SessionContext

type SessionContext struct {
	mock.Mock
}

SessionContext is an autogenerated mock type for the SessionContext type

func NewSessionContext

func NewSessionContext(t interface {
	mock.TestingT
	Cleanup(func())
}) *SessionContext

NewSessionContext creates a new instance of SessionContext. 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 (*SessionContext) AbortTransaction

func (_m *SessionContext) AbortTransaction(ctx context.Context) error

AbortTransaction provides a mock function with given fields: ctx

func (*SessionContext) AdvanceClusterTime

func (_m *SessionContext) AdvanceClusterTime(_a0 bson.Raw) error

AdvanceClusterTime provides a mock function with given fields: _a0

func (*SessionContext) AdvanceOperationTime

func (_m *SessionContext) AdvanceOperationTime(_a0 *primitive.Timestamp) error

AdvanceOperationTime provides a mock function with given fields: _a0

func (*SessionContext) Client

func (_m *SessionContext) Client() mongoifc.Client

Client provides a mock function with given fields:

func (*SessionContext) ClusterTime

func (_m *SessionContext) ClusterTime() bson.Raw

ClusterTime provides a mock function with given fields:

func (*SessionContext) CommitTransaction

func (_m *SessionContext) CommitTransaction(ctx context.Context) error

CommitTransaction provides a mock function with given fields: ctx

func (*SessionContext) Deadline

func (_m *SessionContext) Deadline() (time.Time, bool)

Deadline provides a mock function with given fields:

func (*SessionContext) Done

func (_m *SessionContext) Done() <-chan struct{}

Done provides a mock function with given fields:

func (*SessionContext) EXPECT

func (_m *SessionContext) EXPECT() *SessionContext_Expecter

func (*SessionContext) EndSession

func (_m *SessionContext) EndSession(ctx context.Context)

EndSession provides a mock function with given fields: ctx

func (*SessionContext) Err

func (_m *SessionContext) Err() error

Err provides a mock function with given fields:

func (*SessionContext) ID

func (_m *SessionContext) ID() bson.Raw

ID provides a mock function with given fields:

func (*SessionContext) OperationTime

func (_m *SessionContext) OperationTime() *primitive.Timestamp

OperationTime provides a mock function with given fields:

func (*SessionContext) StartTransaction

func (_m *SessionContext) StartTransaction(opts ...*options.TransactionOptions) error

StartTransaction provides a mock function with given fields: opts

func (*SessionContext) Value

func (_m *SessionContext) Value(key interface{}) interface{}

Value provides a mock function with given fields: key

func (*SessionContext) WithTransaction

func (_m *SessionContext) WithTransaction(ctx context.Context, fn func(mongoifc.SessionContext) (interface{}, error), opts ...*options.TransactionOptions) (interface{}, error)

WithTransaction provides a mock function with given fields: ctx, fn, opts

type SessionContext_AbortTransaction_Call

type SessionContext_AbortTransaction_Call struct {
	*mock.Call
}

SessionContext_AbortTransaction_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AbortTransaction'

func (*SessionContext_AbortTransaction_Call) Return

func (_c *SessionContext_AbortTransaction_Call) Return(_a0 error) *SessionContext_AbortTransaction_Call

func (*SessionContext_AbortTransaction_Call) Run

func (_c *SessionContext_AbortTransaction_Call) Run(run func(ctx context.Context)) *SessionContext_AbortTransaction_Call

func (*SessionContext_AbortTransaction_Call) RunAndReturn

func (_c *SessionContext_AbortTransaction_Call) RunAndReturn(run func(context.Context) error) *SessionContext_AbortTransaction_Call

type SessionContext_AdvanceClusterTime_Call

type SessionContext_AdvanceClusterTime_Call struct {
	*mock.Call
}

SessionContext_AdvanceClusterTime_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AdvanceClusterTime'

func (*SessionContext_AdvanceClusterTime_Call) Return

func (_c *SessionContext_AdvanceClusterTime_Call) Return(_a0 error) *SessionContext_AdvanceClusterTime_Call

func (*SessionContext_AdvanceClusterTime_Call) Run

func (_c *SessionContext_AdvanceClusterTime_Call) Run(run func(_a0 bson.Raw)) *SessionContext_AdvanceClusterTime_Call

func (*SessionContext_AdvanceClusterTime_Call) RunAndReturn

func (_c *SessionContext_AdvanceClusterTime_Call) RunAndReturn(run func(bson.Raw) error) *SessionContext_AdvanceClusterTime_Call

type SessionContext_AdvanceOperationTime_Call

type SessionContext_AdvanceOperationTime_Call struct {
	*mock.Call
}

SessionContext_AdvanceOperationTime_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AdvanceOperationTime'

func (*SessionContext_AdvanceOperationTime_Call) Return

func (_c *SessionContext_AdvanceOperationTime_Call) Return(_a0 error) *SessionContext_AdvanceOperationTime_Call

func (*SessionContext_AdvanceOperationTime_Call) Run

func (_c *SessionContext_AdvanceOperationTime_Call) Run(run func(_a0 *primitive.Timestamp)) *SessionContext_AdvanceOperationTime_Call

func (*SessionContext_AdvanceOperationTime_Call) RunAndReturn

func (_c *SessionContext_AdvanceOperationTime_Call) RunAndReturn(run func(*primitive.Timestamp) error) *SessionContext_AdvanceOperationTime_Call

type SessionContext_Client_Call

type SessionContext_Client_Call struct {
	*mock.Call
}

SessionContext_Client_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Client'

func (*SessionContext_Client_Call) Return

func (_c *SessionContext_Client_Call) Return(_a0 mongoifc.Client) *SessionContext_Client_Call

func (*SessionContext_Client_Call) Run

func (_c *SessionContext_Client_Call) Run(run func()) *SessionContext_Client_Call

func (*SessionContext_Client_Call) RunAndReturn

func (_c *SessionContext_Client_Call) RunAndReturn(run func() mongoifc.Client) *SessionContext_Client_Call

type SessionContext_ClusterTime_Call

type SessionContext_ClusterTime_Call struct {
	*mock.Call
}

SessionContext_ClusterTime_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ClusterTime'

func (*SessionContext_ClusterTime_Call) Return

func (_c *SessionContext_ClusterTime_Call) Return(_a0 bson.Raw) *SessionContext_ClusterTime_Call

func (*SessionContext_ClusterTime_Call) Run

func (_c *SessionContext_ClusterTime_Call) Run(run func()) *SessionContext_ClusterTime_Call

func (*SessionContext_ClusterTime_Call) RunAndReturn

func (_c *SessionContext_ClusterTime_Call) RunAndReturn(run func() bson.Raw) *SessionContext_ClusterTime_Call

type SessionContext_CommitTransaction_Call

type SessionContext_CommitTransaction_Call struct {
	*mock.Call
}

SessionContext_CommitTransaction_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CommitTransaction'

func (*SessionContext_CommitTransaction_Call) Return

func (_c *SessionContext_CommitTransaction_Call) Return(_a0 error) *SessionContext_CommitTransaction_Call

func (*SessionContext_CommitTransaction_Call) Run

func (_c *SessionContext_CommitTransaction_Call) Run(run func(ctx context.Context)) *SessionContext_CommitTransaction_Call

func (*SessionContext_CommitTransaction_Call) RunAndReturn

func (_c *SessionContext_CommitTransaction_Call) RunAndReturn(run func(context.Context) error) *SessionContext_CommitTransaction_Call

type SessionContext_Deadline_Call

type SessionContext_Deadline_Call struct {
	*mock.Call
}

SessionContext_Deadline_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Deadline'

func (*SessionContext_Deadline_Call) Return

func (_c *SessionContext_Deadline_Call) Return(deadline time.Time, ok bool) *SessionContext_Deadline_Call

func (*SessionContext_Deadline_Call) Run

func (_c *SessionContext_Deadline_Call) Run(run func()) *SessionContext_Deadline_Call

func (*SessionContext_Deadline_Call) RunAndReturn

func (_c *SessionContext_Deadline_Call) RunAndReturn(run func() (time.Time, bool)) *SessionContext_Deadline_Call

type SessionContext_Done_Call

type SessionContext_Done_Call struct {
	*mock.Call
}

SessionContext_Done_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Done'

func (*SessionContext_Done_Call) Return

func (_c *SessionContext_Done_Call) Return(_a0 <-chan struct{}) *SessionContext_Done_Call

func (*SessionContext_Done_Call) Run

func (_c *SessionContext_Done_Call) Run(run func()) *SessionContext_Done_Call

func (*SessionContext_Done_Call) RunAndReturn

func (_c *SessionContext_Done_Call) RunAndReturn(run func() <-chan struct{}) *SessionContext_Done_Call

type SessionContext_EndSession_Call

type SessionContext_EndSession_Call struct {
	*mock.Call
}

SessionContext_EndSession_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'EndSession'

func (*SessionContext_EndSession_Call) Return

func (_c *SessionContext_EndSession_Call) Return() *SessionContext_EndSession_Call

func (*SessionContext_EndSession_Call) Run

func (_c *SessionContext_EndSession_Call) Run(run func(ctx context.Context)) *SessionContext_EndSession_Call

func (*SessionContext_EndSession_Call) RunAndReturn

func (_c *SessionContext_EndSession_Call) RunAndReturn(run func(context.Context)) *SessionContext_EndSession_Call

type SessionContext_Err_Call

type SessionContext_Err_Call struct {
	*mock.Call
}

SessionContext_Err_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Err'

func (*SessionContext_Err_Call) Return

func (_c *SessionContext_Err_Call) Return(_a0 error) *SessionContext_Err_Call

func (*SessionContext_Err_Call) Run

func (_c *SessionContext_Err_Call) Run(run func()) *SessionContext_Err_Call

func (*SessionContext_Err_Call) RunAndReturn

func (_c *SessionContext_Err_Call) RunAndReturn(run func() error) *SessionContext_Err_Call

type SessionContext_Expecter

type SessionContext_Expecter struct {
	// contains filtered or unexported fields
}

func (*SessionContext_Expecter) AbortTransaction

func (_e *SessionContext_Expecter) AbortTransaction(ctx interface{}) *SessionContext_AbortTransaction_Call

AbortTransaction is a helper method to define mock.On call

• ctx context.Context

func (*SessionContext_Expecter) AdvanceClusterTime

func (_e *SessionContext_Expecter) AdvanceClusterTime(_a0 interface{}) *SessionContext_AdvanceClusterTime_Call

AdvanceClusterTime is a helper method to define mock.On call

• _a0 bson.Raw

func (*SessionContext_Expecter) AdvanceOperationTime

func (_e *SessionContext_Expecter) AdvanceOperationTime(_a0 interface{}) *SessionContext_AdvanceOperationTime_Call

AdvanceOperationTime is a helper method to define mock.On call

• _a0 *primitive.Timestamp

func (*SessionContext_Expecter) Client

func (_e *SessionContext_Expecter) Client() *SessionContext_Client_Call

Client is a helper method to define mock.On call

func (*SessionContext_Expecter) ClusterTime

func (_e *SessionContext_Expecter) ClusterTime() *SessionContext_ClusterTime_Call

ClusterTime is a helper method to define mock.On call

func (*SessionContext_Expecter) CommitTransaction

func (_e *SessionContext_Expecter) CommitTransaction(ctx interface{}) *SessionContext_CommitTransaction_Call

CommitTransaction is a helper method to define mock.On call

• ctx context.Context

func (*SessionContext_Expecter) Deadline

func (_e *SessionContext_Expecter) Deadline() *SessionContext_Deadline_Call

Deadline is a helper method to define mock.On call

func (*SessionContext_Expecter) Done

func (_e *SessionContext_Expecter) Done() *SessionContext_Done_Call

Done is a helper method to define mock.On call

func (*SessionContext_Expecter) EndSession

func (_e *SessionContext_Expecter) EndSession(ctx interface{}) *SessionContext_EndSession_Call

EndSession is a helper method to define mock.On call

• ctx context.Context

func (*SessionContext_Expecter) Err

func (_e *SessionContext_Expecter) Err() *SessionContext_Err_Call

Err is a helper method to define mock.On call

func (*SessionContext_Expecter) ID

func (_e *SessionContext_Expecter) ID() *SessionContext_ID_Call

ID is a helper method to define mock.On call

func (*SessionContext_Expecter) OperationTime

func (_e *SessionContext_Expecter) OperationTime() *SessionContext_OperationTime_Call

OperationTime is a helper method to define mock.On call

func (*SessionContext_Expecter) StartTransaction

func (_e *SessionContext_Expecter) StartTransaction(opts ...interface{}) *SessionContext_StartTransaction_Call

StartTransaction is a helper method to define mock.On call

• opts ...*options.TransactionOptions

func (*SessionContext_Expecter) Value

func (_e *SessionContext_Expecter) Value(key interface{}) *SessionContext_Value_Call

Value is a helper method to define mock.On call

• key interface{}

func (*SessionContext_Expecter) WithTransaction

func (_e *SessionContext_Expecter) WithTransaction(ctx interface{}, fn interface{}, opts ...interface{}) *SessionContext_WithTransaction_Call

WithTransaction is a helper method to define mock.On call

• ctx context.Context
• fn func(mongoifc.SessionContext)(interface{} , error)
• opts ...*options.TransactionOptions

type SessionContext_ID_Call

type SessionContext_ID_Call struct {
	*mock.Call
}

SessionContext_ID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ID'

func (*SessionContext_ID_Call) Return

func (_c *SessionContext_ID_Call) Return(_a0 bson.Raw) *SessionContext_ID_Call

func (*SessionContext_ID_Call) Run

func (_c *SessionContext_ID_Call) Run(run func()) *SessionContext_ID_Call

func (*SessionContext_ID_Call) RunAndReturn

func (_c *SessionContext_ID_Call) RunAndReturn(run func() bson.Raw) *SessionContext_ID_Call

type SessionContext_OperationTime_Call

type SessionContext_OperationTime_Call struct {
	*mock.Call
}

SessionContext_OperationTime_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OperationTime'

func (*SessionContext_OperationTime_Call) Return

func (_c *SessionContext_OperationTime_Call) Return(_a0 *primitive.Timestamp) *SessionContext_OperationTime_Call

func (*SessionContext_OperationTime_Call) Run

func (_c *SessionContext_OperationTime_Call) Run(run func()) *SessionContext_OperationTime_Call

func (*SessionContext_OperationTime_Call) RunAndReturn

func (_c *SessionContext_OperationTime_Call) RunAndReturn(run func() *primitive.Timestamp) *SessionContext_OperationTime_Call

type SessionContext_StartTransaction_Call

type SessionContext_StartTransaction_Call struct {
	*mock.Call
}

SessionContext_StartTransaction_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StartTransaction'

func (*SessionContext_StartTransaction_Call) Return

func (_c *SessionContext_StartTransaction_Call) Return(_a0 error) *SessionContext_StartTransaction_Call

func (*SessionContext_StartTransaction_Call) Run

func (_c *SessionContext_StartTransaction_Call) Run(run func(opts ...*options.TransactionOptions)) *SessionContext_StartTransaction_Call

func (*SessionContext_StartTransaction_Call) RunAndReturn

func (_c *SessionContext_StartTransaction_Call) RunAndReturn(run func(...*options.TransactionOptions) error) *SessionContext_StartTransaction_Call

type SessionContext_Value_Call

type SessionContext_Value_Call struct {
	*mock.Call
}

SessionContext_Value_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Value'

func (*SessionContext_Value_Call) Return

func (_c *SessionContext_Value_Call) Return(_a0 interface{}) *SessionContext_Value_Call

func (*SessionContext_Value_Call) Run

func (_c *SessionContext_Value_Call) Run(run func(key interface{})) *SessionContext_Value_Call

func (*SessionContext_Value_Call) RunAndReturn

func (_c *SessionContext_Value_Call) RunAndReturn(run func(interface{}) interface{}) *SessionContext_Value_Call

type SessionContext_WithTransaction_Call

type SessionContext_WithTransaction_Call struct {
	*mock.Call
}

SessionContext_WithTransaction_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WithTransaction'

func (*SessionContext_WithTransaction_Call) Return

func (_c *SessionContext_WithTransaction_Call) Return(_a0 interface{}, _a1 error) *SessionContext_WithTransaction_Call

func (*SessionContext_WithTransaction_Call) Run

func (_c *SessionContext_WithTransaction_Call) Run(run func(ctx context.Context, fn func(mongoifc.SessionContext) (interface{}, error), opts ...*options.TransactionOptions)) *SessionContext_WithTransaction_Call

func (*SessionContext_WithTransaction_Call) RunAndReturn

func (_c *SessionContext_WithTransaction_Call) RunAndReturn(run func(context.Context, func(mongoifc.SessionContext) (interface{}, error), ...*options.TransactionOptions) (interface{}, error)) *SessionContext_WithTransaction_Call

type Session_AbortTransaction_Call

type Session_AbortTransaction_Call struct {
	*mock.Call
}

Session_AbortTransaction_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AbortTransaction'

func (*Session_AbortTransaction_Call) Return

func (_c *Session_AbortTransaction_Call) Return(_a0 error) *Session_AbortTransaction_Call

func (*Session_AbortTransaction_Call) Run

func (_c *Session_AbortTransaction_Call) Run(run func(ctx context.Context)) *Session_AbortTransaction_Call

func (*Session_AbortTransaction_Call) RunAndReturn

func (_c *Session_AbortTransaction_Call) RunAndReturn(run func(context.Context) error) *Session_AbortTransaction_Call

type Session_AdvanceClusterTime_Call

type Session_AdvanceClusterTime_Call struct {
	*mock.Call
}

Session_AdvanceClusterTime_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AdvanceClusterTime'

func (*Session_AdvanceClusterTime_Call) Return

func (_c *Session_AdvanceClusterTime_Call) Return(_a0 error) *Session_AdvanceClusterTime_Call

func (*Session_AdvanceClusterTime_Call) Run

func (_c *Session_AdvanceClusterTime_Call) Run(run func(_a0 bson.Raw)) *Session_AdvanceClusterTime_Call

func (*Session_AdvanceClusterTime_Call) RunAndReturn

func (_c *Session_AdvanceClusterTime_Call) RunAndReturn(run func(bson.Raw) error) *Session_AdvanceClusterTime_Call

type Session_AdvanceOperationTime_Call

type Session_AdvanceOperationTime_Call struct {
	*mock.Call
}

Session_AdvanceOperationTime_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AdvanceOperationTime'

func (*Session_AdvanceOperationTime_Call) Return

func (_c *Session_AdvanceOperationTime_Call) Return(_a0 error) *Session_AdvanceOperationTime_Call

func (*Session_AdvanceOperationTime_Call) Run

func (_c *Session_AdvanceOperationTime_Call) Run(run func(_a0 *primitive.Timestamp)) *Session_AdvanceOperationTime_Call

func (*Session_AdvanceOperationTime_Call) RunAndReturn

func (_c *Session_AdvanceOperationTime_Call) RunAndReturn(run func(*primitive.Timestamp) error) *Session_AdvanceOperationTime_Call

type Session_Client_Call

type Session_Client_Call struct {
	*mock.Call
}

Session_Client_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Client'

func (*Session_Client_Call) Return

func (_c *Session_Client_Call) Return(_a0 mongoifc.Client) *Session_Client_Call

func (*Session_Client_Call) Run

func (_c *Session_Client_Call) Run(run func()) *Session_Client_Call

func (*Session_Client_Call) RunAndReturn

func (_c *Session_Client_Call) RunAndReturn(run func() mongoifc.Client) *Session_Client_Call

type Session_ClusterTime_Call

type Session_ClusterTime_Call struct {
	*mock.Call
}

Session_ClusterTime_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ClusterTime'

func (*Session_ClusterTime_Call) Return

func (_c *Session_ClusterTime_Call) Return(_a0 bson.Raw) *Session_ClusterTime_Call

func (*Session_ClusterTime_Call) Run

func (_c *Session_ClusterTime_Call) Run(run func()) *Session_ClusterTime_Call

func (*Session_ClusterTime_Call) RunAndReturn

func (_c *Session_ClusterTime_Call) RunAndReturn(run func() bson.Raw) *Session_ClusterTime_Call

type Session_CommitTransaction_Call

type Session_CommitTransaction_Call struct {
	*mock.Call
}

Session_CommitTransaction_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CommitTransaction'

func (*Session_CommitTransaction_Call) Return

func (_c *Session_CommitTransaction_Call) Return(_a0 error) *Session_CommitTransaction_Call

func (*Session_CommitTransaction_Call) Run

func (_c *Session_CommitTransaction_Call) Run(run func(ctx context.Context)) *Session_CommitTransaction_Call

func (*Session_CommitTransaction_Call) RunAndReturn

func (_c *Session_CommitTransaction_Call) RunAndReturn(run func(context.Context) error) *Session_CommitTransaction_Call

type Session_EndSession_Call

type Session_EndSession_Call struct {
	*mock.Call
}

Session_EndSession_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'EndSession'

func (*Session_EndSession_Call) Return

func (_c *Session_EndSession_Call) Return() *Session_EndSession_Call

func (*Session_EndSession_Call) Run

func (_c *Session_EndSession_Call) Run(run func(ctx context.Context)) *Session_EndSession_Call

func (*Session_EndSession_Call) RunAndReturn

func (_c *Session_EndSession_Call) RunAndReturn(run func(context.Context)) *Session_EndSession_Call

type Session_Expecter

type Session_Expecter struct {
	// contains filtered or unexported fields
}

func (*Session_Expecter) AbortTransaction

func (_e *Session_Expecter) AbortTransaction(ctx interface{}) *Session_AbortTransaction_Call

AbortTransaction is a helper method to define mock.On call

• ctx context.Context

func (*Session_Expecter) AdvanceClusterTime

func (_e *Session_Expecter) AdvanceClusterTime(_a0 interface{}) *Session_AdvanceClusterTime_Call

AdvanceClusterTime is a helper method to define mock.On call

• _a0 bson.Raw

func (*Session_Expecter) AdvanceOperationTime

func (_e *Session_Expecter) AdvanceOperationTime(_a0 interface{}) *Session_AdvanceOperationTime_Call

AdvanceOperationTime is a helper method to define mock.On call

• _a0 *primitive.Timestamp

func (*Session_Expecter) Client

func (_e *Session_Expecter) Client() *Session_Client_Call

Client is a helper method to define mock.On call

func (*Session_Expecter) ClusterTime

func (_e *Session_Expecter) ClusterTime() *Session_ClusterTime_Call

ClusterTime is a helper method to define mock.On call

func (*Session_Expecter) CommitTransaction

func (_e *Session_Expecter) CommitTransaction(ctx interface{}) *Session_CommitTransaction_Call

CommitTransaction is a helper method to define mock.On call

• ctx context.Context

func (*Session_Expecter) EndSession

func (_e *Session_Expecter) EndSession(ctx interface{}) *Session_EndSession_Call

EndSession is a helper method to define mock.On call

• ctx context.Context

func (*Session_Expecter) ID

func (_e *Session_Expecter) ID() *Session_ID_Call

ID is a helper method to define mock.On call

func (*Session_Expecter) OperationTime

func (_e *Session_Expecter) OperationTime() *Session_OperationTime_Call

OperationTime is a helper method to define mock.On call

func (*Session_Expecter) StartTransaction

func (_e *Session_Expecter) StartTransaction(opts ...interface{}) *Session_StartTransaction_Call

StartTransaction is a helper method to define mock.On call

• opts ...*options.TransactionOptions

func (*Session_Expecter) WithTransaction

func (_e *Session_Expecter) WithTransaction(ctx interface{}, fn interface{}, opts ...interface{}) *Session_WithTransaction_Call

WithTransaction is a helper method to define mock.On call

• ctx context.Context
• fn func(mongoifc.SessionContext)(interface{} , error)
• opts ...*options.TransactionOptions

type Session_ID_Call

type Session_ID_Call struct {
	*mock.Call
}

Session_ID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ID'

func (*Session_ID_Call) Return

func (_c *Session_ID_Call) Return(_a0 bson.Raw) *Session_ID_Call

func (*Session_ID_Call) Run

func (_c *Session_ID_Call) Run(run func()) *Session_ID_Call

func (*Session_ID_Call) RunAndReturn

func (_c *Session_ID_Call) RunAndReturn(run func() bson.Raw) *Session_ID_Call

type Session_OperationTime_Call

type Session_OperationTime_Call struct {
	*mock.Call
}

Session_OperationTime_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OperationTime'

func (*Session_OperationTime_Call) Return

func (_c *Session_OperationTime_Call) Return(_a0 *primitive.Timestamp) *Session_OperationTime_Call

func (*Session_OperationTime_Call) Run

func (_c *Session_OperationTime_Call) Run(run func()) *Session_OperationTime_Call

func (*Session_OperationTime_Call) RunAndReturn

func (_c *Session_OperationTime_Call) RunAndReturn(run func() *primitive.Timestamp) *Session_OperationTime_Call

type Session_StartTransaction_Call

type Session_StartTransaction_Call struct {
	*mock.Call
}

Session_StartTransaction_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StartTransaction'

func (*Session_StartTransaction_Call) Return

func (_c *Session_StartTransaction_Call) Return(_a0 error) *Session_StartTransaction_Call

func (*Session_StartTransaction_Call) Run

func (_c *Session_StartTransaction_Call) Run(run func(opts ...*options.TransactionOptions)) *Session_StartTransaction_Call

func (*Session_StartTransaction_Call) RunAndReturn

func (_c *Session_StartTransaction_Call) RunAndReturn(run func(...*options.TransactionOptions) error) *Session_StartTransaction_Call

type Session_WithTransaction_Call

type Session_WithTransaction_Call struct {
	*mock.Call
}

Session_WithTransaction_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WithTransaction'

func (*Session_WithTransaction_Call) Return

func (_c *Session_WithTransaction_Call) Return(_a0 interface{}, _a1 error) *Session_WithTransaction_Call

func (*Session_WithTransaction_Call) Run

func (_c *Session_WithTransaction_Call) Run(run func(ctx context.Context, fn func(mongoifc.SessionContext) (interface{}, error), opts ...*options.TransactionOptions)) *Session_WithTransaction_Call

func (*Session_WithTransaction_Call) RunAndReturn

func (_c *Session_WithTransaction_Call) RunAndReturn(run func(context.Context, func(mongoifc.SessionContext) (interface{}, error), ...*options.TransactionOptions) (interface{}, error)) *Session_WithTransaction_Call

type SingleResult

type SingleResult struct {
	mock.Mock
}

SingleResult is an autogenerated mock type for the SingleResult type

func NewSingleResult

func NewSingleResult(t interface {
	mock.TestingT
	Cleanup(func())
}) *SingleResult

NewSingleResult creates a new instance of SingleResult. 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 (*SingleResult) Decode

func (_m *SingleResult) Decode(v interface{}) error

Decode provides a mock function with given fields: v

func (*SingleResult) DecodeBytes

func (_m *SingleResult) DecodeBytes() (bson.Raw, error)

DecodeBytes provides a mock function with given fields:

func (*SingleResult) EXPECT

func (_m *SingleResult) EXPECT() *SingleResult_Expecter

func (*SingleResult) Err

func (_m *SingleResult) Err() error

Err provides a mock function with given fields:

func (*SingleResult) Raw

func (_m *SingleResult) Raw() (bson.Raw, error)

Raw provides a mock function with given fields:

type SingleResult_DecodeBytes_Call

type SingleResult_DecodeBytes_Call struct {
	*mock.Call
}

SingleResult_DecodeBytes_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DecodeBytes'

func (*SingleResult_DecodeBytes_Call) Return

func (_c *SingleResult_DecodeBytes_Call) Return(_a0 bson.Raw, _a1 error) *SingleResult_DecodeBytes_Call

func (*SingleResult_DecodeBytes_Call) Run

func (_c *SingleResult_DecodeBytes_Call) Run(run func()) *SingleResult_DecodeBytes_Call

func (*SingleResult_DecodeBytes_Call) RunAndReturn

func (_c *SingleResult_DecodeBytes_Call) RunAndReturn(run func() (bson.Raw, error)) *SingleResult_DecodeBytes_Call

type SingleResult_Decode_Call

type SingleResult_Decode_Call struct {
	*mock.Call
}

SingleResult_Decode_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Decode'

func (*SingleResult_Decode_Call) Return

func (_c *SingleResult_Decode_Call) Return(_a0 error) *SingleResult_Decode_Call

func (*SingleResult_Decode_Call) Run

func (_c *SingleResult_Decode_Call) Run(run func(v interface{})) *SingleResult_Decode_Call

func (*SingleResult_Decode_Call) RunAndReturn

func (_c *SingleResult_Decode_Call) RunAndReturn(run func(interface{}) error) *SingleResult_Decode_Call

type SingleResult_Err_Call

type SingleResult_Err_Call struct {
	*mock.Call
}

SingleResult_Err_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Err'

func (*SingleResult_Err_Call) Return

func (_c *SingleResult_Err_Call) Return(_a0 error) *SingleResult_Err_Call

func (*SingleResult_Err_Call) Run

func (_c *SingleResult_Err_Call) Run(run func()) *SingleResult_Err_Call

func (*SingleResult_Err_Call) RunAndReturn

func (_c *SingleResult_Err_Call) RunAndReturn(run func() error) *SingleResult_Err_Call

type SingleResult_Expecter

type SingleResult_Expecter struct {
	// contains filtered or unexported fields
}

func (*SingleResult_Expecter) Decode

func (_e *SingleResult_Expecter) Decode(v interface{}) *SingleResult_Decode_Call

Decode is a helper method to define mock.On call

• v interface{}

func (*SingleResult_Expecter) DecodeBytes

func (_e *SingleResult_Expecter) DecodeBytes() *SingleResult_DecodeBytes_Call

DecodeBytes is a helper method to define mock.On call

func (*SingleResult_Expecter) Err

func (_e *SingleResult_Expecter) Err() *SingleResult_Err_Call

Err is a helper method to define mock.On call

func (*SingleResult_Expecter) Raw

func (_e *SingleResult_Expecter) Raw() *SingleResult_Raw_Call

Raw is a helper method to define mock.On call

type SingleResult_Raw_Call

type SingleResult_Raw_Call struct {
	*mock.Call
}

SingleResult_Raw_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Raw'

func (*SingleResult_Raw_Call) Return

func (_c *SingleResult_Raw_Call) Return(_a0 bson.Raw, _a1 error) *SingleResult_Raw_Call

func (*SingleResult_Raw_Call) Run

func (_c *SingleResult_Raw_Call) Run(run func()) *SingleResult_Raw_Call

func (*SingleResult_Raw_Call) RunAndReturn

func (_c *SingleResult_Raw_Call) RunAndReturn(run func() (bson.Raw, error)) *SingleResult_Raw_Call