Documentation ¶
Overview ¶
Package mock_pmongo is a generated GoMock package.
Package mock_pmongo is a generated GoMock package.
Package mock_pmongo is a generated GoMock package.
Package mock_pmongo is a generated GoMock package.
Package mock_pmongo is a generated GoMock package.
Package mock_pmongo is a generated GoMock package.
Package mock_pmongo is a generated GoMock package.
Package mock_pmongo is a generated GoMock package.
Index ¶
- type MockBucketInterface
- func (m *MockBucketInterface) Delete(fileID interface{}) error
- func (m *MockBucketInterface) DownloadToStream(fileID interface{}, stream io.Writer) (int64, error)
- func (m *MockBucketInterface) DownloadToStreamByName(filename string, stream io.Writer, opts ...*options.NameOptions) (int64, error)
- func (m *MockBucketInterface) Drop() error
- func (m *MockBucketInterface) EXPECT() *MockBucketInterfaceMockRecorder
- func (m *MockBucketInterface) Find(filter interface{}, opts ...*options.GridFSFindOptions) (pmongo.CursorInterface, error)
- func (m *MockBucketInterface) OpenDownloadStream(fileID interface{}) (pmongo.DownloadStreamInterface, error)
- func (m *MockBucketInterface) OpenDownloadStreamByName(filename string, opts ...*options.NameOptions) (pmongo.DownloadStreamInterface, error)
- func (m *MockBucketInterface) OpenUploadStream(filename string, opts ...*options.UploadOptions) (pmongo.UploadStreamInterface, error)
- func (m *MockBucketInterface) OpenUploadStreamWithID(fileID interface{}, filename string, opts ...*options.UploadOptions) (pmongo.UploadStreamInterface, error)
- func (m *MockBucketInterface) Rename(fileID interface{}, newFilename string) error
- func (m *MockBucketInterface) SetReadDeadline(t time.Time) error
- func (m *MockBucketInterface) SetWriteDeadline(t time.Time) error
- func (m *MockBucketInterface) UploadFromStream(filename string, source io.Reader, opts ...*options.UploadOptions) (primitive.ObjectID, error)
- func (m *MockBucketInterface) UploadFromStreamWithID(fileID interface{}, filename string, source io.Reader, ...) error
- type MockBucketInterfaceMockRecorder
- func (mr *MockBucketInterfaceMockRecorder) Delete(fileID interface{}) *gomock.Call
- func (mr *MockBucketInterfaceMockRecorder) DownloadToStream(fileID, stream interface{}) *gomock.Call
- func (mr *MockBucketInterfaceMockRecorder) DownloadToStreamByName(filename, stream interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockBucketInterfaceMockRecorder) Drop() *gomock.Call
- func (mr *MockBucketInterfaceMockRecorder) Find(filter interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockBucketInterfaceMockRecorder) OpenDownloadStream(fileID interface{}) *gomock.Call
- func (mr *MockBucketInterfaceMockRecorder) OpenDownloadStreamByName(filename interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockBucketInterfaceMockRecorder) OpenUploadStream(filename interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockBucketInterfaceMockRecorder) OpenUploadStreamWithID(fileID, filename interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockBucketInterfaceMockRecorder) Rename(fileID, newFilename interface{}) *gomock.Call
- func (mr *MockBucketInterfaceMockRecorder) SetReadDeadline(t interface{}) *gomock.Call
- func (mr *MockBucketInterfaceMockRecorder) SetWriteDeadline(t interface{}) *gomock.Call
- func (mr *MockBucketInterfaceMockRecorder) UploadFromStream(filename, source interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockBucketInterfaceMockRecorder) UploadFromStreamWithID(fileID, filename, source interface{}, opts ...interface{}) *gomock.Call
- type MockClientInterface
- func (m *MockClientInterface) Connect(ctx context.Context) error
- func (m *MockClientInterface) Database(name string, opts ...*options.DatabaseOptions) pmongo.DatabaseInterface
- func (m *MockClientInterface) Disconnect(ctx context.Context) error
- func (m *MockClientInterface) EXPECT() *MockClientInterfaceMockRecorder
- func (m *MockClientInterface) ListDatabaseNames(ctx context.Context, filter interface{}, opts ...*options.ListDatabasesOptions) ([]string, error)
- func (m *MockClientInterface) ListDatabases(ctx context.Context, filter interface{}, opts ...*options.ListDatabasesOptions) (mongo.ListDatabasesResult, error)
- func (m *MockClientInterface) NumberSessionsInProgress() int
- func (m *MockClientInterface) Ping(ctx context.Context, rp *readpref.ReadPref) error
- func (m *MockClientInterface) StartSession(opts ...*options.SessionOptions) (pmongo.SessionInterface, error)
- func (m *MockClientInterface) UseSession(ctx context.Context, fn func(mongo.SessionContext) error) error
- func (m *MockClientInterface) UseSessionWithOptions(ctx context.Context, opts *options.SessionOptions, ...) error
- func (m *MockClientInterface) Watch(ctx context.Context, pipeline interface{}, ...) (*mongo.ChangeStream, error)
- type MockClientInterfaceMockRecorder
- func (mr *MockClientInterfaceMockRecorder) Connect(ctx interface{}) *gomock.Call
- func (mr *MockClientInterfaceMockRecorder) Database(name interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockClientInterfaceMockRecorder) Disconnect(ctx interface{}) *gomock.Call
- func (mr *MockClientInterfaceMockRecorder) ListDatabaseNames(ctx, filter interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockClientInterfaceMockRecorder) ListDatabases(ctx, filter interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockClientInterfaceMockRecorder) NumberSessionsInProgress() *gomock.Call
- func (mr *MockClientInterfaceMockRecorder) Ping(ctx, rp interface{}) *gomock.Call
- func (mr *MockClientInterfaceMockRecorder) StartSession(opts ...interface{}) *gomock.Call
- func (mr *MockClientInterfaceMockRecorder) UseSession(ctx, fn interface{}) *gomock.Call
- func (mr *MockClientInterfaceMockRecorder) UseSessionWithOptions(ctx, opts, fn interface{}) *gomock.Call
- func (mr *MockClientInterfaceMockRecorder) Watch(ctx, pipeline interface{}, opts ...interface{}) *gomock.Call
- type MockCollectionInterface
- func (m *MockCollectionInterface) Aggregate(ctx context.Context, pipeline interface{}, opts ...*options.AggregateOptions) (pmongo.CursorInterface, error)
- func (m *MockCollectionInterface) BulkWrite(ctx context.Context, models []mongo.WriteModel, ...) (*mongo.BulkWriteResult, error)
- func (m *MockCollectionInterface) Clone(opts ...*options.CollectionOptions) (pmongo.CollectionInterface, error)
- func (m *MockCollectionInterface) CountDocuments(ctx context.Context, filter interface{}, opts ...*options.CountOptions) (int64, error)
- func (m *MockCollectionInterface) Database() pmongo.DatabaseInterface
- func (m *MockCollectionInterface) DeleteMany(ctx context.Context, filter interface{}, opts ...*options.DeleteOptions) (*mongo.DeleteResult, error)
- func (m *MockCollectionInterface) DeleteOne(ctx context.Context, filter interface{}, opts ...*options.DeleteOptions) (*mongo.DeleteResult, error)
- func (m *MockCollectionInterface) Distinct(ctx context.Context, fieldName string, filter interface{}, ...) ([]interface{}, error)
- func (m *MockCollectionInterface) Drop(ctx context.Context) error
- func (m *MockCollectionInterface) EXPECT() *MockCollectionInterfaceMockRecorder
- func (m *MockCollectionInterface) EstimatedDocumentCount(ctx context.Context, opts ...*options.EstimatedDocumentCountOptions) (int64, error)
- func (m *MockCollectionInterface) Find(ctx context.Context, filter interface{}, opts ...*options.FindOptions) (pmongo.CursorInterface, error)
- func (m *MockCollectionInterface) FindOne(ctx context.Context, filter interface{}, opts ...*options.FindOneOptions) pmongo.SingleResultInterface
- func (m *MockCollectionInterface) FindOneAndDelete(ctx context.Context, filter interface{}, ...) pmongo.SingleResultInterface
- func (m *MockCollectionInterface) FindOneAndReplace(ctx context.Context, filter, replacement interface{}, ...) pmongo.SingleResultInterface
- func (m *MockCollectionInterface) FindOneAndUpdate(ctx context.Context, filter, update interface{}, ...) pmongo.SingleResultInterface
- func (m *MockCollectionInterface) Indexes() pmongo.IndexViewInterface
- func (m *MockCollectionInterface) InsertMany(ctx context.Context, documents []interface{}, ...) (*mongo.InsertManyResult, error)
- func (m *MockCollectionInterface) InsertOne(ctx context.Context, document interface{}, opts ...*options.InsertOneOptions) (*mongo.InsertOneResult, error)
- func (m *MockCollectionInterface) Name() string
- func (m *MockCollectionInterface) ReplaceOne(ctx context.Context, filter, replacement interface{}, ...) (*mongo.UpdateResult, error)
- func (m *MockCollectionInterface) UpdateMany(ctx context.Context, filter, update interface{}, ...) (*mongo.UpdateResult, error)
- func (m *MockCollectionInterface) UpdateOne(ctx context.Context, filter, update interface{}, ...) (*mongo.UpdateResult, error)
- func (m *MockCollectionInterface) Watch(ctx context.Context, pipeline interface{}, ...) (*mongo.ChangeStream, error)
- type MockCollectionInterfaceMockRecorder
- func (mr *MockCollectionInterfaceMockRecorder) Aggregate(ctx, pipeline interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockCollectionInterfaceMockRecorder) BulkWrite(ctx, models interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockCollectionInterfaceMockRecorder) Clone(opts ...interface{}) *gomock.Call
- func (mr *MockCollectionInterfaceMockRecorder) CountDocuments(ctx, filter interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockCollectionInterfaceMockRecorder) Database() *gomock.Call
- func (mr *MockCollectionInterfaceMockRecorder) DeleteMany(ctx, filter interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockCollectionInterfaceMockRecorder) DeleteOne(ctx, filter interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockCollectionInterfaceMockRecorder) Distinct(ctx, fieldName, filter interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockCollectionInterfaceMockRecorder) Drop(ctx interface{}) *gomock.Call
- func (mr *MockCollectionInterfaceMockRecorder) EstimatedDocumentCount(ctx interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockCollectionInterfaceMockRecorder) Find(ctx, filter interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockCollectionInterfaceMockRecorder) FindOne(ctx, filter interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockCollectionInterfaceMockRecorder) FindOneAndDelete(ctx, filter interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockCollectionInterfaceMockRecorder) FindOneAndReplace(ctx, filter, replacement interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockCollectionInterfaceMockRecorder) FindOneAndUpdate(ctx, filter, update interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockCollectionInterfaceMockRecorder) Indexes() *gomock.Call
- func (mr *MockCollectionInterfaceMockRecorder) InsertMany(ctx, documents interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockCollectionInterfaceMockRecorder) InsertOne(ctx, document interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockCollectionInterfaceMockRecorder) Name() *gomock.Call
- func (mr *MockCollectionInterfaceMockRecorder) ReplaceOne(ctx, filter, replacement interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockCollectionInterfaceMockRecorder) UpdateMany(ctx, filter, update interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockCollectionInterfaceMockRecorder) UpdateOne(ctx, filter, update interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockCollectionInterfaceMockRecorder) Watch(ctx, pipeline interface{}, opts ...interface{}) *gomock.Call
- type MockCursorInterface
- func (m *MockCursorInterface) All(ctx context.Context, results interface{}) error
- func (m *MockCursorInterface) Close(ctx context.Context) error
- func (m *MockCursorInterface) Decode(val interface{}) error
- func (m *MockCursorInterface) EXPECT() *MockCursorInterfaceMockRecorder
- func (m *MockCursorInterface) Err() error
- func (m *MockCursorInterface) ID() int64
- func (m *MockCursorInterface) Next(ctx context.Context) bool
- func (m *MockCursorInterface) TryNext(ctx context.Context) bool
- type MockCursorInterfaceMockRecorder
- func (mr *MockCursorInterfaceMockRecorder) All(ctx, results interface{}) *gomock.Call
- func (mr *MockCursorInterfaceMockRecorder) Close(ctx interface{}) *gomock.Call
- func (mr *MockCursorInterfaceMockRecorder) Decode(val interface{}) *gomock.Call
- func (mr *MockCursorInterfaceMockRecorder) Err() *gomock.Call
- func (mr *MockCursorInterfaceMockRecorder) ID() *gomock.Call
- func (mr *MockCursorInterfaceMockRecorder) Next(ctx interface{}) *gomock.Call
- func (mr *MockCursorInterfaceMockRecorder) TryNext(ctx interface{}) *gomock.Call
- type MockDatabaseInterface
- func (m *MockDatabaseInterface) Aggregate(ctx context.Context, pipeline interface{}, opts ...*options.AggregateOptions) (pmongo.CursorInterface, error)
- func (m *MockDatabaseInterface) Client() pmongo.ClientInterface
- func (m *MockDatabaseInterface) Collection(name string, opts ...*options.CollectionOptions) pmongo.CollectionInterface
- func (m *MockDatabaseInterface) Drop(ctx context.Context) error
- func (m *MockDatabaseInterface) EXPECT() *MockDatabaseInterfaceMockRecorder
- func (m *MockDatabaseInterface) ListCollectionNames(ctx context.Context, filter interface{}, ...) ([]string, error)
- func (m *MockDatabaseInterface) ListCollections(ctx context.Context, filter interface{}, ...) (pmongo.CursorInterface, error)
- func (m *MockDatabaseInterface) Name() string
- func (m *MockDatabaseInterface) NewBucket(opts ...*options.BucketOptions) (pmongo.BucketInterface, error)
- func (m *MockDatabaseInterface) ReadConcern() *readconcern.ReadConcern
- func (m *MockDatabaseInterface) ReadPreference() *readpref.ReadPref
- func (m *MockDatabaseInterface) RunCommand(ctx context.Context, runCommand interface{}, opts ...*options.RunCmdOptions) pmongo.SingleResultInterface
- func (m *MockDatabaseInterface) RunCommandCursor(ctx context.Context, runCommand interface{}, opts ...*options.RunCmdOptions) (pmongo.CursorInterface, error)
- func (m *MockDatabaseInterface) Watch(ctx context.Context, pipeline interface{}, ...) (*mongo.ChangeStream, error)
- func (m *MockDatabaseInterface) WriteConcern() *writeconcern.WriteConcern
- type MockDatabaseInterfaceMockRecorder
- func (mr *MockDatabaseInterfaceMockRecorder) Aggregate(ctx, pipeline interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockDatabaseInterfaceMockRecorder) Client() *gomock.Call
- func (mr *MockDatabaseInterfaceMockRecorder) Collection(name interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockDatabaseInterfaceMockRecorder) Drop(ctx interface{}) *gomock.Call
- func (mr *MockDatabaseInterfaceMockRecorder) ListCollectionNames(ctx, filter interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockDatabaseInterfaceMockRecorder) ListCollections(ctx, filter interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockDatabaseInterfaceMockRecorder) Name() *gomock.Call
- func (mr *MockDatabaseInterfaceMockRecorder) NewBucket(opts ...interface{}) *gomock.Call
- func (mr *MockDatabaseInterfaceMockRecorder) ReadConcern() *gomock.Call
- func (mr *MockDatabaseInterfaceMockRecorder) ReadPreference() *gomock.Call
- func (mr *MockDatabaseInterfaceMockRecorder) RunCommand(ctx, runCommand interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockDatabaseInterfaceMockRecorder) RunCommandCursor(ctx, runCommand interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockDatabaseInterfaceMockRecorder) Watch(ctx, pipeline interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockDatabaseInterfaceMockRecorder) WriteConcern() *gomock.Call
- type MockDownloadStreamInterface
- func (m *MockDownloadStreamInterface) Close() error
- func (m *MockDownloadStreamInterface) EXPECT() *MockDownloadStreamInterfaceMockRecorder
- func (m *MockDownloadStreamInterface) Read(p []byte) (int, error)
- func (m *MockDownloadStreamInterface) SetReadDeadline(t time.Time) error
- func (m *MockDownloadStreamInterface) Skip(skip int64) (int64, error)
- type MockDownloadStreamInterfaceMockRecorder
- func (mr *MockDownloadStreamInterfaceMockRecorder) Close() *gomock.Call
- func (mr *MockDownloadStreamInterfaceMockRecorder) Read(p interface{}) *gomock.Call
- func (mr *MockDownloadStreamInterfaceMockRecorder) SetReadDeadline(t interface{}) *gomock.Call
- func (mr *MockDownloadStreamInterfaceMockRecorder) Skip(skip interface{}) *gomock.Call
- type MockIndexViewInterface
- func (m *MockIndexViewInterface) CreateMany(ctx context.Context, models []mongo.IndexModel, ...) ([]string, error)
- func (m *MockIndexViewInterface) CreateOne(ctx context.Context, model mongo.IndexModel, ...) (string, error)
- func (m *MockIndexViewInterface) DropAll(ctx context.Context, opts ...*options.DropIndexesOptions) (bson.Raw, error)
- func (m *MockIndexViewInterface) DropOne(ctx context.Context, name string, opts ...*options.DropIndexesOptions) (bson.Raw, error)
- func (m *MockIndexViewInterface) EXPECT() *MockIndexViewInterfaceMockRecorder
- func (m *MockIndexViewInterface) List(ctx context.Context, opts ...*options.ListIndexesOptions) (pmongo.CursorInterface, error)
- type MockIndexViewInterfaceMockRecorder
- func (mr *MockIndexViewInterfaceMockRecorder) CreateMany(ctx, models interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockIndexViewInterfaceMockRecorder) CreateOne(ctx, model interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockIndexViewInterfaceMockRecorder) DropAll(ctx interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockIndexViewInterfaceMockRecorder) DropOne(ctx, name interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockIndexViewInterfaceMockRecorder) List(ctx interface{}, opts ...interface{}) *gomock.Call
- type MockSessionInterface
- func (m *MockSessionInterface) AbortTransaction(ctx context.Context) error
- func (m *MockSessionInterface) AdvanceClusterTime(arg0 bson.Raw) error
- func (m *MockSessionInterface) AdvanceOperationTime(ts *primitive.Timestamp) error
- func (m *MockSessionInterface) Client() pmongo.ClientInterface
- func (m *MockSessionInterface) ClusterTime() bson.Raw
- func (m *MockSessionInterface) CommitTransaction(ctx context.Context) error
- func (m *MockSessionInterface) EXPECT() *MockSessionInterfaceMockRecorder
- func (m *MockSessionInterface) EndSession(ctx context.Context)
- func (m *MockSessionInterface) ID() bson.Raw
- func (m *MockSessionInterface) OperationTime() *primitive.Timestamp
- func (m *MockSessionInterface) StartTransaction(opts ...*options.TransactionOptions) error
- func (m *MockSessionInterface) WithTransaction(ctx context.Context, fn func(mongo.SessionContext) (interface{}, error), ...) (interface{}, error)
- type MockSessionInterfaceMockRecorder
- func (mr *MockSessionInterfaceMockRecorder) AbortTransaction(ctx interface{}) *gomock.Call
- func (mr *MockSessionInterfaceMockRecorder) AdvanceClusterTime(arg0 interface{}) *gomock.Call
- func (mr *MockSessionInterfaceMockRecorder) AdvanceOperationTime(ts interface{}) *gomock.Call
- func (mr *MockSessionInterfaceMockRecorder) Client() *gomock.Call
- func (mr *MockSessionInterfaceMockRecorder) ClusterTime() *gomock.Call
- func (mr *MockSessionInterfaceMockRecorder) CommitTransaction(ctx interface{}) *gomock.Call
- func (mr *MockSessionInterfaceMockRecorder) EndSession(ctx interface{}) *gomock.Call
- func (mr *MockSessionInterfaceMockRecorder) ID() *gomock.Call
- func (mr *MockSessionInterfaceMockRecorder) OperationTime() *gomock.Call
- func (mr *MockSessionInterfaceMockRecorder) StartTransaction(opts ...interface{}) *gomock.Call
- func (mr *MockSessionInterfaceMockRecorder) WithTransaction(ctx, fn interface{}, opts ...interface{}) *gomock.Call
- type MockSingleResultInterface
- type MockSingleResultInterfaceMockRecorder
- type MockUploadStreamInterface
- func (m *MockUploadStreamInterface) Abort() error
- func (m *MockUploadStreamInterface) Close() error
- func (m *MockUploadStreamInterface) EXPECT() *MockUploadStreamInterfaceMockRecorder
- func (m *MockUploadStreamInterface) SetWriteDeadline(t time.Time) error
- func (m *MockUploadStreamInterface) Write(p []byte) (int, error)
- type MockUploadStreamInterfaceMockRecorder
- func (mr *MockUploadStreamInterfaceMockRecorder) Abort() *gomock.Call
- func (mr *MockUploadStreamInterfaceMockRecorder) Close() *gomock.Call
- func (mr *MockUploadStreamInterfaceMockRecorder) SetWriteDeadline(t interface{}) *gomock.Call
- func (mr *MockUploadStreamInterfaceMockRecorder) Write(p interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockBucketInterface ¶
type MockBucketInterface struct {
// contains filtered or unexported fields
}
MockBucketInterface is a mock of BucketInterface interface.
func NewMockBucketInterface ¶
func NewMockBucketInterface(ctrl *gomock.Controller) *MockBucketInterface
NewMockBucketInterface creates a new mock instance.
func (*MockBucketInterface) Delete ¶
func (m *MockBucketInterface) Delete(fileID interface{}) error
Delete mocks base method.
func (*MockBucketInterface) DownloadToStream ¶
func (m *MockBucketInterface) DownloadToStream(fileID interface{}, stream io.Writer) (int64, error)
DownloadToStream mocks base method.
func (*MockBucketInterface) DownloadToStreamByName ¶
func (m *MockBucketInterface) DownloadToStreamByName(filename string, stream io.Writer, opts ...*options.NameOptions) (int64, error)
DownloadToStreamByName mocks base method.
func (*MockBucketInterface) Drop ¶
func (m *MockBucketInterface) Drop() error
Drop mocks base method.
func (*MockBucketInterface) EXPECT ¶
func (m *MockBucketInterface) EXPECT() *MockBucketInterfaceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockBucketInterface) Find ¶
func (m *MockBucketInterface) Find(filter interface{}, opts ...*options.GridFSFindOptions) (pmongo.CursorInterface, error)
Find mocks base method.
func (*MockBucketInterface) OpenDownloadStream ¶
func (m *MockBucketInterface) OpenDownloadStream(fileID interface{}) (pmongo.DownloadStreamInterface, error)
OpenDownloadStream mocks base method.
func (*MockBucketInterface) OpenDownloadStreamByName ¶
func (m *MockBucketInterface) OpenDownloadStreamByName(filename string, opts ...*options.NameOptions) (pmongo.DownloadStreamInterface, error)
OpenDownloadStreamByName mocks base method.
func (*MockBucketInterface) OpenUploadStream ¶
func (m *MockBucketInterface) OpenUploadStream(filename string, opts ...*options.UploadOptions) (pmongo.UploadStreamInterface, error)
OpenUploadStream mocks base method.
func (*MockBucketInterface) OpenUploadStreamWithID ¶
func (m *MockBucketInterface) OpenUploadStreamWithID(fileID interface{}, filename string, opts ...*options.UploadOptions) (pmongo.UploadStreamInterface, error)
OpenUploadStreamWithID mocks base method.
func (*MockBucketInterface) Rename ¶
func (m *MockBucketInterface) Rename(fileID interface{}, newFilename string) error
Rename mocks base method.
func (*MockBucketInterface) SetReadDeadline ¶
func (m *MockBucketInterface) SetReadDeadline(t time.Time) error
SetReadDeadline mocks base method.
func (*MockBucketInterface) SetWriteDeadline ¶
func (m *MockBucketInterface) SetWriteDeadline(t time.Time) error
SetWriteDeadline mocks base method.
func (*MockBucketInterface) UploadFromStream ¶
func (m *MockBucketInterface) UploadFromStream(filename string, source io.Reader, opts ...*options.UploadOptions) (primitive.ObjectID, error)
UploadFromStream mocks base method.
func (*MockBucketInterface) UploadFromStreamWithID ¶
func (m *MockBucketInterface) UploadFromStreamWithID(fileID interface{}, filename string, source io.Reader, opts ...*options.UploadOptions) error
UploadFromStreamWithID mocks base method.
type MockBucketInterfaceMockRecorder ¶
type MockBucketInterfaceMockRecorder struct {
// contains filtered or unexported fields
}
MockBucketInterfaceMockRecorder is the mock recorder for MockBucketInterface.
func (*MockBucketInterfaceMockRecorder) Delete ¶
func (mr *MockBucketInterfaceMockRecorder) Delete(fileID interface{}) *gomock.Call
Delete indicates an expected call of Delete.
func (*MockBucketInterfaceMockRecorder) DownloadToStream ¶
func (mr *MockBucketInterfaceMockRecorder) DownloadToStream(fileID, stream interface{}) *gomock.Call
DownloadToStream indicates an expected call of DownloadToStream.
func (*MockBucketInterfaceMockRecorder) DownloadToStreamByName ¶
func (mr *MockBucketInterfaceMockRecorder) DownloadToStreamByName(filename, stream interface{}, opts ...interface{}) *gomock.Call
DownloadToStreamByName indicates an expected call of DownloadToStreamByName.
func (*MockBucketInterfaceMockRecorder) Drop ¶
func (mr *MockBucketInterfaceMockRecorder) Drop() *gomock.Call
Drop indicates an expected call of Drop.
func (*MockBucketInterfaceMockRecorder) Find ¶
func (mr *MockBucketInterfaceMockRecorder) Find(filter interface{}, opts ...interface{}) *gomock.Call
Find indicates an expected call of Find.
func (*MockBucketInterfaceMockRecorder) OpenDownloadStream ¶
func (mr *MockBucketInterfaceMockRecorder) OpenDownloadStream(fileID interface{}) *gomock.Call
OpenDownloadStream indicates an expected call of OpenDownloadStream.
func (*MockBucketInterfaceMockRecorder) OpenDownloadStreamByName ¶
func (mr *MockBucketInterfaceMockRecorder) OpenDownloadStreamByName(filename interface{}, opts ...interface{}) *gomock.Call
OpenDownloadStreamByName indicates an expected call of OpenDownloadStreamByName.
func (*MockBucketInterfaceMockRecorder) OpenUploadStream ¶
func (mr *MockBucketInterfaceMockRecorder) OpenUploadStream(filename interface{}, opts ...interface{}) *gomock.Call
OpenUploadStream indicates an expected call of OpenUploadStream.
func (*MockBucketInterfaceMockRecorder) OpenUploadStreamWithID ¶
func (mr *MockBucketInterfaceMockRecorder) OpenUploadStreamWithID(fileID, filename interface{}, opts ...interface{}) *gomock.Call
OpenUploadStreamWithID indicates an expected call of OpenUploadStreamWithID.
func (*MockBucketInterfaceMockRecorder) Rename ¶
func (mr *MockBucketInterfaceMockRecorder) Rename(fileID, newFilename interface{}) *gomock.Call
Rename indicates an expected call of Rename.
func (*MockBucketInterfaceMockRecorder) SetReadDeadline ¶
func (mr *MockBucketInterfaceMockRecorder) SetReadDeadline(t interface{}) *gomock.Call
SetReadDeadline indicates an expected call of SetReadDeadline.
func (*MockBucketInterfaceMockRecorder) SetWriteDeadline ¶
func (mr *MockBucketInterfaceMockRecorder) SetWriteDeadline(t interface{}) *gomock.Call
SetWriteDeadline indicates an expected call of SetWriteDeadline.
func (*MockBucketInterfaceMockRecorder) UploadFromStream ¶
func (mr *MockBucketInterfaceMockRecorder) UploadFromStream(filename, source interface{}, opts ...interface{}) *gomock.Call
UploadFromStream indicates an expected call of UploadFromStream.
func (*MockBucketInterfaceMockRecorder) UploadFromStreamWithID ¶
func (mr *MockBucketInterfaceMockRecorder) UploadFromStreamWithID(fileID, filename, source interface{}, opts ...interface{}) *gomock.Call
UploadFromStreamWithID indicates an expected call of UploadFromStreamWithID.
type MockClientInterface ¶
type MockClientInterface struct {
// contains filtered or unexported fields
}
MockClientInterface is a mock of ClientInterface interface.
func NewMockClientInterface ¶
func NewMockClientInterface(ctrl *gomock.Controller) *MockClientInterface
NewMockClientInterface creates a new mock instance.
func (*MockClientInterface) Connect ¶
func (m *MockClientInterface) Connect(ctx context.Context) error
Connect mocks base method.
func (*MockClientInterface) Database ¶
func (m *MockClientInterface) Database(name string, opts ...*options.DatabaseOptions) pmongo.DatabaseInterface
Database mocks base method.
func (*MockClientInterface) Disconnect ¶
func (m *MockClientInterface) Disconnect(ctx context.Context) error
Disconnect mocks base method.
func (*MockClientInterface) EXPECT ¶
func (m *MockClientInterface) EXPECT() *MockClientInterfaceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockClientInterface) ListDatabaseNames ¶
func (m *MockClientInterface) ListDatabaseNames(ctx context.Context, filter interface{}, opts ...*options.ListDatabasesOptions) ([]string, error)
ListDatabaseNames mocks base method.
func (*MockClientInterface) ListDatabases ¶
func (m *MockClientInterface) ListDatabases(ctx context.Context, filter interface{}, opts ...*options.ListDatabasesOptions) (mongo.ListDatabasesResult, error)
ListDatabases mocks base method.
func (*MockClientInterface) NumberSessionsInProgress ¶
func (m *MockClientInterface) NumberSessionsInProgress() int
NumberSessionsInProgress mocks base method.
func (*MockClientInterface) StartSession ¶
func (m *MockClientInterface) StartSession(opts ...*options.SessionOptions) (pmongo.SessionInterface, error)
StartSession mocks base method.
func (*MockClientInterface) UseSession ¶
func (m *MockClientInterface) UseSession(ctx context.Context, fn func(mongo.SessionContext) error) error
UseSession mocks base method.
func (*MockClientInterface) UseSessionWithOptions ¶
func (m *MockClientInterface) UseSessionWithOptions(ctx context.Context, opts *options.SessionOptions, fn func(mongo.SessionContext) error) error
UseSessionWithOptions mocks base method.
func (*MockClientInterface) Watch ¶
func (m *MockClientInterface) Watch(ctx context.Context, pipeline interface{}, opts ...*options.ChangeStreamOptions) (*mongo.ChangeStream, error)
Watch mocks base method.
type MockClientInterfaceMockRecorder ¶
type MockClientInterfaceMockRecorder struct {
// contains filtered or unexported fields
}
MockClientInterfaceMockRecorder is the mock recorder for MockClientInterface.
func (*MockClientInterfaceMockRecorder) Connect ¶
func (mr *MockClientInterfaceMockRecorder) Connect(ctx interface{}) *gomock.Call
Connect indicates an expected call of Connect.
func (*MockClientInterfaceMockRecorder) Database ¶
func (mr *MockClientInterfaceMockRecorder) Database(name interface{}, opts ...interface{}) *gomock.Call
Database indicates an expected call of Database.
func (*MockClientInterfaceMockRecorder) Disconnect ¶
func (mr *MockClientInterfaceMockRecorder) Disconnect(ctx interface{}) *gomock.Call
Disconnect indicates an expected call of Disconnect.
func (*MockClientInterfaceMockRecorder) ListDatabaseNames ¶
func (mr *MockClientInterfaceMockRecorder) ListDatabaseNames(ctx, filter interface{}, opts ...interface{}) *gomock.Call
ListDatabaseNames indicates an expected call of ListDatabaseNames.
func (*MockClientInterfaceMockRecorder) ListDatabases ¶
func (mr *MockClientInterfaceMockRecorder) ListDatabases(ctx, filter interface{}, opts ...interface{}) *gomock.Call
ListDatabases indicates an expected call of ListDatabases.
func (*MockClientInterfaceMockRecorder) NumberSessionsInProgress ¶
func (mr *MockClientInterfaceMockRecorder) NumberSessionsInProgress() *gomock.Call
NumberSessionsInProgress indicates an expected call of NumberSessionsInProgress.
func (*MockClientInterfaceMockRecorder) Ping ¶
func (mr *MockClientInterfaceMockRecorder) Ping(ctx, rp interface{}) *gomock.Call
Ping indicates an expected call of Ping.
func (*MockClientInterfaceMockRecorder) StartSession ¶
func (mr *MockClientInterfaceMockRecorder) StartSession(opts ...interface{}) *gomock.Call
StartSession indicates an expected call of StartSession.
func (*MockClientInterfaceMockRecorder) UseSession ¶
func (mr *MockClientInterfaceMockRecorder) UseSession(ctx, fn interface{}) *gomock.Call
UseSession indicates an expected call of UseSession.
func (*MockClientInterfaceMockRecorder) UseSessionWithOptions ¶
func (mr *MockClientInterfaceMockRecorder) UseSessionWithOptions(ctx, opts, fn interface{}) *gomock.Call
UseSessionWithOptions indicates an expected call of UseSessionWithOptions.
func (*MockClientInterfaceMockRecorder) Watch ¶
func (mr *MockClientInterfaceMockRecorder) Watch(ctx, pipeline interface{}, opts ...interface{}) *gomock.Call
Watch indicates an expected call of Watch.
type MockCollectionInterface ¶
type MockCollectionInterface struct {
// contains filtered or unexported fields
}
MockCollectionInterface is a mock of CollectionInterface interface.
func NewMockCollectionInterface ¶
func NewMockCollectionInterface(ctrl *gomock.Controller) *MockCollectionInterface
NewMockCollectionInterface creates a new mock instance.
func (*MockCollectionInterface) Aggregate ¶
func (m *MockCollectionInterface) Aggregate(ctx context.Context, pipeline interface{}, opts ...*options.AggregateOptions) (pmongo.CursorInterface, error)
Aggregate mocks base method.
func (*MockCollectionInterface) BulkWrite ¶
func (m *MockCollectionInterface) BulkWrite(ctx context.Context, models []mongo.WriteModel, opts ...*options.BulkWriteOptions) (*mongo.BulkWriteResult, error)
BulkWrite mocks base method.
func (*MockCollectionInterface) Clone ¶
func (m *MockCollectionInterface) Clone(opts ...*options.CollectionOptions) (pmongo.CollectionInterface, error)
Clone mocks base method.
func (*MockCollectionInterface) CountDocuments ¶
func (m *MockCollectionInterface) CountDocuments(ctx context.Context, filter interface{}, opts ...*options.CountOptions) (int64, error)
CountDocuments mocks base method.
func (*MockCollectionInterface) Database ¶
func (m *MockCollectionInterface) Database() pmongo.DatabaseInterface
Database mocks base method.
func (*MockCollectionInterface) DeleteMany ¶
func (m *MockCollectionInterface) DeleteMany(ctx context.Context, filter interface{}, opts ...*options.DeleteOptions) (*mongo.DeleteResult, error)
DeleteMany mocks base method.
func (*MockCollectionInterface) DeleteOne ¶
func (m *MockCollectionInterface) DeleteOne(ctx context.Context, filter interface{}, opts ...*options.DeleteOptions) (*mongo.DeleteResult, error)
DeleteOne mocks base method.
func (*MockCollectionInterface) Distinct ¶
func (m *MockCollectionInterface) Distinct(ctx context.Context, fieldName string, filter interface{}, opts ...*options.DistinctOptions) ([]interface{}, error)
Distinct mocks base method.
func (*MockCollectionInterface) Drop ¶
func (m *MockCollectionInterface) Drop(ctx context.Context) error
Drop mocks base method.
func (*MockCollectionInterface) EXPECT ¶
func (m *MockCollectionInterface) EXPECT() *MockCollectionInterfaceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockCollectionInterface) EstimatedDocumentCount ¶
func (m *MockCollectionInterface) EstimatedDocumentCount(ctx context.Context, opts ...*options.EstimatedDocumentCountOptions) (int64, error)
EstimatedDocumentCount mocks base method.
func (*MockCollectionInterface) Find ¶
func (m *MockCollectionInterface) Find(ctx context.Context, filter interface{}, opts ...*options.FindOptions) (pmongo.CursorInterface, error)
Find mocks base method.
func (*MockCollectionInterface) FindOne ¶
func (m *MockCollectionInterface) FindOne(ctx context.Context, filter interface{}, opts ...*options.FindOneOptions) pmongo.SingleResultInterface
FindOne mocks base method.
func (*MockCollectionInterface) FindOneAndDelete ¶
func (m *MockCollectionInterface) FindOneAndDelete(ctx context.Context, filter interface{}, opts ...*options.FindOneAndDeleteOptions) pmongo.SingleResultInterface
FindOneAndDelete mocks base method.
func (*MockCollectionInterface) FindOneAndReplace ¶
func (m *MockCollectionInterface) FindOneAndReplace(ctx context.Context, filter, replacement interface{}, opts ...*options.FindOneAndReplaceOptions) pmongo.SingleResultInterface
FindOneAndReplace mocks base method.
func (*MockCollectionInterface) FindOneAndUpdate ¶
func (m *MockCollectionInterface) FindOneAndUpdate(ctx context.Context, filter, update interface{}, opts ...*options.FindOneAndUpdateOptions) pmongo.SingleResultInterface
FindOneAndUpdate mocks base method.
func (*MockCollectionInterface) Indexes ¶
func (m *MockCollectionInterface) Indexes() pmongo.IndexViewInterface
Indexes mocks base method.
func (*MockCollectionInterface) InsertMany ¶
func (m *MockCollectionInterface) InsertMany(ctx context.Context, documents []interface{}, opts ...*options.InsertManyOptions) (*mongo.InsertManyResult, error)
InsertMany mocks base method.
func (*MockCollectionInterface) InsertOne ¶
func (m *MockCollectionInterface) InsertOne(ctx context.Context, document interface{}, opts ...*options.InsertOneOptions) (*mongo.InsertOneResult, error)
InsertOne mocks base method.
func (*MockCollectionInterface) Name ¶
func (m *MockCollectionInterface) Name() string
Name mocks base method.
func (*MockCollectionInterface) ReplaceOne ¶
func (m *MockCollectionInterface) ReplaceOne(ctx context.Context, filter, replacement interface{}, opts ...*options.ReplaceOptions) (*mongo.UpdateResult, error)
ReplaceOne mocks base method.
func (*MockCollectionInterface) UpdateMany ¶
func (m *MockCollectionInterface) UpdateMany(ctx context.Context, filter, update interface{}, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error)
UpdateMany mocks base method.
func (*MockCollectionInterface) UpdateOne ¶
func (m *MockCollectionInterface) UpdateOne(ctx context.Context, filter, update interface{}, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error)
UpdateOne mocks base method.
func (*MockCollectionInterface) Watch ¶
func (m *MockCollectionInterface) Watch(ctx context.Context, pipeline interface{}, opts ...*options.ChangeStreamOptions) (*mongo.ChangeStream, error)
Watch mocks base method.
type MockCollectionInterfaceMockRecorder ¶
type MockCollectionInterfaceMockRecorder struct {
// contains filtered or unexported fields
}
MockCollectionInterfaceMockRecorder is the mock recorder for MockCollectionInterface.
func (*MockCollectionInterfaceMockRecorder) Aggregate ¶
func (mr *MockCollectionInterfaceMockRecorder) Aggregate(ctx, pipeline interface{}, opts ...interface{}) *gomock.Call
Aggregate indicates an expected call of Aggregate.
func (*MockCollectionInterfaceMockRecorder) BulkWrite ¶
func (mr *MockCollectionInterfaceMockRecorder) BulkWrite(ctx, models interface{}, opts ...interface{}) *gomock.Call
BulkWrite indicates an expected call of BulkWrite.
func (*MockCollectionInterfaceMockRecorder) Clone ¶
func (mr *MockCollectionInterfaceMockRecorder) Clone(opts ...interface{}) *gomock.Call
Clone indicates an expected call of Clone.
func (*MockCollectionInterfaceMockRecorder) CountDocuments ¶
func (mr *MockCollectionInterfaceMockRecorder) CountDocuments(ctx, filter interface{}, opts ...interface{}) *gomock.Call
CountDocuments indicates an expected call of CountDocuments.
func (*MockCollectionInterfaceMockRecorder) Database ¶
func (mr *MockCollectionInterfaceMockRecorder) Database() *gomock.Call
Database indicates an expected call of Database.
func (*MockCollectionInterfaceMockRecorder) DeleteMany ¶
func (mr *MockCollectionInterfaceMockRecorder) DeleteMany(ctx, filter interface{}, opts ...interface{}) *gomock.Call
DeleteMany indicates an expected call of DeleteMany.
func (*MockCollectionInterfaceMockRecorder) DeleteOne ¶
func (mr *MockCollectionInterfaceMockRecorder) DeleteOne(ctx, filter interface{}, opts ...interface{}) *gomock.Call
DeleteOne indicates an expected call of DeleteOne.
func (*MockCollectionInterfaceMockRecorder) Distinct ¶
func (mr *MockCollectionInterfaceMockRecorder) Distinct(ctx, fieldName, filter interface{}, opts ...interface{}) *gomock.Call
Distinct indicates an expected call of Distinct.
func (*MockCollectionInterfaceMockRecorder) Drop ¶
func (mr *MockCollectionInterfaceMockRecorder) Drop(ctx interface{}) *gomock.Call
Drop indicates an expected call of Drop.
func (*MockCollectionInterfaceMockRecorder) EstimatedDocumentCount ¶
func (mr *MockCollectionInterfaceMockRecorder) EstimatedDocumentCount(ctx interface{}, opts ...interface{}) *gomock.Call
EstimatedDocumentCount indicates an expected call of EstimatedDocumentCount.
func (*MockCollectionInterfaceMockRecorder) Find ¶
func (mr *MockCollectionInterfaceMockRecorder) Find(ctx, filter interface{}, opts ...interface{}) *gomock.Call
Find indicates an expected call of Find.
func (*MockCollectionInterfaceMockRecorder) FindOne ¶
func (mr *MockCollectionInterfaceMockRecorder) FindOne(ctx, filter interface{}, opts ...interface{}) *gomock.Call
FindOne indicates an expected call of FindOne.
func (*MockCollectionInterfaceMockRecorder) FindOneAndDelete ¶
func (mr *MockCollectionInterfaceMockRecorder) FindOneAndDelete(ctx, filter interface{}, opts ...interface{}) *gomock.Call
FindOneAndDelete indicates an expected call of FindOneAndDelete.
func (*MockCollectionInterfaceMockRecorder) FindOneAndReplace ¶
func (mr *MockCollectionInterfaceMockRecorder) FindOneAndReplace(ctx, filter, replacement interface{}, opts ...interface{}) *gomock.Call
FindOneAndReplace indicates an expected call of FindOneAndReplace.
func (*MockCollectionInterfaceMockRecorder) FindOneAndUpdate ¶
func (mr *MockCollectionInterfaceMockRecorder) FindOneAndUpdate(ctx, filter, update interface{}, opts ...interface{}) *gomock.Call
FindOneAndUpdate indicates an expected call of FindOneAndUpdate.
func (*MockCollectionInterfaceMockRecorder) Indexes ¶
func (mr *MockCollectionInterfaceMockRecorder) Indexes() *gomock.Call
Indexes indicates an expected call of Indexes.
func (*MockCollectionInterfaceMockRecorder) InsertMany ¶
func (mr *MockCollectionInterfaceMockRecorder) InsertMany(ctx, documents interface{}, opts ...interface{}) *gomock.Call
InsertMany indicates an expected call of InsertMany.
func (*MockCollectionInterfaceMockRecorder) InsertOne ¶
func (mr *MockCollectionInterfaceMockRecorder) InsertOne(ctx, document interface{}, opts ...interface{}) *gomock.Call
InsertOne indicates an expected call of InsertOne.
func (*MockCollectionInterfaceMockRecorder) Name ¶
func (mr *MockCollectionInterfaceMockRecorder) Name() *gomock.Call
Name indicates an expected call of Name.
func (*MockCollectionInterfaceMockRecorder) ReplaceOne ¶
func (mr *MockCollectionInterfaceMockRecorder) ReplaceOne(ctx, filter, replacement interface{}, opts ...interface{}) *gomock.Call
ReplaceOne indicates an expected call of ReplaceOne.
func (*MockCollectionInterfaceMockRecorder) UpdateMany ¶
func (mr *MockCollectionInterfaceMockRecorder) UpdateMany(ctx, filter, update interface{}, opts ...interface{}) *gomock.Call
UpdateMany indicates an expected call of UpdateMany.
func (*MockCollectionInterfaceMockRecorder) UpdateOne ¶
func (mr *MockCollectionInterfaceMockRecorder) UpdateOne(ctx, filter, update interface{}, opts ...interface{}) *gomock.Call
UpdateOne indicates an expected call of UpdateOne.
func (*MockCollectionInterfaceMockRecorder) Watch ¶
func (mr *MockCollectionInterfaceMockRecorder) Watch(ctx, pipeline interface{}, opts ...interface{}) *gomock.Call
Watch indicates an expected call of Watch.
type MockCursorInterface ¶
type MockCursorInterface struct {
// contains filtered or unexported fields
}
MockCursorInterface is a mock of CursorInterface interface.
func NewMockCursorInterface ¶
func NewMockCursorInterface(ctrl *gomock.Controller) *MockCursorInterface
NewMockCursorInterface creates a new mock instance.
func (*MockCursorInterface) All ¶
func (m *MockCursorInterface) All(ctx context.Context, results interface{}) error
All mocks base method.
func (*MockCursorInterface) Close ¶
func (m *MockCursorInterface) Close(ctx context.Context) error
Close mocks base method.
func (*MockCursorInterface) Decode ¶
func (m *MockCursorInterface) Decode(val interface{}) error
Decode mocks base method.
func (*MockCursorInterface) EXPECT ¶
func (m *MockCursorInterface) EXPECT() *MockCursorInterfaceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockCursorInterfaceMockRecorder ¶
type MockCursorInterfaceMockRecorder struct {
// contains filtered or unexported fields
}
MockCursorInterfaceMockRecorder is the mock recorder for MockCursorInterface.
func (*MockCursorInterfaceMockRecorder) All ¶
func (mr *MockCursorInterfaceMockRecorder) All(ctx, results interface{}) *gomock.Call
All indicates an expected call of All.
func (*MockCursorInterfaceMockRecorder) Close ¶
func (mr *MockCursorInterfaceMockRecorder) Close(ctx interface{}) *gomock.Call
Close indicates an expected call of Close.
func (*MockCursorInterfaceMockRecorder) Decode ¶
func (mr *MockCursorInterfaceMockRecorder) Decode(val interface{}) *gomock.Call
Decode indicates an expected call of Decode.
func (*MockCursorInterfaceMockRecorder) Err ¶
func (mr *MockCursorInterfaceMockRecorder) Err() *gomock.Call
Err indicates an expected call of Err.
func (*MockCursorInterfaceMockRecorder) ID ¶
func (mr *MockCursorInterfaceMockRecorder) ID() *gomock.Call
ID indicates an expected call of ID.
func (*MockCursorInterfaceMockRecorder) Next ¶
func (mr *MockCursorInterfaceMockRecorder) Next(ctx interface{}) *gomock.Call
Next indicates an expected call of Next.
func (*MockCursorInterfaceMockRecorder) TryNext ¶
func (mr *MockCursorInterfaceMockRecorder) TryNext(ctx interface{}) *gomock.Call
TryNext indicates an expected call of TryNext.
type MockDatabaseInterface ¶
type MockDatabaseInterface struct {
// contains filtered or unexported fields
}
MockDatabaseInterface is a mock of DatabaseInterface interface.
func NewMockDatabaseInterface ¶
func NewMockDatabaseInterface(ctrl *gomock.Controller) *MockDatabaseInterface
NewMockDatabaseInterface creates a new mock instance.
func (*MockDatabaseInterface) Aggregate ¶
func (m *MockDatabaseInterface) Aggregate(ctx context.Context, pipeline interface{}, opts ...*options.AggregateOptions) (pmongo.CursorInterface, error)
Aggregate mocks base method.
func (*MockDatabaseInterface) Client ¶
func (m *MockDatabaseInterface) Client() pmongo.ClientInterface
Client mocks base method.
func (*MockDatabaseInterface) Collection ¶
func (m *MockDatabaseInterface) Collection(name string, opts ...*options.CollectionOptions) pmongo.CollectionInterface
Collection mocks base method.
func (*MockDatabaseInterface) Drop ¶
func (m *MockDatabaseInterface) Drop(ctx context.Context) error
Drop mocks base method.
func (*MockDatabaseInterface) EXPECT ¶
func (m *MockDatabaseInterface) EXPECT() *MockDatabaseInterfaceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDatabaseInterface) ListCollectionNames ¶
func (m *MockDatabaseInterface) ListCollectionNames(ctx context.Context, filter interface{}, opts ...*options.ListCollectionsOptions) ([]string, error)
ListCollectionNames mocks base method.
func (*MockDatabaseInterface) ListCollections ¶
func (m *MockDatabaseInterface) ListCollections(ctx context.Context, filter interface{}, opts ...*options.ListCollectionsOptions) (pmongo.CursorInterface, error)
ListCollections mocks base method.
func (*MockDatabaseInterface) Name ¶
func (m *MockDatabaseInterface) Name() string
Name mocks base method.
func (*MockDatabaseInterface) NewBucket ¶
func (m *MockDatabaseInterface) NewBucket(opts ...*options.BucketOptions) (pmongo.BucketInterface, error)
NewBucket mocks base method.
func (*MockDatabaseInterface) ReadConcern ¶
func (m *MockDatabaseInterface) ReadConcern() *readconcern.ReadConcern
ReadConcern mocks base method.
func (*MockDatabaseInterface) ReadPreference ¶
func (m *MockDatabaseInterface) ReadPreference() *readpref.ReadPref
ReadPreference mocks base method.
func (*MockDatabaseInterface) RunCommand ¶
func (m *MockDatabaseInterface) RunCommand(ctx context.Context, runCommand interface{}, opts ...*options.RunCmdOptions) pmongo.SingleResultInterface
RunCommand mocks base method.
func (*MockDatabaseInterface) RunCommandCursor ¶
func (m *MockDatabaseInterface) RunCommandCursor(ctx context.Context, runCommand interface{}, opts ...*options.RunCmdOptions) (pmongo.CursorInterface, error)
RunCommandCursor mocks base method.
func (*MockDatabaseInterface) Watch ¶
func (m *MockDatabaseInterface) Watch(ctx context.Context, pipeline interface{}, opts ...*options.ChangeStreamOptions) (*mongo.ChangeStream, error)
Watch mocks base method.
func (*MockDatabaseInterface) WriteConcern ¶
func (m *MockDatabaseInterface) WriteConcern() *writeconcern.WriteConcern
WriteConcern mocks base method.
type MockDatabaseInterfaceMockRecorder ¶
type MockDatabaseInterfaceMockRecorder struct {
// contains filtered or unexported fields
}
MockDatabaseInterfaceMockRecorder is the mock recorder for MockDatabaseInterface.
func (*MockDatabaseInterfaceMockRecorder) Aggregate ¶
func (mr *MockDatabaseInterfaceMockRecorder) Aggregate(ctx, pipeline interface{}, opts ...interface{}) *gomock.Call
Aggregate indicates an expected call of Aggregate.
func (*MockDatabaseInterfaceMockRecorder) Client ¶
func (mr *MockDatabaseInterfaceMockRecorder) Client() *gomock.Call
Client indicates an expected call of Client.
func (*MockDatabaseInterfaceMockRecorder) Collection ¶
func (mr *MockDatabaseInterfaceMockRecorder) Collection(name interface{}, opts ...interface{}) *gomock.Call
Collection indicates an expected call of Collection.
func (*MockDatabaseInterfaceMockRecorder) Drop ¶
func (mr *MockDatabaseInterfaceMockRecorder) Drop(ctx interface{}) *gomock.Call
Drop indicates an expected call of Drop.
func (*MockDatabaseInterfaceMockRecorder) ListCollectionNames ¶
func (mr *MockDatabaseInterfaceMockRecorder) ListCollectionNames(ctx, filter interface{}, opts ...interface{}) *gomock.Call
ListCollectionNames indicates an expected call of ListCollectionNames.
func (*MockDatabaseInterfaceMockRecorder) ListCollections ¶
func (mr *MockDatabaseInterfaceMockRecorder) ListCollections(ctx, filter interface{}, opts ...interface{}) *gomock.Call
ListCollections indicates an expected call of ListCollections.
func (*MockDatabaseInterfaceMockRecorder) Name ¶
func (mr *MockDatabaseInterfaceMockRecorder) Name() *gomock.Call
Name indicates an expected call of Name.
func (*MockDatabaseInterfaceMockRecorder) NewBucket ¶
func (mr *MockDatabaseInterfaceMockRecorder) NewBucket(opts ...interface{}) *gomock.Call
NewBucket indicates an expected call of NewBucket.
func (*MockDatabaseInterfaceMockRecorder) ReadConcern ¶
func (mr *MockDatabaseInterfaceMockRecorder) ReadConcern() *gomock.Call
ReadConcern indicates an expected call of ReadConcern.
func (*MockDatabaseInterfaceMockRecorder) ReadPreference ¶
func (mr *MockDatabaseInterfaceMockRecorder) ReadPreference() *gomock.Call
ReadPreference indicates an expected call of ReadPreference.
func (*MockDatabaseInterfaceMockRecorder) RunCommand ¶
func (mr *MockDatabaseInterfaceMockRecorder) RunCommand(ctx, runCommand interface{}, opts ...interface{}) *gomock.Call
RunCommand indicates an expected call of RunCommand.
func (*MockDatabaseInterfaceMockRecorder) RunCommandCursor ¶
func (mr *MockDatabaseInterfaceMockRecorder) RunCommandCursor(ctx, runCommand interface{}, opts ...interface{}) *gomock.Call
RunCommandCursor indicates an expected call of RunCommandCursor.
func (*MockDatabaseInterfaceMockRecorder) Watch ¶
func (mr *MockDatabaseInterfaceMockRecorder) Watch(ctx, pipeline interface{}, opts ...interface{}) *gomock.Call
Watch indicates an expected call of Watch.
func (*MockDatabaseInterfaceMockRecorder) WriteConcern ¶
func (mr *MockDatabaseInterfaceMockRecorder) WriteConcern() *gomock.Call
WriteConcern indicates an expected call of WriteConcern.
type MockDownloadStreamInterface ¶
type MockDownloadStreamInterface struct {
// contains filtered or unexported fields
}
MockDownloadStreamInterface is a mock of DownloadStreamInterface interface.
func NewMockDownloadStreamInterface ¶
func NewMockDownloadStreamInterface(ctrl *gomock.Controller) *MockDownloadStreamInterface
NewMockDownloadStreamInterface creates a new mock instance.
func (*MockDownloadStreamInterface) Close ¶
func (m *MockDownloadStreamInterface) Close() error
Close mocks base method.
func (*MockDownloadStreamInterface) EXPECT ¶
func (m *MockDownloadStreamInterface) EXPECT() *MockDownloadStreamInterfaceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDownloadStreamInterface) Read ¶
func (m *MockDownloadStreamInterface) Read(p []byte) (int, error)
Read mocks base method.
func (*MockDownloadStreamInterface) SetReadDeadline ¶
func (m *MockDownloadStreamInterface) SetReadDeadline(t time.Time) error
SetReadDeadline mocks base method.
type MockDownloadStreamInterfaceMockRecorder ¶
type MockDownloadStreamInterfaceMockRecorder struct {
// contains filtered or unexported fields
}
MockDownloadStreamInterfaceMockRecorder is the mock recorder for MockDownloadStreamInterface.
func (*MockDownloadStreamInterfaceMockRecorder) Close ¶
func (mr *MockDownloadStreamInterfaceMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockDownloadStreamInterfaceMockRecorder) Read ¶
func (mr *MockDownloadStreamInterfaceMockRecorder) Read(p interface{}) *gomock.Call
Read indicates an expected call of Read.
func (*MockDownloadStreamInterfaceMockRecorder) SetReadDeadline ¶
func (mr *MockDownloadStreamInterfaceMockRecorder) SetReadDeadline(t interface{}) *gomock.Call
SetReadDeadline indicates an expected call of SetReadDeadline.
func (*MockDownloadStreamInterfaceMockRecorder) Skip ¶
func (mr *MockDownloadStreamInterfaceMockRecorder) Skip(skip interface{}) *gomock.Call
Skip indicates an expected call of Skip.
type MockIndexViewInterface ¶
type MockIndexViewInterface struct {
// contains filtered or unexported fields
}
MockIndexViewInterface is a mock of IndexViewInterface interface.
func NewMockIndexViewInterface ¶
func NewMockIndexViewInterface(ctrl *gomock.Controller) *MockIndexViewInterface
NewMockIndexViewInterface creates a new mock instance.
func (*MockIndexViewInterface) CreateMany ¶
func (m *MockIndexViewInterface) CreateMany(ctx context.Context, models []mongo.IndexModel, opts ...*options.CreateIndexesOptions) ([]string, error)
CreateMany mocks base method.
func (*MockIndexViewInterface) CreateOne ¶
func (m *MockIndexViewInterface) CreateOne(ctx context.Context, model mongo.IndexModel, opts ...*options.CreateIndexesOptions) (string, error)
CreateOne mocks base method.
func (*MockIndexViewInterface) DropAll ¶
func (m *MockIndexViewInterface) DropAll(ctx context.Context, opts ...*options.DropIndexesOptions) (bson.Raw, error)
DropAll mocks base method.
func (*MockIndexViewInterface) DropOne ¶
func (m *MockIndexViewInterface) DropOne(ctx context.Context, name string, opts ...*options.DropIndexesOptions) (bson.Raw, error)
DropOne mocks base method.
func (*MockIndexViewInterface) EXPECT ¶
func (m *MockIndexViewInterface) EXPECT() *MockIndexViewInterfaceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockIndexViewInterface) List ¶
func (m *MockIndexViewInterface) List(ctx context.Context, opts ...*options.ListIndexesOptions) (pmongo.CursorInterface, error)
List mocks base method.
type MockIndexViewInterfaceMockRecorder ¶
type MockIndexViewInterfaceMockRecorder struct {
// contains filtered or unexported fields
}
MockIndexViewInterfaceMockRecorder is the mock recorder for MockIndexViewInterface.
func (*MockIndexViewInterfaceMockRecorder) CreateMany ¶
func (mr *MockIndexViewInterfaceMockRecorder) CreateMany(ctx, models interface{}, opts ...interface{}) *gomock.Call
CreateMany indicates an expected call of CreateMany.
func (*MockIndexViewInterfaceMockRecorder) CreateOne ¶
func (mr *MockIndexViewInterfaceMockRecorder) CreateOne(ctx, model interface{}, opts ...interface{}) *gomock.Call
CreateOne indicates an expected call of CreateOne.
func (*MockIndexViewInterfaceMockRecorder) DropAll ¶
func (mr *MockIndexViewInterfaceMockRecorder) DropAll(ctx interface{}, opts ...interface{}) *gomock.Call
DropAll indicates an expected call of DropAll.
func (*MockIndexViewInterfaceMockRecorder) DropOne ¶
func (mr *MockIndexViewInterfaceMockRecorder) DropOne(ctx, name interface{}, opts ...interface{}) *gomock.Call
DropOne indicates an expected call of DropOne.
func (*MockIndexViewInterfaceMockRecorder) List ¶
func (mr *MockIndexViewInterfaceMockRecorder) List(ctx interface{}, opts ...interface{}) *gomock.Call
List indicates an expected call of List.
type MockSessionInterface ¶
type MockSessionInterface struct {
// contains filtered or unexported fields
}
MockSessionInterface is a mock of SessionInterface interface.
func NewMockSessionInterface ¶
func NewMockSessionInterface(ctrl *gomock.Controller) *MockSessionInterface
NewMockSessionInterface creates a new mock instance.
func (*MockSessionInterface) AbortTransaction ¶
func (m *MockSessionInterface) AbortTransaction(ctx context.Context) error
AbortTransaction mocks base method.
func (*MockSessionInterface) AdvanceClusterTime ¶
func (m *MockSessionInterface) AdvanceClusterTime(arg0 bson.Raw) error
AdvanceClusterTime mocks base method.
func (*MockSessionInterface) AdvanceOperationTime ¶
func (m *MockSessionInterface) AdvanceOperationTime(ts *primitive.Timestamp) error
AdvanceOperationTime mocks base method.
func (*MockSessionInterface) Client ¶
func (m *MockSessionInterface) Client() pmongo.ClientInterface
Client mocks base method.
func (*MockSessionInterface) ClusterTime ¶
func (m *MockSessionInterface) ClusterTime() bson.Raw
ClusterTime mocks base method.
func (*MockSessionInterface) CommitTransaction ¶
func (m *MockSessionInterface) CommitTransaction(ctx context.Context) error
CommitTransaction mocks base method.
func (*MockSessionInterface) EXPECT ¶
func (m *MockSessionInterface) EXPECT() *MockSessionInterfaceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockSessionInterface) EndSession ¶
func (m *MockSessionInterface) EndSession(ctx context.Context)
EndSession mocks base method.
func (*MockSessionInterface) ID ¶
func (m *MockSessionInterface) ID() bson.Raw
ID mocks base method.
func (*MockSessionInterface) OperationTime ¶
func (m *MockSessionInterface) OperationTime() *primitive.Timestamp
OperationTime mocks base method.
func (*MockSessionInterface) StartTransaction ¶
func (m *MockSessionInterface) StartTransaction(opts ...*options.TransactionOptions) error
StartTransaction mocks base method.
func (*MockSessionInterface) WithTransaction ¶
func (m *MockSessionInterface) WithTransaction(ctx context.Context, fn func(mongo.SessionContext) (interface{}, error), opts ...*options.TransactionOptions) (interface{}, error)
WithTransaction mocks base method.
type MockSessionInterfaceMockRecorder ¶
type MockSessionInterfaceMockRecorder struct {
// contains filtered or unexported fields
}
MockSessionInterfaceMockRecorder is the mock recorder for MockSessionInterface.
func (*MockSessionInterfaceMockRecorder) AbortTransaction ¶
func (mr *MockSessionInterfaceMockRecorder) AbortTransaction(ctx interface{}) *gomock.Call
AbortTransaction indicates an expected call of AbortTransaction.
func (*MockSessionInterfaceMockRecorder) AdvanceClusterTime ¶
func (mr *MockSessionInterfaceMockRecorder) AdvanceClusterTime(arg0 interface{}) *gomock.Call
AdvanceClusterTime indicates an expected call of AdvanceClusterTime.
func (*MockSessionInterfaceMockRecorder) AdvanceOperationTime ¶
func (mr *MockSessionInterfaceMockRecorder) AdvanceOperationTime(ts interface{}) *gomock.Call
AdvanceOperationTime indicates an expected call of AdvanceOperationTime.
func (*MockSessionInterfaceMockRecorder) Client ¶
func (mr *MockSessionInterfaceMockRecorder) Client() *gomock.Call
Client indicates an expected call of Client.
func (*MockSessionInterfaceMockRecorder) ClusterTime ¶
func (mr *MockSessionInterfaceMockRecorder) ClusterTime() *gomock.Call
ClusterTime indicates an expected call of ClusterTime.
func (*MockSessionInterfaceMockRecorder) CommitTransaction ¶
func (mr *MockSessionInterfaceMockRecorder) CommitTransaction(ctx interface{}) *gomock.Call
CommitTransaction indicates an expected call of CommitTransaction.
func (*MockSessionInterfaceMockRecorder) EndSession ¶
func (mr *MockSessionInterfaceMockRecorder) EndSession(ctx interface{}) *gomock.Call
EndSession indicates an expected call of EndSession.
func (*MockSessionInterfaceMockRecorder) ID ¶
func (mr *MockSessionInterfaceMockRecorder) ID() *gomock.Call
ID indicates an expected call of ID.
func (*MockSessionInterfaceMockRecorder) OperationTime ¶
func (mr *MockSessionInterfaceMockRecorder) OperationTime() *gomock.Call
OperationTime indicates an expected call of OperationTime.
func (*MockSessionInterfaceMockRecorder) StartTransaction ¶
func (mr *MockSessionInterfaceMockRecorder) StartTransaction(opts ...interface{}) *gomock.Call
StartTransaction indicates an expected call of StartTransaction.
func (*MockSessionInterfaceMockRecorder) WithTransaction ¶
func (mr *MockSessionInterfaceMockRecorder) WithTransaction(ctx, fn interface{}, opts ...interface{}) *gomock.Call
WithTransaction indicates an expected call of WithTransaction.
type MockSingleResultInterface ¶
type MockSingleResultInterface struct {
// contains filtered or unexported fields
}
MockSingleResultInterface is a mock of SingleResultInterface interface.
func NewMockSingleResultInterface ¶
func NewMockSingleResultInterface(ctrl *gomock.Controller) *MockSingleResultInterface
NewMockSingleResultInterface creates a new mock instance.
func (*MockSingleResultInterface) Decode ¶
func (m *MockSingleResultInterface) Decode(v interface{}) error
Decode mocks base method.
func (*MockSingleResultInterface) DecodeBytes ¶
func (m *MockSingleResultInterface) DecodeBytes() (bson.Raw, error)
DecodeBytes mocks base method.
func (*MockSingleResultInterface) EXPECT ¶
func (m *MockSingleResultInterface) EXPECT() *MockSingleResultInterfaceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockSingleResultInterface) Err ¶
func (m *MockSingleResultInterface) Err() error
Err mocks base method.
type MockSingleResultInterfaceMockRecorder ¶
type MockSingleResultInterfaceMockRecorder struct {
// contains filtered or unexported fields
}
MockSingleResultInterfaceMockRecorder is the mock recorder for MockSingleResultInterface.
func (*MockSingleResultInterfaceMockRecorder) Decode ¶
func (mr *MockSingleResultInterfaceMockRecorder) Decode(v interface{}) *gomock.Call
Decode indicates an expected call of Decode.
func (*MockSingleResultInterfaceMockRecorder) DecodeBytes ¶
func (mr *MockSingleResultInterfaceMockRecorder) DecodeBytes() *gomock.Call
DecodeBytes indicates an expected call of DecodeBytes.
func (*MockSingleResultInterfaceMockRecorder) Err ¶
func (mr *MockSingleResultInterfaceMockRecorder) Err() *gomock.Call
Err indicates an expected call of Err.
type MockUploadStreamInterface ¶
type MockUploadStreamInterface struct {
// contains filtered or unexported fields
}
MockUploadStreamInterface is a mock of UploadStreamInterface interface.
func NewMockUploadStreamInterface ¶
func NewMockUploadStreamInterface(ctrl *gomock.Controller) *MockUploadStreamInterface
NewMockUploadStreamInterface creates a new mock instance.
func (*MockUploadStreamInterface) Abort ¶
func (m *MockUploadStreamInterface) Abort() error
Abort mocks base method.
func (*MockUploadStreamInterface) Close ¶
func (m *MockUploadStreamInterface) Close() error
Close mocks base method.
func (*MockUploadStreamInterface) EXPECT ¶
func (m *MockUploadStreamInterface) EXPECT() *MockUploadStreamInterfaceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockUploadStreamInterface) SetWriteDeadline ¶
func (m *MockUploadStreamInterface) SetWriteDeadline(t time.Time) error
SetWriteDeadline mocks base method.
type MockUploadStreamInterfaceMockRecorder ¶
type MockUploadStreamInterfaceMockRecorder struct {
// contains filtered or unexported fields
}
MockUploadStreamInterfaceMockRecorder is the mock recorder for MockUploadStreamInterface.
func (*MockUploadStreamInterfaceMockRecorder) Abort ¶
func (mr *MockUploadStreamInterfaceMockRecorder) Abort() *gomock.Call
Abort indicates an expected call of Abort.
func (*MockUploadStreamInterfaceMockRecorder) Close ¶
func (mr *MockUploadStreamInterfaceMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockUploadStreamInterfaceMockRecorder) SetWriteDeadline ¶
func (mr *MockUploadStreamInterfaceMockRecorder) SetWriteDeadline(t interface{}) *gomock.Call
SetWriteDeadline indicates an expected call of SetWriteDeadline.
func (*MockUploadStreamInterfaceMockRecorder) Write ¶
func (mr *MockUploadStreamInterfaceMockRecorder) Write(p interface{}) *gomock.Call
Write indicates an expected call of Write.