heliosmongo

Documentation

Index

• Constants
• Variables
• func BatchCursorFromCursor(c *Cursor) *driver.BatchCursor
• func IsDuplicateKeyError(err error) bool
• func IsNetworkError(err error) bool
• func IsTimeout(err error) bool
• func WithSession(ctx context.Context, sess Session, fn func(SessionContext) error) error
• type BSONAppender
• type BSONAppenderFunc
• type BulkWriteError
• type BulkWriteException
• type BulkWriteResult
• type ChangeStream
• type Client
  • func Connect(ctx context.Context, opts ...*options.ClientOptions) (*Client, error)
  • func NewClient(opts ...*options.ClientOptions) (*Client, error)
• type ClientEncryption
  • func NewClientEncryption(keyVaultClient *Client, opts ...*options.ClientEncryptionOptions) (*ClientEncryption, error)
• type Collection
• type CollectionSpecification
• type CommandError
• type Cursor
  • func NewCursorFromDocuments(documents []interface{}, err error, registry *bsoncodec.Registry) (*Cursor, error)
• type Database
• type DatabaseSpecification
• type DeleteManyModel
  • func NewDeleteManyModel() *DeleteManyModel
• type DeleteOneModel
  • func NewDeleteOneModel() *DeleteOneModel
• type DeleteResult
• type Dialer
• type EncryptionKeyVaultError
• type ErrMapForOrderedArgument
• type IndexModel
• type IndexOptionsBuilder
  • func NewIndexOptionsBuilder() *IndexOptionsBuilder
• type IndexSpecification
• type IndexView
• type InsertManyResult
• type InsertOneModel
  • func NewInsertOneModel() *InsertOneModel
• type InsertOneResult
• type ListDatabasesResult
• type MarshalError
• type MongocryptError
• type MongocryptdError
• type Pipeline
• type ReplaceOneModel
  • func NewReplaceOneModel() *ReplaceOneModel
• type RewrapManyDataKeyResult
• type ServerError
• type Session
  • func SessionFromContext(ctx context.Context) Session
• type SessionContext
  • func NewSessionContext(ctx context.Context, sess Session) SessionContext
• type SingleResult
  • func NewSingleResultFromDocument(document interface{}, err error, registry *bsoncodec.Registry) *SingleResult
• type StreamType
• type UpdateManyModel
  • func NewUpdateManyModel() *UpdateManyModel
• type UpdateOneModel
  • func NewUpdateOneModel() *UpdateOneModel
• type UpdateResult
• type WriteConcernError
• type WriteError
• type WriteErrors
• type WriteException
• type WriteModel
• type XSession

Constants

const ClientStream = originalMongo.ClientStream

const CollectionStream = originalMongo.CollectionStream

const DatabaseStream = originalMongo.DatabaseStream

Variables

var ErrClientDisconnected = originalMongo.ErrClientDisconnected

var ErrEmptySlice = originalMongo.ErrEmptySlice

var ErrInvalidIndexValue = originalMongo.ErrInvalidIndexValue

var ErrMissingResumeToken = originalMongo.ErrMissingResumeToken

var ErrMultipleIndexDrop = originalMongo.ErrMultipleIndexDrop

var ErrNilCursor = originalMongo.ErrNilCursor

var ErrNilDocument = originalMongo.ErrNilDocument

var ErrNilValue = originalMongo.ErrNilValue

var ErrNoDocuments = originalMongo.ErrNoDocuments

var ErrNonStringIndexName = originalMongo.ErrNonStringIndexName

var ErrUnacknowledgedWrite = originalMongo.ErrUnacknowledgedWrite

var ErrWrongClient = originalMongo.ErrWrongClient

Functions

func BatchCursorFromCursor

func BatchCursorFromCursor(c *Cursor) *driver.BatchCursor

func IsDuplicateKeyError

func IsDuplicateKeyError(err error) bool

func IsNetworkError

func IsNetworkError(err error) bool

func IsTimeout

func IsTimeout(err error) bool

func WithSession

func WithSession(ctx context.Context, sess Session, fn func(SessionContext) error) error

Types

type BSONAppender

type BSONAppender = originalMongo.BSONAppender

type BSONAppenderFunc

type BSONAppenderFunc = originalMongo.BSONAppenderFunc

type BulkWriteError

type BulkWriteError = originalMongo.BulkWriteError

type BulkWriteException

type BulkWriteException = originalMongo.BulkWriteException

type BulkWriteResult

type BulkWriteResult = originalMongo.BulkWriteResult

type ChangeStream

type ChangeStream = originalMongo.ChangeStream

