Documentation ¶
Overview ¶
Package mocks is a generated GoMock package.
Index ¶
- type MockChangeStream
- func (m *MockChangeStream) Close(arg0 context.Context) error
- func (m *MockChangeStream) Current() bson.Raw
- func (m *MockChangeStream) Decode(arg0 interface{}) error
- func (m *MockChangeStream) EXPECT() *MockChangeStreamMockRecorder
- func (m *MockChangeStream) Err() error
- func (m *MockChangeStream) ID() int64
- func (m *MockChangeStream) Next(arg0 context.Context) bool
- func (m *MockChangeStream) ResumeToken() bson.Raw
- func (m *MockChangeStream) TryNext(arg0 context.Context) bool
- type MockChangeStreamMockRecorder
- func (mr *MockChangeStreamMockRecorder) Close(arg0 interface{}) *gomock.Call
- func (mr *MockChangeStreamMockRecorder) Current() *gomock.Call
- func (mr *MockChangeStreamMockRecorder) Decode(arg0 interface{}) *gomock.Call
- func (mr *MockChangeStreamMockRecorder) Err() *gomock.Call
- func (mr *MockChangeStreamMockRecorder) ID() *gomock.Call
- func (mr *MockChangeStreamMockRecorder) Next(arg0 interface{}) *gomock.Call
- func (mr *MockChangeStreamMockRecorder) ResumeToken() *gomock.Call
- func (mr *MockChangeStreamMockRecorder) TryNext(arg0 interface{}) *gomock.Call
- type MockClient
- func (m *MockClient) Connect(arg0 context.Context) error
- func (m *MockClient) Database(arg0 string, arg1 ...*options.DatabaseOptions) mongoifc.Database
- func (m *MockClient) Disconnect(arg0 context.Context) error
- func (m *MockClient) EXPECT() *MockClientMockRecorder
- func (m *MockClient) ListDatabaseNames(arg0 context.Context, arg1 interface{}, arg2 ...*options.ListDatabasesOptions) ([]string, error)
- func (m *MockClient) ListDatabases(arg0 context.Context, arg1 interface{}, arg2 ...*options.ListDatabasesOptions) (mongo.ListDatabasesResult, error)
- func (m *MockClient) NumberSessionsInProgress() int
- func (m *MockClient) Ping(arg0 context.Context, arg1 *readpref.ReadPref) error
- func (m *MockClient) StartSession(arg0 ...*options.SessionOptions) (mongoifc.Session, error)
- func (m *MockClient) UseSession(arg0 context.Context, arg1 func(mongoifc.SessionContext) error) error
- func (m *MockClient) UseSessionWithOptions(arg0 context.Context, arg1 *options.SessionOptions, ...) error
- func (m *MockClient) Watch(arg0 context.Context, arg1 interface{}, arg2 ...*options.ChangeStreamOptions) (mongoifc.ChangeStream, error)
- type MockClientMockRecorder
- func (mr *MockClientMockRecorder) Connect(arg0 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) Database(arg0 interface{}, arg1 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) Disconnect(arg0 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) ListDatabaseNames(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) ListDatabases(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) NumberSessionsInProgress() *gomock.Call
- func (mr *MockClientMockRecorder) Ping(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) StartSession(arg0 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) UseSession(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) UseSessionWithOptions(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) Watch(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- type MockCollection
- func (m *MockCollection) Aggregate(arg0 context.Context, arg1 interface{}, arg2 ...*options.AggregateOptions) (mongoifc.Cursor, error)
- func (m *MockCollection) BulkWrite(arg0 context.Context, arg1 []mongo.WriteModel, ...) (*mongo.BulkWriteResult, error)
- func (m *MockCollection) Clone(arg0 ...*options.CollectionOptions) (mongoifc.Collection, error)
- func (m *MockCollection) CountDocuments(arg0 context.Context, arg1 interface{}, arg2 ...*options.CountOptions) (int64, error)
- func (m *MockCollection) Database() mongoifc.Database
- func (m *MockCollection) DeleteMany(arg0 context.Context, arg1 interface{}, arg2 ...*options.DeleteOptions) (*mongo.DeleteResult, error)
- func (m *MockCollection) DeleteOne(arg0 context.Context, arg1 interface{}, arg2 ...*options.DeleteOptions) (*mongo.DeleteResult, error)
- func (m *MockCollection) Distinct(arg0 context.Context, arg1 string, arg2 interface{}, ...) ([]interface{}, error)
- func (m *MockCollection) Drop(arg0 context.Context) error
- func (m *MockCollection) EXPECT() *MockCollectionMockRecorder
- func (m *MockCollection) EstimatedDocumentCount(arg0 context.Context, arg1 ...*options.EstimatedDocumentCountOptions) (int64, error)
- func (m *MockCollection) Find(arg0 context.Context, arg1 interface{}, arg2 ...*options.FindOptions) (mongoifc.Cursor, error)
- func (m *MockCollection) FindOne(arg0 context.Context, arg1 interface{}, arg2 ...*options.FindOneOptions) mongoifc.SingleResult
- func (m *MockCollection) FindOneAndDelete(arg0 context.Context, arg1 interface{}, ...) mongoifc.SingleResult
- func (m *MockCollection) FindOneAndReplace(arg0 context.Context, arg1, arg2 interface{}, ...) mongoifc.SingleResult
- func (m *MockCollection) FindOneAndUpdate(arg0 context.Context, arg1, arg2 interface{}, ...) mongoifc.SingleResult
- func (m *MockCollection) Indexes() mongoifc.IndexView
- func (m *MockCollection) InsertMany(arg0 context.Context, arg1 []interface{}, arg2 ...*options.InsertManyOptions) (*mongo.InsertManyResult, error)
- func (m *MockCollection) InsertOne(arg0 context.Context, arg1 interface{}, arg2 ...*options.InsertOneOptions) (*mongo.InsertOneResult, error)
- func (m *MockCollection) Name() string
- func (m *MockCollection) ReplaceOne(arg0 context.Context, arg1, arg2 interface{}, arg3 ...*options.ReplaceOptions) (*mongo.UpdateResult, error)
- func (m *MockCollection) UpdateByID(arg0 context.Context, arg1, arg2 interface{}, arg3 ...*options.UpdateOptions) (*mongo.UpdateResult, error)
- func (m *MockCollection) UpdateMany(arg0 context.Context, arg1, arg2 interface{}, arg3 ...*options.UpdateOptions) (*mongo.UpdateResult, error)
- func (m *MockCollection) UpdateOne(arg0 context.Context, arg1, arg2 interface{}, arg3 ...*options.UpdateOptions) (*mongo.UpdateResult, error)
- func (m *MockCollection) Watch(arg0 context.Context, arg1 interface{}, arg2 ...*options.ChangeStreamOptions) (mongoifc.ChangeStream, error)
- type MockCollectionMockRecorder
- func (mr *MockCollectionMockRecorder) Aggregate(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockCollectionMockRecorder) BulkWrite(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockCollectionMockRecorder) Clone(arg0 ...interface{}) *gomock.Call
- func (mr *MockCollectionMockRecorder) CountDocuments(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockCollectionMockRecorder) Database() *gomock.Call
- func (mr *MockCollectionMockRecorder) DeleteMany(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockCollectionMockRecorder) DeleteOne(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockCollectionMockRecorder) Distinct(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockCollectionMockRecorder) Drop(arg0 interface{}) *gomock.Call
- func (mr *MockCollectionMockRecorder) EstimatedDocumentCount(arg0 interface{}, arg1 ...interface{}) *gomock.Call
- func (mr *MockCollectionMockRecorder) Find(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockCollectionMockRecorder) FindOne(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockCollectionMockRecorder) FindOneAndDelete(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockCollectionMockRecorder) FindOneAndReplace(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockCollectionMockRecorder) FindOneAndUpdate(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockCollectionMockRecorder) Indexes() *gomock.Call
- func (mr *MockCollectionMockRecorder) InsertMany(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockCollectionMockRecorder) InsertOne(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockCollectionMockRecorder) Name() *gomock.Call
- func (mr *MockCollectionMockRecorder) ReplaceOne(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockCollectionMockRecorder) UpdateByID(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockCollectionMockRecorder) UpdateMany(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockCollectionMockRecorder) UpdateOne(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockCollectionMockRecorder) Watch(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- type MockCursor
- func (m *MockCursor) All(arg0 context.Context, arg1 interface{}) error
- func (m *MockCursor) Close(arg0 context.Context) error
- func (m *MockCursor) Current() bson.Raw
- func (m *MockCursor) Decode(arg0 interface{}) error
- func (m *MockCursor) EXPECT() *MockCursorMockRecorder
- func (m *MockCursor) Err() error
- func (m *MockCursor) ID() int64
- func (m *MockCursor) Next(arg0 context.Context) bool
- func (m *MockCursor) RemainingBatchLength() int
- func (m *MockCursor) TryNext(arg0 context.Context) bool
- type MockCursorMockRecorder
- func (mr *MockCursorMockRecorder) All(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockCursorMockRecorder) Close(arg0 interface{}) *gomock.Call
- func (mr *MockCursorMockRecorder) Current() *gomock.Call
- func (mr *MockCursorMockRecorder) Decode(arg0 interface{}) *gomock.Call
- func (mr *MockCursorMockRecorder) Err() *gomock.Call
- func (mr *MockCursorMockRecorder) ID() *gomock.Call
- func (mr *MockCursorMockRecorder) Next(arg0 interface{}) *gomock.Call
- func (mr *MockCursorMockRecorder) RemainingBatchLength() *gomock.Call
- func (mr *MockCursorMockRecorder) TryNext(arg0 interface{}) *gomock.Call
- type MockDatabase
- func (m *MockDatabase) Aggregate(arg0 context.Context, arg1 interface{}, arg2 ...*options.AggregateOptions) (mongoifc.Cursor, error)
- func (m *MockDatabase) Client() mongoifc.Client
- func (m *MockDatabase) Collection(arg0 string, arg1 ...*options.CollectionOptions) mongoifc.Collection
- func (m *MockDatabase) CreateCollection(arg0 context.Context, arg1 string, arg2 ...*options.CreateCollectionOptions) error
- func (m *MockDatabase) CreateView(arg0 context.Context, arg1, arg2 string, arg3 interface{}, ...) error
- func (m *MockDatabase) Drop(arg0 context.Context) error
- func (m *MockDatabase) EXPECT() *MockDatabaseMockRecorder
- func (m *MockDatabase) ListCollectionNames(arg0 context.Context, arg1 interface{}, ...) ([]string, error)
- func (m *MockDatabase) ListCollectionSpecifications(arg0 context.Context, arg1 interface{}, ...) ([]*mongo.CollectionSpecification, error)
- func (m *MockDatabase) ListCollections(arg0 context.Context, arg1 interface{}, ...) (mongoifc.Cursor, error)
- func (m *MockDatabase) Name() string
- func (m *MockDatabase) ReadConcern() *readconcern.ReadConcern
- func (m *MockDatabase) ReadPreference() *readpref.ReadPref
- func (m *MockDatabase) RunCommand(arg0 context.Context, arg1 interface{}, arg2 ...*options.RunCmdOptions) mongoifc.SingleResult
- func (m *MockDatabase) RunCommandCursor(arg0 context.Context, arg1 interface{}, arg2 ...*options.RunCmdOptions) (mongoifc.Cursor, error)
- func (m *MockDatabase) Watch(arg0 context.Context, arg1 interface{}, arg2 ...*options.ChangeStreamOptions) (mongoifc.ChangeStream, error)
- func (m *MockDatabase) WriteConcern() *writeconcern.WriteConcern
- type MockDatabaseMockRecorder
- func (mr *MockDatabaseMockRecorder) Aggregate(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDatabaseMockRecorder) Client() *gomock.Call
- func (mr *MockDatabaseMockRecorder) Collection(arg0 interface{}, arg1 ...interface{}) *gomock.Call
- func (mr *MockDatabaseMockRecorder) CreateCollection(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDatabaseMockRecorder) CreateView(arg0, arg1, arg2, arg3 interface{}, arg4 ...interface{}) *gomock.Call
- func (mr *MockDatabaseMockRecorder) Drop(arg0 interface{}) *gomock.Call
- func (mr *MockDatabaseMockRecorder) ListCollectionNames(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDatabaseMockRecorder) ListCollectionSpecifications(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDatabaseMockRecorder) ListCollections(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDatabaseMockRecorder) Name() *gomock.Call
- func (mr *MockDatabaseMockRecorder) ReadConcern() *gomock.Call
- func (mr *MockDatabaseMockRecorder) ReadPreference() *gomock.Call
- func (mr *MockDatabaseMockRecorder) RunCommand(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDatabaseMockRecorder) RunCommandCursor(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDatabaseMockRecorder) Watch(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDatabaseMockRecorder) WriteConcern() *gomock.Call
- type MockIndexView
- func (m *MockIndexView) CreateMany(arg0 context.Context, arg1 []mongo.IndexModel, ...) ([]string, error)
- func (m *MockIndexView) CreateOne(arg0 context.Context, arg1 mongo.IndexModel, ...) (string, error)
- func (m *MockIndexView) DropAll(arg0 context.Context, arg1 ...*options.DropIndexesOptions) (bson.Raw, error)
- func (m *MockIndexView) DropOne(arg0 context.Context, arg1 string, arg2 ...*options.DropIndexesOptions) (bson.Raw, error)
- func (m *MockIndexView) EXPECT() *MockIndexViewMockRecorder
- func (m *MockIndexView) List(arg0 context.Context, arg1 ...*options.ListIndexesOptions) (mongoifc.Cursor, error)
- func (m *MockIndexView) ListSpecifications(arg0 context.Context, arg1 ...*options.ListIndexesOptions) ([]*mongo.IndexSpecification, error)
- type MockIndexViewMockRecorder
- func (mr *MockIndexViewMockRecorder) CreateMany(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockIndexViewMockRecorder) CreateOne(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockIndexViewMockRecorder) DropAll(arg0 interface{}, arg1 ...interface{}) *gomock.Call
- func (mr *MockIndexViewMockRecorder) DropOne(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockIndexViewMockRecorder) List(arg0 interface{}, arg1 ...interface{}) *gomock.Call
- func (mr *MockIndexViewMockRecorder) ListSpecifications(arg0 interface{}, arg1 ...interface{}) *gomock.Call
- type MockSession
- func (m *MockSession) AbortTransaction(arg0 context.Context) error
- func (m *MockSession) AdvanceClusterTime(arg0 bson.Raw) error
- func (m *MockSession) AdvanceOperationTime(arg0 *primitive.Timestamp) error
- func (m *MockSession) Client() mongoifc.Client
- func (m *MockSession) ClusterTime() bson.Raw
- func (m *MockSession) CommitTransaction(arg0 context.Context) error
- func (m *MockSession) EXPECT() *MockSessionMockRecorder
- func (m *MockSession) EndSession(arg0 context.Context)
- func (m *MockSession) ID() bson.Raw
- func (m *MockSession) OperationTime() *primitive.Timestamp
- func (m *MockSession) StartTransaction(arg0 ...*options.TransactionOptions) error
- func (m *MockSession) WithTransaction(arg0 context.Context, arg1 func(mongoifc.SessionContext) (interface{}, error), ...) (interface{}, error)
- type MockSessionContext
- func (m *MockSessionContext) AbortTransaction(arg0 context.Context) error
- func (m *MockSessionContext) AdvanceClusterTime(arg0 bson.Raw) error
- func (m *MockSessionContext) AdvanceOperationTime(arg0 *primitive.Timestamp) error
- func (m *MockSessionContext) Client() mongoifc.Client
- func (m *MockSessionContext) ClusterTime() bson.Raw
- func (m *MockSessionContext) CommitTransaction(arg0 context.Context) error
- func (m *MockSessionContext) Deadline() (time.Time, bool)
- func (m *MockSessionContext) Done() <-chan struct{}
- func (m *MockSessionContext) EXPECT() *MockSessionContextMockRecorder
- func (m *MockSessionContext) EndSession(arg0 context.Context)
- func (m *MockSessionContext) Err() error
- func (m *MockSessionContext) ID() bson.Raw
- func (m *MockSessionContext) OperationTime() *primitive.Timestamp
- func (m *MockSessionContext) StartTransaction(arg0 ...*options.TransactionOptions) error
- func (m *MockSessionContext) Value(arg0 interface{}) interface{}
- func (m *MockSessionContext) WithTransaction(arg0 context.Context, arg1 func(mongoifc.SessionContext) (interface{}, error), ...) (interface{}, error)
- type MockSessionContextMockRecorder
- func (mr *MockSessionContextMockRecorder) AbortTransaction(arg0 interface{}) *gomock.Call
- func (mr *MockSessionContextMockRecorder) AdvanceClusterTime(arg0 interface{}) *gomock.Call
- func (mr *MockSessionContextMockRecorder) AdvanceOperationTime(arg0 interface{}) *gomock.Call
- func (mr *MockSessionContextMockRecorder) Client() *gomock.Call
- func (mr *MockSessionContextMockRecorder) ClusterTime() *gomock.Call
- func (mr *MockSessionContextMockRecorder) CommitTransaction(arg0 interface{}) *gomock.Call
- func (mr *MockSessionContextMockRecorder) Deadline() *gomock.Call
- func (mr *MockSessionContextMockRecorder) Done() *gomock.Call
- func (mr *MockSessionContextMockRecorder) EndSession(arg0 interface{}) *gomock.Call
- func (mr *MockSessionContextMockRecorder) Err() *gomock.Call
- func (mr *MockSessionContextMockRecorder) ID() *gomock.Call
- func (mr *MockSessionContextMockRecorder) OperationTime() *gomock.Call
- func (mr *MockSessionContextMockRecorder) StartTransaction(arg0 ...interface{}) *gomock.Call
- func (mr *MockSessionContextMockRecorder) Value(arg0 interface{}) *gomock.Call
- func (mr *MockSessionContextMockRecorder) WithTransaction(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- type MockSessionMockRecorder
- func (mr *MockSessionMockRecorder) AbortTransaction(arg0 interface{}) *gomock.Call
- func (mr *MockSessionMockRecorder) AdvanceClusterTime(arg0 interface{}) *gomock.Call
- func (mr *MockSessionMockRecorder) AdvanceOperationTime(arg0 interface{}) *gomock.Call
- func (mr *MockSessionMockRecorder) Client() *gomock.Call
- func (mr *MockSessionMockRecorder) ClusterTime() *gomock.Call
- func (mr *MockSessionMockRecorder) CommitTransaction(arg0 interface{}) *gomock.Call
- func (mr *MockSessionMockRecorder) EndSession(arg0 interface{}) *gomock.Call
- func (mr *MockSessionMockRecorder) ID() *gomock.Call
- func (mr *MockSessionMockRecorder) OperationTime() *gomock.Call
- func (mr *MockSessionMockRecorder) StartTransaction(arg0 ...interface{}) *gomock.Call
- func (mr *MockSessionMockRecorder) WithTransaction(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- type MockSingleResult
- type MockSingleResultMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockChangeStream ¶
type MockChangeStream struct {
// contains filtered or unexported fields
}
MockChangeStream is a mock of ChangeStream interface.
func NewMockChangeStream ¶
func NewMockChangeStream(ctrl *gomock.Controller) *MockChangeStream
NewMockChangeStream creates a new mock instance.
func (*MockChangeStream) Close ¶
func (m *MockChangeStream) Close(arg0 context.Context) error
Close mocks base method.
func (*MockChangeStream) Current ¶
func (m *MockChangeStream) Current() bson.Raw
Current mocks base method.
func (*MockChangeStream) Decode ¶
func (m *MockChangeStream) Decode(arg0 interface{}) error
Decode mocks base method.
func (*MockChangeStream) EXPECT ¶
func (m *MockChangeStream) EXPECT() *MockChangeStreamMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockChangeStream) Next ¶
func (m *MockChangeStream) Next(arg0 context.Context) bool
Next mocks base method.
func (*MockChangeStream) ResumeToken ¶
func (m *MockChangeStream) ResumeToken() bson.Raw
ResumeToken mocks base method.
type MockChangeStreamMockRecorder ¶
type MockChangeStreamMockRecorder struct {
// contains filtered or unexported fields
}
MockChangeStreamMockRecorder is the mock recorder for MockChangeStream.
func (*MockChangeStreamMockRecorder) Close ¶
func (mr *MockChangeStreamMockRecorder) Close(arg0 interface{}) *gomock.Call
Close indicates an expected call of Close.
func (*MockChangeStreamMockRecorder) Current ¶
func (mr *MockChangeStreamMockRecorder) Current() *gomock.Call
Current indicates an expected call of Current.
func (*MockChangeStreamMockRecorder) Decode ¶
func (mr *MockChangeStreamMockRecorder) Decode(arg0 interface{}) *gomock.Call
Decode indicates an expected call of Decode.
func (*MockChangeStreamMockRecorder) Err ¶
func (mr *MockChangeStreamMockRecorder) Err() *gomock.Call
Err indicates an expected call of Err.
func (*MockChangeStreamMockRecorder) ID ¶
func (mr *MockChangeStreamMockRecorder) ID() *gomock.Call
ID indicates an expected call of ID.
func (*MockChangeStreamMockRecorder) Next ¶
func (mr *MockChangeStreamMockRecorder) Next(arg0 interface{}) *gomock.Call
Next indicates an expected call of Next.
func (*MockChangeStreamMockRecorder) ResumeToken ¶
func (mr *MockChangeStreamMockRecorder) ResumeToken() *gomock.Call
ResumeToken indicates an expected call of ResumeToken.
func (*MockChangeStreamMockRecorder) TryNext ¶
func (mr *MockChangeStreamMockRecorder) TryNext(arg0 interface{}) *gomock.Call
TryNext indicates an expected call of TryNext.
type MockClient ¶
type MockClient struct {
// contains filtered or unexported fields
}
MockClient is a mock of Client interface.
func NewMockClient ¶
func NewMockClient(ctrl *gomock.Controller) *MockClient
NewMockClient creates a new mock instance.
func (*MockClient) Connect ¶
func (m *MockClient) Connect(arg0 context.Context) error
Connect mocks base method.
func (*MockClient) Database ¶
func (m *MockClient) Database(arg0 string, arg1 ...*options.DatabaseOptions) mongoifc.Database
Database mocks base method.
func (*MockClient) Disconnect ¶
func (m *MockClient) Disconnect(arg0 context.Context) error
Disconnect mocks base method.
func (*MockClient) EXPECT ¶
func (m *MockClient) EXPECT() *MockClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockClient) ListDatabaseNames ¶
func (m *MockClient) ListDatabaseNames(arg0 context.Context, arg1 interface{}, arg2 ...*options.ListDatabasesOptions) ([]string, error)
ListDatabaseNames mocks base method.
func (*MockClient) ListDatabases ¶
func (m *MockClient) ListDatabases(arg0 context.Context, arg1 interface{}, arg2 ...*options.ListDatabasesOptions) (mongo.ListDatabasesResult, error)
ListDatabases mocks base method.
func (*MockClient) NumberSessionsInProgress ¶
func (m *MockClient) NumberSessionsInProgress() int
NumberSessionsInProgress mocks base method.
func (*MockClient) StartSession ¶
func (m *MockClient) StartSession(arg0 ...*options.SessionOptions) (mongoifc.Session, error)
StartSession mocks base method.
func (*MockClient) UseSession ¶
func (m *MockClient) UseSession(arg0 context.Context, arg1 func(mongoifc.SessionContext) error) error
UseSession mocks base method.
func (*MockClient) UseSessionWithOptions ¶
func (m *MockClient) UseSessionWithOptions(arg0 context.Context, arg1 *options.SessionOptions, arg2 func(mongoifc.SessionContext) error) error
UseSessionWithOptions mocks base method.
func (*MockClient) Watch ¶
func (m *MockClient) Watch(arg0 context.Context, arg1 interface{}, arg2 ...*options.ChangeStreamOptions) (mongoifc.ChangeStream, error)
Watch mocks base method.
type MockClientMockRecorder ¶
type MockClientMockRecorder struct {
// contains filtered or unexported fields
}
MockClientMockRecorder is the mock recorder for MockClient.
func (*MockClientMockRecorder) Connect ¶
func (mr *MockClientMockRecorder) Connect(arg0 interface{}) *gomock.Call
Connect indicates an expected call of Connect.
func (*MockClientMockRecorder) Database ¶
func (mr *MockClientMockRecorder) Database(arg0 interface{}, arg1 ...interface{}) *gomock.Call
Database indicates an expected call of Database.
func (*MockClientMockRecorder) Disconnect ¶
func (mr *MockClientMockRecorder) Disconnect(arg0 interface{}) *gomock.Call
Disconnect indicates an expected call of Disconnect.
func (*MockClientMockRecorder) ListDatabaseNames ¶
func (mr *MockClientMockRecorder) ListDatabaseNames(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ListDatabaseNames indicates an expected call of ListDatabaseNames.
func (*MockClientMockRecorder) ListDatabases ¶
func (mr *MockClientMockRecorder) ListDatabases(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ListDatabases indicates an expected call of ListDatabases.
func (*MockClientMockRecorder) NumberSessionsInProgress ¶
func (mr *MockClientMockRecorder) NumberSessionsInProgress() *gomock.Call
NumberSessionsInProgress indicates an expected call of NumberSessionsInProgress.
func (*MockClientMockRecorder) Ping ¶
func (mr *MockClientMockRecorder) Ping(arg0, arg1 interface{}) *gomock.Call
Ping indicates an expected call of Ping.
func (*MockClientMockRecorder) StartSession ¶
func (mr *MockClientMockRecorder) StartSession(arg0 ...interface{}) *gomock.Call
StartSession indicates an expected call of StartSession.
func (*MockClientMockRecorder) UseSession ¶
func (mr *MockClientMockRecorder) UseSession(arg0, arg1 interface{}) *gomock.Call
UseSession indicates an expected call of UseSession.
func (*MockClientMockRecorder) UseSessionWithOptions ¶
func (mr *MockClientMockRecorder) UseSessionWithOptions(arg0, arg1, arg2 interface{}) *gomock.Call
UseSessionWithOptions indicates an expected call of UseSessionWithOptions.
func (*MockClientMockRecorder) Watch ¶
func (mr *MockClientMockRecorder) Watch(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Watch indicates an expected call of Watch.
type MockCollection ¶
type MockCollection struct {
// contains filtered or unexported fields
}
MockCollection is a mock of Collection interface.
func NewMockCollection ¶
func NewMockCollection(ctrl *gomock.Controller) *MockCollection
NewMockCollection creates a new mock instance.
func (*MockCollection) Aggregate ¶
func (m *MockCollection) Aggregate(arg0 context.Context, arg1 interface{}, arg2 ...*options.AggregateOptions) (mongoifc.Cursor, error)
Aggregate mocks base method.
func (*MockCollection) BulkWrite ¶
func (m *MockCollection) BulkWrite(arg0 context.Context, arg1 []mongo.WriteModel, arg2 ...*options.BulkWriteOptions) (*mongo.BulkWriteResult, error)
BulkWrite mocks base method.
func (*MockCollection) Clone ¶
func (m *MockCollection) Clone(arg0 ...*options.CollectionOptions) (mongoifc.Collection, error)
Clone mocks base method.
func (*MockCollection) CountDocuments ¶
func (m *MockCollection) CountDocuments(arg0 context.Context, arg1 interface{}, arg2 ...*options.CountOptions) (int64, error)
CountDocuments mocks base method.
func (*MockCollection) Database ¶
func (m *MockCollection) Database() mongoifc.Database
Database mocks base method.
func (*MockCollection) DeleteMany ¶
func (m *MockCollection) DeleteMany(arg0 context.Context, arg1 interface{}, arg2 ...*options.DeleteOptions) (*mongo.DeleteResult, error)
DeleteMany mocks base method.
func (*MockCollection) DeleteOne ¶
func (m *MockCollection) DeleteOne(arg0 context.Context, arg1 interface{}, arg2 ...*options.DeleteOptions) (*mongo.DeleteResult, error)
DeleteOne mocks base method.
func (*MockCollection) Distinct ¶
func (m *MockCollection) Distinct(arg0 context.Context, arg1 string, arg2 interface{}, arg3 ...*options.DistinctOptions) ([]interface{}, error)
Distinct mocks base method.
func (*MockCollection) Drop ¶
func (m *MockCollection) Drop(arg0 context.Context) error
Drop mocks base method.
func (*MockCollection) EXPECT ¶
func (m *MockCollection) EXPECT() *MockCollectionMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockCollection) EstimatedDocumentCount ¶
func (m *MockCollection) EstimatedDocumentCount(arg0 context.Context, arg1 ...*options.EstimatedDocumentCountOptions) (int64, error)
EstimatedDocumentCount mocks base method.
func (*MockCollection) Find ¶
func (m *MockCollection) Find(arg0 context.Context, arg1 interface{}, arg2 ...*options.FindOptions) (mongoifc.Cursor, error)
Find mocks base method.
func (*MockCollection) FindOne ¶
func (m *MockCollection) FindOne(arg0 context.Context, arg1 interface{}, arg2 ...*options.FindOneOptions) mongoifc.SingleResult
FindOne mocks base method.
func (*MockCollection) FindOneAndDelete ¶
func (m *MockCollection) FindOneAndDelete(arg0 context.Context, arg1 interface{}, arg2 ...*options.FindOneAndDeleteOptions) mongoifc.SingleResult
FindOneAndDelete mocks base method.
func (*MockCollection) FindOneAndReplace ¶
func (m *MockCollection) FindOneAndReplace(arg0 context.Context, arg1, arg2 interface{}, arg3 ...*options.FindOneAndReplaceOptions) mongoifc.SingleResult
FindOneAndReplace mocks base method.
func (*MockCollection) FindOneAndUpdate ¶
func (m *MockCollection) FindOneAndUpdate(arg0 context.Context, arg1, arg2 interface{}, arg3 ...*options.FindOneAndUpdateOptions) mongoifc.SingleResult
FindOneAndUpdate mocks base method.
func (*MockCollection) Indexes ¶
func (m *MockCollection) Indexes() mongoifc.IndexView
Indexes mocks base method.
func (*MockCollection) InsertMany ¶
func (m *MockCollection) InsertMany(arg0 context.Context, arg1 []interface{}, arg2 ...*options.InsertManyOptions) (*mongo.InsertManyResult, error)
InsertMany mocks base method.
func (*MockCollection) InsertOne ¶
func (m *MockCollection) InsertOne(arg0 context.Context, arg1 interface{}, arg2 ...*options.InsertOneOptions) (*mongo.InsertOneResult, error)
InsertOne mocks base method.
func (*MockCollection) ReplaceOne ¶
func (m *MockCollection) ReplaceOne(arg0 context.Context, arg1, arg2 interface{}, arg3 ...*options.ReplaceOptions) (*mongo.UpdateResult, error)
ReplaceOne mocks base method.
func (*MockCollection) UpdateByID ¶
func (m *MockCollection) UpdateByID(arg0 context.Context, arg1, arg2 interface{}, arg3 ...*options.UpdateOptions) (*mongo.UpdateResult, error)
UpdateByID mocks base method.
func (*MockCollection) UpdateMany ¶
func (m *MockCollection) UpdateMany(arg0 context.Context, arg1, arg2 interface{}, arg3 ...*options.UpdateOptions) (*mongo.UpdateResult, error)
UpdateMany mocks base method.
func (*MockCollection) UpdateOne ¶
func (m *MockCollection) UpdateOne(arg0 context.Context, arg1, arg2 interface{}, arg3 ...*options.UpdateOptions) (*mongo.UpdateResult, error)
UpdateOne mocks base method.
func (*MockCollection) Watch ¶
func (m *MockCollection) Watch(arg0 context.Context, arg1 interface{}, arg2 ...*options.ChangeStreamOptions) (mongoifc.ChangeStream, error)
Watch mocks base method.
type MockCollectionMockRecorder ¶
type MockCollectionMockRecorder struct {
// contains filtered or unexported fields
}
MockCollectionMockRecorder is the mock recorder for MockCollection.
func (*MockCollectionMockRecorder) Aggregate ¶
func (mr *MockCollectionMockRecorder) Aggregate(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Aggregate indicates an expected call of Aggregate.
func (*MockCollectionMockRecorder) BulkWrite ¶
func (mr *MockCollectionMockRecorder) BulkWrite(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
BulkWrite indicates an expected call of BulkWrite.
func (*MockCollectionMockRecorder) Clone ¶
func (mr *MockCollectionMockRecorder) Clone(arg0 ...interface{}) *gomock.Call
Clone indicates an expected call of Clone.
func (*MockCollectionMockRecorder) CountDocuments ¶
func (mr *MockCollectionMockRecorder) CountDocuments(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
CountDocuments indicates an expected call of CountDocuments.
func (*MockCollectionMockRecorder) Database ¶
func (mr *MockCollectionMockRecorder) Database() *gomock.Call
Database indicates an expected call of Database.
func (*MockCollectionMockRecorder) DeleteMany ¶
func (mr *MockCollectionMockRecorder) DeleteMany(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DeleteMany indicates an expected call of DeleteMany.
func (*MockCollectionMockRecorder) DeleteOne ¶
func (mr *MockCollectionMockRecorder) DeleteOne(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DeleteOne indicates an expected call of DeleteOne.
func (*MockCollectionMockRecorder) Distinct ¶
func (mr *MockCollectionMockRecorder) Distinct(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
Distinct indicates an expected call of Distinct.
func (*MockCollectionMockRecorder) Drop ¶
func (mr *MockCollectionMockRecorder) Drop(arg0 interface{}) *gomock.Call
Drop indicates an expected call of Drop.
func (*MockCollectionMockRecorder) EstimatedDocumentCount ¶
func (mr *MockCollectionMockRecorder) EstimatedDocumentCount(arg0 interface{}, arg1 ...interface{}) *gomock.Call
EstimatedDocumentCount indicates an expected call of EstimatedDocumentCount.
func (*MockCollectionMockRecorder) Find ¶
func (mr *MockCollectionMockRecorder) Find(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Find indicates an expected call of Find.
func (*MockCollectionMockRecorder) FindOne ¶
func (mr *MockCollectionMockRecorder) FindOne(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
FindOne indicates an expected call of FindOne.
func (*MockCollectionMockRecorder) FindOneAndDelete ¶
func (mr *MockCollectionMockRecorder) FindOneAndDelete(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
FindOneAndDelete indicates an expected call of FindOneAndDelete.
func (*MockCollectionMockRecorder) FindOneAndReplace ¶
func (mr *MockCollectionMockRecorder) FindOneAndReplace(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
FindOneAndReplace indicates an expected call of FindOneAndReplace.
func (*MockCollectionMockRecorder) FindOneAndUpdate ¶
func (mr *MockCollectionMockRecorder) FindOneAndUpdate(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
FindOneAndUpdate indicates an expected call of FindOneAndUpdate.
func (*MockCollectionMockRecorder) Indexes ¶
func (mr *MockCollectionMockRecorder) Indexes() *gomock.Call
Indexes indicates an expected call of Indexes.
func (*MockCollectionMockRecorder) InsertMany ¶
func (mr *MockCollectionMockRecorder) InsertMany(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
InsertMany indicates an expected call of InsertMany.
func (*MockCollectionMockRecorder) InsertOne ¶
func (mr *MockCollectionMockRecorder) InsertOne(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
InsertOne indicates an expected call of InsertOne.
func (*MockCollectionMockRecorder) Name ¶
func (mr *MockCollectionMockRecorder) Name() *gomock.Call
Name indicates an expected call of Name.
func (*MockCollectionMockRecorder) ReplaceOne ¶
func (mr *MockCollectionMockRecorder) ReplaceOne(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
ReplaceOne indicates an expected call of ReplaceOne.
func (*MockCollectionMockRecorder) UpdateByID ¶
func (mr *MockCollectionMockRecorder) UpdateByID(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
UpdateByID indicates an expected call of UpdateByID.
func (*MockCollectionMockRecorder) UpdateMany ¶
func (mr *MockCollectionMockRecorder) UpdateMany(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
UpdateMany indicates an expected call of UpdateMany.
func (*MockCollectionMockRecorder) UpdateOne ¶
func (mr *MockCollectionMockRecorder) UpdateOne(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
UpdateOne indicates an expected call of UpdateOne.
func (*MockCollectionMockRecorder) Watch ¶
func (mr *MockCollectionMockRecorder) Watch(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Watch indicates an expected call of Watch.
type MockCursor ¶
type MockCursor struct {
// contains filtered or unexported fields
}
MockCursor is a mock of Cursor interface.
func NewMockCursor ¶
func NewMockCursor(ctrl *gomock.Controller) *MockCursor
NewMockCursor creates a new mock instance.
func (*MockCursor) All ¶
func (m *MockCursor) All(arg0 context.Context, arg1 interface{}) error
All mocks base method.
func (*MockCursor) Close ¶
func (m *MockCursor) Close(arg0 context.Context) error
Close mocks base method.
func (*MockCursor) Decode ¶
func (m *MockCursor) Decode(arg0 interface{}) error
Decode mocks base method.
func (*MockCursor) EXPECT ¶
func (m *MockCursor) EXPECT() *MockCursorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockCursor) Next ¶
func (m *MockCursor) Next(arg0 context.Context) bool
Next mocks base method.
func (*MockCursor) RemainingBatchLength ¶
func (m *MockCursor) RemainingBatchLength() int
RemainingBatchLength mocks base method.
type MockCursorMockRecorder ¶
type MockCursorMockRecorder struct {
// contains filtered or unexported fields
}
MockCursorMockRecorder is the mock recorder for MockCursor.
func (*MockCursorMockRecorder) All ¶
func (mr *MockCursorMockRecorder) All(arg0, arg1 interface{}) *gomock.Call
All indicates an expected call of All.
func (*MockCursorMockRecorder) Close ¶
func (mr *MockCursorMockRecorder) Close(arg0 interface{}) *gomock.Call
Close indicates an expected call of Close.
func (*MockCursorMockRecorder) Current ¶
func (mr *MockCursorMockRecorder) Current() *gomock.Call
Current indicates an expected call of Current.
func (*MockCursorMockRecorder) Decode ¶
func (mr *MockCursorMockRecorder) Decode(arg0 interface{}) *gomock.Call
Decode indicates an expected call of Decode.
func (*MockCursorMockRecorder) Err ¶
func (mr *MockCursorMockRecorder) Err() *gomock.Call
Err indicates an expected call of Err.
func (*MockCursorMockRecorder) ID ¶
func (mr *MockCursorMockRecorder) ID() *gomock.Call
ID indicates an expected call of ID.
func (*MockCursorMockRecorder) Next ¶
func (mr *MockCursorMockRecorder) Next(arg0 interface{}) *gomock.Call
Next indicates an expected call of Next.
func (*MockCursorMockRecorder) RemainingBatchLength ¶
func (mr *MockCursorMockRecorder) RemainingBatchLength() *gomock.Call
RemainingBatchLength indicates an expected call of RemainingBatchLength.
func (*MockCursorMockRecorder) TryNext ¶
func (mr *MockCursorMockRecorder) TryNext(arg0 interface{}) *gomock.Call
TryNext indicates an expected call of TryNext.
type MockDatabase ¶
type MockDatabase struct {
// contains filtered or unexported fields
}
MockDatabase is a mock of Database interface.
func NewMockDatabase ¶
func NewMockDatabase(ctrl *gomock.Controller) *MockDatabase
NewMockDatabase creates a new mock instance.
func (*MockDatabase) Aggregate ¶
func (m *MockDatabase) Aggregate(arg0 context.Context, arg1 interface{}, arg2 ...*options.AggregateOptions) (mongoifc.Cursor, error)
Aggregate mocks base method.
func (*MockDatabase) Client ¶
func (m *MockDatabase) Client() mongoifc.Client
Client mocks base method.
func (*MockDatabase) Collection ¶
func (m *MockDatabase) Collection(arg0 string, arg1 ...*options.CollectionOptions) mongoifc.Collection
Collection mocks base method.
func (*MockDatabase) CreateCollection ¶
func (m *MockDatabase) CreateCollection(arg0 context.Context, arg1 string, arg2 ...*options.CreateCollectionOptions) error
CreateCollection mocks base method.
func (*MockDatabase) CreateView ¶
func (m *MockDatabase) CreateView(arg0 context.Context, arg1, arg2 string, arg3 interface{}, arg4 ...*options.CreateViewOptions) error
CreateView mocks base method.
func (*MockDatabase) Drop ¶
func (m *MockDatabase) Drop(arg0 context.Context) error
Drop mocks base method.
func (*MockDatabase) EXPECT ¶
func (m *MockDatabase) EXPECT() *MockDatabaseMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDatabase) ListCollectionNames ¶
func (m *MockDatabase) ListCollectionNames(arg0 context.Context, arg1 interface{}, arg2 ...*options.ListCollectionsOptions) ([]string, error)
ListCollectionNames mocks base method.
func (*MockDatabase) ListCollectionSpecifications ¶
func (m *MockDatabase) ListCollectionSpecifications(arg0 context.Context, arg1 interface{}, arg2 ...*options.ListCollectionsOptions) ([]*mongo.CollectionSpecification, error)
ListCollectionSpecifications mocks base method.
func (*MockDatabase) ListCollections ¶
func (m *MockDatabase) ListCollections(arg0 context.Context, arg1 interface{}, arg2 ...*options.ListCollectionsOptions) (mongoifc.Cursor, error)
ListCollections mocks base method.
func (*MockDatabase) ReadConcern ¶
func (m *MockDatabase) ReadConcern() *readconcern.ReadConcern
ReadConcern mocks base method.
func (*MockDatabase) ReadPreference ¶
func (m *MockDatabase) ReadPreference() *readpref.ReadPref
ReadPreference mocks base method.
func (*MockDatabase) RunCommand ¶
func (m *MockDatabase) RunCommand(arg0 context.Context, arg1 interface{}, arg2 ...*options.RunCmdOptions) mongoifc.SingleResult
RunCommand mocks base method.
func (*MockDatabase) RunCommandCursor ¶
func (m *MockDatabase) RunCommandCursor(arg0 context.Context, arg1 interface{}, arg2 ...*options.RunCmdOptions) (mongoifc.Cursor, error)
RunCommandCursor mocks base method.
func (*MockDatabase) Watch ¶
func (m *MockDatabase) Watch(arg0 context.Context, arg1 interface{}, arg2 ...*options.ChangeStreamOptions) (mongoifc.ChangeStream, error)
Watch mocks base method.
func (*MockDatabase) WriteConcern ¶
func (m *MockDatabase) WriteConcern() *writeconcern.WriteConcern
WriteConcern mocks base method.
type MockDatabaseMockRecorder ¶
type MockDatabaseMockRecorder struct {
// contains filtered or unexported fields
}
MockDatabaseMockRecorder is the mock recorder for MockDatabase.
func (*MockDatabaseMockRecorder) Aggregate ¶
func (mr *MockDatabaseMockRecorder) Aggregate(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Aggregate indicates an expected call of Aggregate.
func (*MockDatabaseMockRecorder) Client ¶
func (mr *MockDatabaseMockRecorder) Client() *gomock.Call
Client indicates an expected call of Client.
func (*MockDatabaseMockRecorder) Collection ¶
func (mr *MockDatabaseMockRecorder) Collection(arg0 interface{}, arg1 ...interface{}) *gomock.Call
Collection indicates an expected call of Collection.
func (*MockDatabaseMockRecorder) CreateCollection ¶
func (mr *MockDatabaseMockRecorder) CreateCollection(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
CreateCollection indicates an expected call of CreateCollection.
func (*MockDatabaseMockRecorder) CreateView ¶
func (mr *MockDatabaseMockRecorder) CreateView(arg0, arg1, arg2, arg3 interface{}, arg4 ...interface{}) *gomock.Call
CreateView indicates an expected call of CreateView.
func (*MockDatabaseMockRecorder) Drop ¶
func (mr *MockDatabaseMockRecorder) Drop(arg0 interface{}) *gomock.Call
Drop indicates an expected call of Drop.
func (*MockDatabaseMockRecorder) ListCollectionNames ¶
func (mr *MockDatabaseMockRecorder) ListCollectionNames(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ListCollectionNames indicates an expected call of ListCollectionNames.
func (*MockDatabaseMockRecorder) ListCollectionSpecifications ¶
func (mr *MockDatabaseMockRecorder) ListCollectionSpecifications(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ListCollectionSpecifications indicates an expected call of ListCollectionSpecifications.
func (*MockDatabaseMockRecorder) ListCollections ¶
func (mr *MockDatabaseMockRecorder) ListCollections(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ListCollections indicates an expected call of ListCollections.
func (*MockDatabaseMockRecorder) Name ¶
func (mr *MockDatabaseMockRecorder) Name() *gomock.Call
Name indicates an expected call of Name.
func (*MockDatabaseMockRecorder) ReadConcern ¶
func (mr *MockDatabaseMockRecorder) ReadConcern() *gomock.Call
ReadConcern indicates an expected call of ReadConcern.
func (*MockDatabaseMockRecorder) ReadPreference ¶
func (mr *MockDatabaseMockRecorder) ReadPreference() *gomock.Call
ReadPreference indicates an expected call of ReadPreference.
func (*MockDatabaseMockRecorder) RunCommand ¶
func (mr *MockDatabaseMockRecorder) RunCommand(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
RunCommand indicates an expected call of RunCommand.
func (*MockDatabaseMockRecorder) RunCommandCursor ¶
func (mr *MockDatabaseMockRecorder) RunCommandCursor(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
RunCommandCursor indicates an expected call of RunCommandCursor.
func (*MockDatabaseMockRecorder) Watch ¶
func (mr *MockDatabaseMockRecorder) Watch(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Watch indicates an expected call of Watch.
func (*MockDatabaseMockRecorder) WriteConcern ¶
func (mr *MockDatabaseMockRecorder) WriteConcern() *gomock.Call
WriteConcern indicates an expected call of WriteConcern.
type MockIndexView ¶
type MockIndexView struct {
// contains filtered or unexported fields
}
MockIndexView is a mock of IndexView interface.
func NewMockIndexView ¶
func NewMockIndexView(ctrl *gomock.Controller) *MockIndexView
NewMockIndexView creates a new mock instance.
func (*MockIndexView) CreateMany ¶
func (m *MockIndexView) CreateMany(arg0 context.Context, arg1 []mongo.IndexModel, arg2 ...*options.CreateIndexesOptions) ([]string, error)
CreateMany mocks base method.
func (*MockIndexView) CreateOne ¶
func (m *MockIndexView) CreateOne(arg0 context.Context, arg1 mongo.IndexModel, arg2 ...*options.CreateIndexesOptions) (string, error)
CreateOne mocks base method.
func (*MockIndexView) DropAll ¶
func (m *MockIndexView) DropAll(arg0 context.Context, arg1 ...*options.DropIndexesOptions) (bson.Raw, error)
DropAll mocks base method.
func (*MockIndexView) DropOne ¶
func (m *MockIndexView) DropOne(arg0 context.Context, arg1 string, arg2 ...*options.DropIndexesOptions) (bson.Raw, error)
DropOne mocks base method.
func (*MockIndexView) EXPECT ¶
func (m *MockIndexView) EXPECT() *MockIndexViewMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockIndexView) List ¶
func (m *MockIndexView) List(arg0 context.Context, arg1 ...*options.ListIndexesOptions) (mongoifc.Cursor, error)
List mocks base method.
func (*MockIndexView) ListSpecifications ¶
func (m *MockIndexView) ListSpecifications(arg0 context.Context, arg1 ...*options.ListIndexesOptions) ([]*mongo.IndexSpecification, error)
ListSpecifications mocks base method.
type MockIndexViewMockRecorder ¶
type MockIndexViewMockRecorder struct {
// contains filtered or unexported fields
}
MockIndexViewMockRecorder is the mock recorder for MockIndexView.
func (*MockIndexViewMockRecorder) CreateMany ¶
func (mr *MockIndexViewMockRecorder) CreateMany(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
CreateMany indicates an expected call of CreateMany.
func (*MockIndexViewMockRecorder) CreateOne ¶
func (mr *MockIndexViewMockRecorder) CreateOne(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
CreateOne indicates an expected call of CreateOne.
func (*MockIndexViewMockRecorder) DropAll ¶
func (mr *MockIndexViewMockRecorder) DropAll(arg0 interface{}, arg1 ...interface{}) *gomock.Call
DropAll indicates an expected call of DropAll.
func (*MockIndexViewMockRecorder) DropOne ¶
func (mr *MockIndexViewMockRecorder) DropOne(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DropOne indicates an expected call of DropOne.
func (*MockIndexViewMockRecorder) List ¶
func (mr *MockIndexViewMockRecorder) List(arg0 interface{}, arg1 ...interface{}) *gomock.Call
List indicates an expected call of List.
func (*MockIndexViewMockRecorder) ListSpecifications ¶
func (mr *MockIndexViewMockRecorder) ListSpecifications(arg0 interface{}, arg1 ...interface{}) *gomock.Call
ListSpecifications indicates an expected call of ListSpecifications.
type MockSession ¶
type MockSession struct {
// contains filtered or unexported fields
}
MockSession is a mock of Session interface.
func NewMockSession ¶
func NewMockSession(ctrl *gomock.Controller) *MockSession
NewMockSession creates a new mock instance.
func (*MockSession) AbortTransaction ¶
func (m *MockSession) AbortTransaction(arg0 context.Context) error
AbortTransaction mocks base method.
func (*MockSession) AdvanceClusterTime ¶
func (m *MockSession) AdvanceClusterTime(arg0 bson.Raw) error
AdvanceClusterTime mocks base method.
func (*MockSession) AdvanceOperationTime ¶
func (m *MockSession) AdvanceOperationTime(arg0 *primitive.Timestamp) error
AdvanceOperationTime mocks base method.
func (*MockSession) Client ¶
func (m *MockSession) Client() mongoifc.Client
Client mocks base method.
func (*MockSession) ClusterTime ¶
func (m *MockSession) ClusterTime() bson.Raw
ClusterTime mocks base method.
func (*MockSession) CommitTransaction ¶
func (m *MockSession) CommitTransaction(arg0 context.Context) error
CommitTransaction mocks base method.
func (*MockSession) EXPECT ¶
func (m *MockSession) EXPECT() *MockSessionMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockSession) EndSession ¶
func (m *MockSession) EndSession(arg0 context.Context)
EndSession mocks base method.
func (*MockSession) OperationTime ¶
func (m *MockSession) OperationTime() *primitive.Timestamp
OperationTime mocks base method.
func (*MockSession) StartTransaction ¶
func (m *MockSession) StartTransaction(arg0 ...*options.TransactionOptions) error
StartTransaction mocks base method.
func (*MockSession) WithTransaction ¶
func (m *MockSession) WithTransaction(arg0 context.Context, arg1 func(mongoifc.SessionContext) (interface{}, error), arg2 ...*options.TransactionOptions) (interface{}, error)
WithTransaction mocks base method.
type MockSessionContext ¶ added in v1.0.0
type MockSessionContext struct {
// contains filtered or unexported fields
}
MockSessionContext is a mock of SessionContext interface.
func NewMockSessionContext ¶ added in v1.0.0
func NewMockSessionContext(ctrl *gomock.Controller) *MockSessionContext
NewMockSessionContext creates a new mock instance.
func (*MockSessionContext) AbortTransaction ¶ added in v1.0.0
func (m *MockSessionContext) AbortTransaction(arg0 context.Context) error
AbortTransaction mocks base method.
func (*MockSessionContext) AdvanceClusterTime ¶ added in v1.0.0
func (m *MockSessionContext) AdvanceClusterTime(arg0 bson.Raw) error
AdvanceClusterTime mocks base method.
func (*MockSessionContext) AdvanceOperationTime ¶ added in v1.0.0
func (m *MockSessionContext) AdvanceOperationTime(arg0 *primitive.Timestamp) error
AdvanceOperationTime mocks base method.
func (*MockSessionContext) Client ¶ added in v1.0.0
func (m *MockSessionContext) Client() mongoifc.Client
Client mocks base method.
func (*MockSessionContext) ClusterTime ¶ added in v1.0.0
func (m *MockSessionContext) ClusterTime() bson.Raw
ClusterTime mocks base method.
func (*MockSessionContext) CommitTransaction ¶ added in v1.0.0
func (m *MockSessionContext) CommitTransaction(arg0 context.Context) error
CommitTransaction mocks base method.
func (*MockSessionContext) Deadline ¶ added in v1.0.0
func (m *MockSessionContext) Deadline() (time.Time, bool)
Deadline mocks base method.
func (*MockSessionContext) Done ¶ added in v1.0.0
func (m *MockSessionContext) Done() <-chan struct{}
Done mocks base method.
func (*MockSessionContext) EXPECT ¶ added in v1.0.0
func (m *MockSessionContext) EXPECT() *MockSessionContextMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockSessionContext) EndSession ¶ added in v1.0.0
func (m *MockSessionContext) EndSession(arg0 context.Context)
EndSession mocks base method.
func (*MockSessionContext) Err ¶ added in v1.0.0
func (m *MockSessionContext) Err() error
Err mocks base method.
func (*MockSessionContext) ID ¶ added in v1.0.0
func (m *MockSessionContext) ID() bson.Raw
ID mocks base method.
func (*MockSessionContext) OperationTime ¶ added in v1.0.0
func (m *MockSessionContext) OperationTime() *primitive.Timestamp
OperationTime mocks base method.
func (*MockSessionContext) StartTransaction ¶ added in v1.0.0
func (m *MockSessionContext) StartTransaction(arg0 ...*options.TransactionOptions) error
StartTransaction mocks base method.
func (*MockSessionContext) Value ¶ added in v1.0.0
func (m *MockSessionContext) Value(arg0 interface{}) interface{}
Value mocks base method.
func (*MockSessionContext) WithTransaction ¶ added in v1.0.0
func (m *MockSessionContext) WithTransaction(arg0 context.Context, arg1 func(mongoifc.SessionContext) (interface{}, error), arg2 ...*options.TransactionOptions) (interface{}, error)
WithTransaction mocks base method.
type MockSessionContextMockRecorder ¶ added in v1.0.0
type MockSessionContextMockRecorder struct {
// contains filtered or unexported fields
}
MockSessionContextMockRecorder is the mock recorder for MockSessionContext.
func (*MockSessionContextMockRecorder) AbortTransaction ¶ added in v1.0.0
func (mr *MockSessionContextMockRecorder) AbortTransaction(arg0 interface{}) *gomock.Call
AbortTransaction indicates an expected call of AbortTransaction.
func (*MockSessionContextMockRecorder) AdvanceClusterTime ¶ added in v1.0.0
func (mr *MockSessionContextMockRecorder) AdvanceClusterTime(arg0 interface{}) *gomock.Call
AdvanceClusterTime indicates an expected call of AdvanceClusterTime.
func (*MockSessionContextMockRecorder) AdvanceOperationTime ¶ added in v1.0.0
func (mr *MockSessionContextMockRecorder) AdvanceOperationTime(arg0 interface{}) *gomock.Call
AdvanceOperationTime indicates an expected call of AdvanceOperationTime.
func (*MockSessionContextMockRecorder) Client ¶ added in v1.0.0
func (mr *MockSessionContextMockRecorder) Client() *gomock.Call
Client indicates an expected call of Client.
func (*MockSessionContextMockRecorder) ClusterTime ¶ added in v1.0.0
func (mr *MockSessionContextMockRecorder) ClusterTime() *gomock.Call
ClusterTime indicates an expected call of ClusterTime.
func (*MockSessionContextMockRecorder) CommitTransaction ¶ added in v1.0.0
func (mr *MockSessionContextMockRecorder) CommitTransaction(arg0 interface{}) *gomock.Call
CommitTransaction indicates an expected call of CommitTransaction.
func (*MockSessionContextMockRecorder) Deadline ¶ added in v1.0.0
func (mr *MockSessionContextMockRecorder) Deadline() *gomock.Call
Deadline indicates an expected call of Deadline.
func (*MockSessionContextMockRecorder) Done ¶ added in v1.0.0
func (mr *MockSessionContextMockRecorder) Done() *gomock.Call
Done indicates an expected call of Done.
func (*MockSessionContextMockRecorder) EndSession ¶ added in v1.0.0
func (mr *MockSessionContextMockRecorder) EndSession(arg0 interface{}) *gomock.Call
EndSession indicates an expected call of EndSession.
func (*MockSessionContextMockRecorder) Err ¶ added in v1.0.0
func (mr *MockSessionContextMockRecorder) Err() *gomock.Call
Err indicates an expected call of Err.
func (*MockSessionContextMockRecorder) ID ¶ added in v1.0.0
func (mr *MockSessionContextMockRecorder) ID() *gomock.Call
ID indicates an expected call of ID.
func (*MockSessionContextMockRecorder) OperationTime ¶ added in v1.0.0
func (mr *MockSessionContextMockRecorder) OperationTime() *gomock.Call
OperationTime indicates an expected call of OperationTime.
func (*MockSessionContextMockRecorder) StartTransaction ¶ added in v1.0.0
func (mr *MockSessionContextMockRecorder) StartTransaction(arg0 ...interface{}) *gomock.Call
StartTransaction indicates an expected call of StartTransaction.
func (*MockSessionContextMockRecorder) Value ¶ added in v1.0.0
func (mr *MockSessionContextMockRecorder) Value(arg0 interface{}) *gomock.Call
Value indicates an expected call of Value.
func (*MockSessionContextMockRecorder) WithTransaction ¶ added in v1.0.0
func (mr *MockSessionContextMockRecorder) WithTransaction(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
WithTransaction indicates an expected call of WithTransaction.
type MockSessionMockRecorder ¶
type MockSessionMockRecorder struct {
// contains filtered or unexported fields
}
MockSessionMockRecorder is the mock recorder for MockSession.
func (*MockSessionMockRecorder) AbortTransaction ¶
func (mr *MockSessionMockRecorder) AbortTransaction(arg0 interface{}) *gomock.Call
AbortTransaction indicates an expected call of AbortTransaction.
func (*MockSessionMockRecorder) AdvanceClusterTime ¶
func (mr *MockSessionMockRecorder) AdvanceClusterTime(arg0 interface{}) *gomock.Call
AdvanceClusterTime indicates an expected call of AdvanceClusterTime.
func (*MockSessionMockRecorder) AdvanceOperationTime ¶
func (mr *MockSessionMockRecorder) AdvanceOperationTime(arg0 interface{}) *gomock.Call
AdvanceOperationTime indicates an expected call of AdvanceOperationTime.
func (*MockSessionMockRecorder) Client ¶
func (mr *MockSessionMockRecorder) Client() *gomock.Call
Client indicates an expected call of Client.
func (*MockSessionMockRecorder) ClusterTime ¶
func (mr *MockSessionMockRecorder) ClusterTime() *gomock.Call
ClusterTime indicates an expected call of ClusterTime.
func (*MockSessionMockRecorder) CommitTransaction ¶
func (mr *MockSessionMockRecorder) CommitTransaction(arg0 interface{}) *gomock.Call
CommitTransaction indicates an expected call of CommitTransaction.
func (*MockSessionMockRecorder) EndSession ¶
func (mr *MockSessionMockRecorder) EndSession(arg0 interface{}) *gomock.Call
EndSession indicates an expected call of EndSession.
func (*MockSessionMockRecorder) ID ¶
func (mr *MockSessionMockRecorder) ID() *gomock.Call
ID indicates an expected call of ID.
func (*MockSessionMockRecorder) OperationTime ¶
func (mr *MockSessionMockRecorder) OperationTime() *gomock.Call
OperationTime indicates an expected call of OperationTime.
func (*MockSessionMockRecorder) StartTransaction ¶
func (mr *MockSessionMockRecorder) StartTransaction(arg0 ...interface{}) *gomock.Call
StartTransaction indicates an expected call of StartTransaction.
func (*MockSessionMockRecorder) WithTransaction ¶
func (mr *MockSessionMockRecorder) WithTransaction(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
WithTransaction indicates an expected call of WithTransaction.
type MockSingleResult ¶
type MockSingleResult struct {
// contains filtered or unexported fields
}
MockSingleResult is a mock of SingleResult interface.
func NewMockSingleResult ¶
func NewMockSingleResult(ctrl *gomock.Controller) *MockSingleResult
NewMockSingleResult creates a new mock instance.
func (*MockSingleResult) Decode ¶
func (m *MockSingleResult) Decode(arg0 interface{}) error
Decode mocks base method.
func (*MockSingleResult) DecodeBytes ¶
func (m *MockSingleResult) DecodeBytes() (bson.Raw, error)
DecodeBytes mocks base method.
func (*MockSingleResult) EXPECT ¶
func (m *MockSingleResult) EXPECT() *MockSingleResultMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockSingleResultMockRecorder ¶
type MockSingleResultMockRecorder struct {
// contains filtered or unexported fields
}
MockSingleResultMockRecorder is the mock recorder for MockSingleResult.
func (*MockSingleResultMockRecorder) Decode ¶
func (mr *MockSingleResultMockRecorder) Decode(arg0 interface{}) *gomock.Call
Decode indicates an expected call of Decode.
func (*MockSingleResultMockRecorder) DecodeBytes ¶
func (mr *MockSingleResultMockRecorder) DecodeBytes() *gomock.Call
DecodeBytes indicates an expected call of DecodeBytes.
func (*MockSingleResultMockRecorder) Err ¶
func (mr *MockSingleResultMockRecorder) Err() *gomock.Call
Err indicates an expected call of Err.