type Client

type Client = originalMongo.Client

func Connect

func Connect(ctx context.Context, opts ...*options.ClientOptions) (*Client, error)

func NewClient

func NewClient(opts ...*options.ClientOptions) (*Client, error)

type ClientEncryption

type ClientEncryption = originalMongo.ClientEncryption

func NewClientEncryption

func NewClientEncryption(keyVaultClient *Client, opts ...*options.ClientEncryptionOptions) (*ClientEncryption, error)

type Collection

type Collection = originalMongo.Collection

type CollectionSpecification

type CollectionSpecification = originalMongo.CollectionSpecification

type CommandError

type CommandError = originalMongo.CommandError

type Cursor

type Cursor = originalMongo.Cursor

func NewCursorFromDocuments

func NewCursorFromDocuments(documents []interface{}, err error, registry *bsoncodec.Registry) (*Cursor, error)

type Database

type Database = originalMongo.Database

type DatabaseSpecification

type DatabaseSpecification = originalMongo.DatabaseSpecification

type DeleteManyModel

type DeleteManyModel = originalMongo.DeleteManyModel

func NewDeleteManyModel

func NewDeleteManyModel() *DeleteManyModel

type DeleteOneModel

type DeleteOneModel = originalMongo.DeleteOneModel

func NewDeleteOneModel

func NewDeleteOneModel() *DeleteOneModel

type DeleteResult

type DeleteResult = originalMongo.DeleteResult

type Dialer

type Dialer = originalMongo.Dialer

type EncryptionKeyVaultError

type EncryptionKeyVaultError = originalMongo.EncryptionKeyVaultError

type ErrMapForOrderedArgument

type ErrMapForOrderedArgument = originalMongo.ErrMapForOrderedArgument

type IndexModel

type IndexModel = originalMongo.IndexModel

type IndexOptionsBuilder

type IndexOptionsBuilder = originalMongo.IndexOptionsBuilder

func NewIndexOptionsBuilder

func NewIndexOptionsBuilder() *IndexOptionsBuilder

type IndexSpecification

type IndexSpecification = originalMongo.IndexSpecification

type IndexView

type IndexView = originalMongo.IndexView

type InsertManyResult

type InsertManyResult = originalMongo.InsertManyResult

type InsertOneModel

type InsertOneModel = originalMongo.InsertOneModel

func NewInsertOneModel

func NewInsertOneModel() *InsertOneModel

type InsertOneResult

type InsertOneResult = originalMongo.InsertOneResult

type ListDatabasesResult

type ListDatabasesResult = originalMongo.ListDatabasesResult

type MarshalError

type MarshalError = originalMongo.MarshalError

type MongocryptError

type MongocryptError = originalMongo.MongocryptError

type MongocryptdError

type MongocryptdError = originalMongo.MongocryptdError

type Pipeline

type Pipeline = originalMongo.Pipeline

type ReplaceOneModel

type ReplaceOneModel = originalMongo.ReplaceOneModel

func NewReplaceOneModel

func NewReplaceOneModel() *ReplaceOneModel

type RewrapManyDataKeyResult

type RewrapManyDataKeyResult = originalMongo.RewrapManyDataKeyResult

type ServerError

type ServerError = originalMongo.ServerError

type Session

type Session = originalMongo.Session

func SessionFromContext

func SessionFromContext(ctx context.Context) Session

type SessionContext

type SessionContext = originalMongo.SessionContext

func NewSessionContext

func NewSessionContext(ctx context.Context, sess Session) SessionContext

type SingleResult

type SingleResult = originalMongo.SingleResult

func NewSingleResultFromDocument

func NewSingleResultFromDocument(document interface{}, err error, registry *bsoncodec.Registry) *SingleResult

type StreamType

type StreamType = originalMongo.StreamType

type UpdateManyModel

type UpdateManyModel = originalMongo.UpdateManyModel

func NewUpdateManyModel

func NewUpdateManyModel() *UpdateManyModel

type UpdateOneModel

type UpdateOneModel = originalMongo.UpdateOneModel

func NewUpdateOneModel

func NewUpdateOneModel() *UpdateOneModel

type UpdateResult

type UpdateResult = originalMongo.UpdateResult

type WriteConcernError

type WriteConcernError = originalMongo.WriteConcernError

type WriteError

type WriteError = originalMongo.WriteError

type WriteErrors

type WriteErrors = originalMongo.WriteErrors

type WriteException

type WriteException = originalMongo.WriteException

type WriteModel

type WriteModel = originalMongo.WriteModel

type XSession

type XSession = originalMongo.XSession