Documentation ¶
Index ¶
- Constants
- Variables
- func CompressPayload(in []byte, opts CompressionOpts) ([]byte, error)
- func DecompressPayload(in []byte, opts CompressionOpts) ([]byte, error)
- func ExtractErrorFromServerResponse(doc bsoncore.Document) error
- type BatchCursor
- func (bc *BatchCursor) Batch() *bsoncore.DocumentSequence
- func (bc *BatchCursor) Close(ctx context.Context) error
- func (bc *BatchCursor) Err() error
- func (bc *BatchCursor) ID() int64
- func (bc *BatchCursor) KillCursor(ctx context.Context) error
- func (bc *BatchCursor) Next(ctx context.Context) bool
- func (bc *BatchCursor) PostBatchResumeToken() bsoncore.Document
- func (bc *BatchCursor) Server() Server
- func (bc *BatchCursor) SetBatchSize(size int32)
- type Batches
- type CollectionInfoFn
- type CompressionOpts
- type Compressor
- type Connection
- type Connector
- type Crypt
- type CryptOptions
- type CursorOptions
- type CursorResponse
- type Deployment
- type Disconnector
- type Error
- func (e Error) Error() string
- func (e Error) HasErrorLabel(label string) bool
- func (e Error) NamespaceNotFound() bool
- func (e Error) NetworkError() bool
- func (e Error) NodeIsRecovering() bool
- func (e Error) NodeIsShuttingDown() bool
- func (e Error) NotPrimary() bool
- func (e Error) RetryableRead() bool
- func (e Error) RetryableWrite(wireVersion *description.VersionRange) bool
- func (e Error) UnsupportedStorageEngine() bool
- func (e Error) Unwrap() error
- type ErrorProcessor
- type Expirable
- type HandshakeInformation
- type Handshaker
- type InvalidOperationError
- type KeyRetrieverFn
- type LegacyOperationKind
- type ListCollectionsBatchCursor
- func (lcbc *ListCollectionsBatchCursor) Batch() *bsoncore.DocumentSequence
- func (lcbc *ListCollectionsBatchCursor) Close(ctx context.Context) error
- func (lcbc *ListCollectionsBatchCursor) Err() error
- func (lcbc *ListCollectionsBatchCursor) ID() int64
- func (lcbc *ListCollectionsBatchCursor) Next(ctx context.Context) bool
- func (lcbc *ListCollectionsBatchCursor) Server() Server
- type LocalAddresser
- type MarkCommandFn
- type Operation
- type PinnedConnection
- type ProcessErrorResult
- type QueryFailureError
- type RTTMonitor
- type ResponseError
- type ResponseInfo
- type RetryMode
- type RetryablePoolError
- type Server
- type ServerAPIOptions
- type SingleConnectionDeployment
- func (ssd SingleConnectionDeployment) Connection(context.Context) (Connection, error)
- func (ssd SingleConnectionDeployment) Kind() description.TopologyKind
- func (ssd SingleConnectionDeployment) RTTMonitor() RTTMonitor
- func (ssd SingleConnectionDeployment) SelectServer(context.Context, description.ServerSelector) (Server, error)
- type SingleServerDeployment
- type StreamerConnection
- type Subscriber
- type Subscription
- type Type
- type WriteCommandError
- type WriteConcernError
- type WriteError
- type WriteErrors
Constants ¶
const TestServerAPIVersion = "1"
TestServerAPIVersion is the most recent, stable variant of options.ServerAPIVersion. Only to be used in testing.
Variables ¶
var ( // UnknownTransactionCommitResult is an error label for unknown transaction commit results. UnknownTransactionCommitResult = "UnknownTransactionCommitResult" // TransientTransactionError is an error label for transient errors with transactions. TransientTransactionError = "TransientTransactionError" // NetworkError is an error label for network errors. NetworkError = "NetworkError" // RetryableWriteError is an error lable for retryable write errors. RetryableWriteError = "RetryableWriteError" // NoWritesPerformed is an error label indicated that no writes were performed for an operation. NoWritesPerformed = "NoWritesPerformed" // ErrCursorNotFound is the cursor not found error for legacy find operations. ErrCursorNotFound = errors.New("cursor not found") // ErrUnacknowledgedWrite is returned from functions that have an unacknowledged // write concern. ErrUnacknowledgedWrite = errors.New("unacknowledged write") // ErrUnsupportedStorageEngine is returned when a retryable write is attempted against a server // that uses a storage engine that does not support retryable writes ErrUnsupportedStorageEngine = errors.New("this MongoDB deployment does not support retryable writes. Please add retryWrites=false to your connection string") // ErrDeadlineWouldBeExceeded is returned when a Timeout set on an operation would be exceeded // if the operation were sent to the server. ErrDeadlineWouldBeExceeded = errors.New("operation not sent to server, as Timeout would be exceeded") // ErrNegativeMaxTime is returned when MaxTime on an operation is a negative value. ErrNegativeMaxTime = errors.New("a negative value was provided for MaxTime on an operation") )
var ( // ErrNoDocCommandResponse occurs when the server indicated a response existed, but none was found. ErrNoDocCommandResponse = errors.New("command returned no documents") // ErrMultiDocCommandResponse occurs when the server sent multiple documents in response to a command. ErrMultiDocCommandResponse = errors.New("command returned multiple documents") // ErrReplyDocumentMismatch occurs when the number of documents returned in an OP_QUERY does not match the numberReturned field. ErrReplyDocumentMismatch = errors.New("number of documents returned does not match numberReturned field") // ErrNonPrimaryReadPref is returned when a read is attempted in a transaction with a non-primary read preference. ErrNonPrimaryReadPref = errors.New("read preference in a transaction must be primary") )
var ErrDocumentTooLarge = errors.New("an inserted document is too large")
ErrDocumentTooLarge occurs when a document that is larger than the maximum size accepted by a server is passed to an insert command.
Functions ¶
func CompressPayload ¶ added in v1.3.0
func CompressPayload(in []byte, opts CompressionOpts) ([]byte, error)
CompressPayload takes a byte slice and compresses it according to the options passed
func DecompressPayload ¶ added in v1.2.0
func DecompressPayload(in []byte, opts CompressionOpts) ([]byte, error)
DecompressPayload takes a byte slice that has been compressed and undoes it according to the options passed
func ExtractErrorFromServerResponse ¶ added in v1.6.0
ExtractErrorFromServerResponse extracts an error from a server response bsoncore.Document if there is one. Also used in testing for SDAM.
Types ¶
type BatchCursor ¶ added in v0.3.0
type BatchCursor struct {
// contains filtered or unexported fields
}
BatchCursor is a batch implementation of a cursor. It returns documents in entire batches instead of one at a time. An individual document cursor can be built on top of this batch cursor.
func NewBatchCursor ¶ added in v0.3.0
func NewBatchCursor(cr CursorResponse, clientSession *session.Client, clock *session.ClusterClock, opts CursorOptions) (*BatchCursor, error)
NewBatchCursor creates a new BatchCursor from the provided parameters.
func NewBatchCursorFromDocuments ¶ added in v1.9.0
func NewBatchCursorFromDocuments(documents []byte) *BatchCursor
NewBatchCursorFromDocuments returns a batch cursor with current batch set to a sequence-style DocumentSequence containing the provided documents.
func NewEmptyBatchCursor ¶ added in v0.3.0
func NewEmptyBatchCursor() *BatchCursor
NewEmptyBatchCursor returns a batch cursor that is empty.
func (*BatchCursor) Batch ¶ added in v0.3.0
func (bc *BatchCursor) Batch() *bsoncore.DocumentSequence
Batch will return a DocumentSequence for the current batch of documents. The returned DocumentSequence is only valid until the next call to Next or Close.
func (*BatchCursor) Close ¶ added in v0.3.0
func (bc *BatchCursor) Close(ctx context.Context) error
Close closes this batch cursor.
func (*BatchCursor) Err ¶ added in v0.3.0
func (bc *BatchCursor) Err() error
Err returns the latest error encountered.
func (*BatchCursor) ID ¶ added in v0.3.0
func (bc *BatchCursor) ID() int64
ID returns the cursor ID for this batch cursor.
func (*BatchCursor) KillCursor ¶ added in v1.1.0
func (bc *BatchCursor) KillCursor(ctx context.Context) error
KillCursor kills cursor on server without closing batch cursor
func (*BatchCursor) Next ¶ added in v0.3.0
func (bc *BatchCursor) Next(ctx context.Context) bool
Next indicates if there is another batch available. Returning false does not necessarily indicate that the cursor is closed. This method will return false when an empty batch is returned.
If Next returns true, there is a valid batch of documents available. If Next returns false, there is not a valid batch of documents available.
func (*BatchCursor) PostBatchResumeToken ¶ added in v1.1.0
func (bc *BatchCursor) PostBatchResumeToken() bsoncore.Document
PostBatchResumeToken returns the latest seen post batch resume token.
func (*BatchCursor) Server ¶ added in v1.0.0
func (bc *BatchCursor) Server() Server
Server returns the server for this cursor.
func (*BatchCursor) SetBatchSize ¶ added in v1.6.0
func (bc *BatchCursor) SetBatchSize(size int32)
SetBatchSize sets the batchSize for future getMores.
type Batches ¶ added in v1.1.0
type Batches struct { Identifier string Documents []bsoncore.Document Current []bsoncore.Document Ordered *bool }
Batches contains the necessary information to batch split an operation. This is only used for write oeprations.
func (*Batches) AdvanceBatch ¶ added in v1.1.0
AdvanceBatch splits the next batch using maxCount and targetBatchSize. This method will do nothing if the current batch has not been cleared. We do this so that when this is called during execute we can call it without first needing to check if we already have a batch, which makes the code simpler and makes retrying easier. The maxDocSize parameter is used to check that any one document is not too large. If the first document is bigger than targetBatchSize but smaller than maxDocSize, a batch of size 1 containing that document will be created.
func (*Batches) ClearBatch ¶ added in v1.1.0
func (b *Batches) ClearBatch()
ClearBatch clears the Current batch. This must be called before AdvanceBatch will advance to the next batch.
type CollectionInfoFn ¶ added in v1.2.0
type CollectionInfoFn func(ctx context.Context, db string, filter bsoncore.Document) (bsoncore.Document, error)
CollectionInfoFn is a callback used to retrieve collection information.
type CompressionOpts ¶ added in v1.2.0
type CompressionOpts struct { Compressor wiremessage.CompressorID ZlibLevel int ZstdLevel int UncompressedSize int32 }
CompressionOpts holds settings for how to compress a payload
type Compressor ¶ added in v1.1.0
Compressor is an interface used to compress wire messages. If a Connection supports compression it should implement this interface as well. The CompressWireMessage method will be called during the execution of an operation if the wire message is allowed to be compressed.
type Connection ¶ added in v1.1.0
type Connection interface { WriteWireMessage(context.Context, []byte) error ReadWireMessage(ctx context.Context, dst []byte) ([]byte, error) Description() description.Server // Close closes any underlying connection and returns or frees any resources held by the // connection. Close is idempotent and can be called multiple times, although subsequent calls // to Close may return an error. A connection cannot be used after it is closed. Close() error ID() string ServerConnectionID() *int32 Address() address.Address Stale() bool }
Connection represents a connection to a MongoDB server.
type Connector ¶ added in v1.2.0
type Connector interface {
Connect() error
}
Connector represents a type that can connect to a server.
type Crypt ¶ added in v1.2.0
type Crypt interface { // Encrypt encrypts the given command. Encrypt(ctx context.Context, db string, cmd bsoncore.Document) (bsoncore.Document, error) // Decrypt decrypts the given command response. Decrypt(ctx context.Context, cmdResponse bsoncore.Document) (bsoncore.Document, error) // CreateDataKey creates a data key using the given KMS provider and options. CreateDataKey(ctx context.Context, kmsProvider string, opts *options.DataKeyOptions) (bsoncore.Document, error) // EncryptExplicit encrypts the given value with the given options. EncryptExplicit(ctx context.Context, val bsoncore.Value, opts *options.ExplicitEncryptionOptions) (byte, []byte, error) // EncryptExplicitExpression encrypts the given expression with the given options. EncryptExplicitExpression(ctx context.Context, val bsoncore.Document, opts *options.ExplicitEncryptionOptions) (bsoncore.Document, error) // DecryptExplicit decrypts the given encrypted value. DecryptExplicit(ctx context.Context, subtype byte, data []byte) (bsoncore.Value, error) // Close cleans up any resources associated with the Crypt instance. Close() // BypassAutoEncryption returns true if auto-encryption should be bypassed. BypassAutoEncryption() bool // RewrapDataKey attempts to rewrap the document data keys matching the filter, preparing the re-wrapped documents // to be returned as a slice of bsoncore.Document. RewrapDataKey(ctx context.Context, filter []byte, opts *options.RewrapManyDataKeyOptions) ([]bsoncore.Document, error) }
Crypt is an interface implemented by types that can encrypt and decrypt instances of bsoncore.Document.
Users should rely on the driver's crypt type (used by default) for encryption and decryption unless they are perfectly confident in another implementation of Crypt.
func NewCrypt ¶ added in v1.2.0
func NewCrypt(opts *CryptOptions) Crypt
NewCrypt creates a new Crypt instance configured with the given AutoEncryptionOptions.
type CryptOptions ¶ added in v1.2.0
type CryptOptions struct { MongoCrypt *mongocrypt.MongoCrypt CollInfoFn CollectionInfoFn KeyFn KeyRetrieverFn MarkFn MarkCommandFn TLSConfig map[string]*tls.Config HTTPClient *http.Client BypassAutoEncryption bool BypassQueryAnalysis bool }
CryptOptions specifies options to configure a Crypt instance.
type CursorOptions ¶ added in v1.1.0
type CursorOptions struct { BatchSize int32 Comment bsoncore.Value MaxTimeMS int64 Limit int32 CommandMonitor *event.CommandMonitor Crypt Crypt ServerAPI *ServerAPIOptions }
CursorOptions are extra options that are required to construct a BatchCursor.
type CursorResponse ¶ added in v1.1.0
type CursorResponse struct { Server Server ErrorProcessor ErrorProcessor // This will only be set when pinning to a connection. Connection PinnedConnection Desc description.Server FirstBatch *bsoncore.DocumentSequence Database string Collection string ID int64 // contains filtered or unexported fields }
CursorResponse represents the response from a command the results in a cursor. A BatchCursor can be constructed from a CursorResponse.
func NewCursorResponse ¶ added in v1.1.0
func NewCursorResponse(info ResponseInfo) (CursorResponse, error)
NewCursorResponse constructs a cursor response from the given response and server. This method can be used within the ProcessResponse method for an operation.
type Deployment ¶ added in v1.1.0
type Deployment interface { SelectServer(context.Context, description.ServerSelector) (Server, error) Kind() description.TopologyKind }
Deployment is implemented by types that can select a server from a deployment.
type Disconnector ¶ added in v1.2.0
Disconnector represents a type that can disconnect from a server.
type Error ¶ added in v1.1.0
type Error struct { Code int32 Message string Labels []string Name string Wrapped error TopologyVersion *description.TopologyVersion Raw bsoncore.Document }
Error is a command execution error from the database.
func (Error) HasErrorLabel ¶ added in v1.1.0
HasErrorLabel returns true if the error contains the specified label.
func (Error) NamespaceNotFound ¶ added in v1.1.0
NamespaceNotFound returns true if this errors is a NamespaceNotFound error.
func (Error) NetworkError ¶ added in v1.1.0
NetworkError returns true if the error is a network error.
func (Error) NodeIsRecovering ¶ added in v1.1.0
NodeIsRecovering returns true if this error is a node is recovering error.
func (Error) NodeIsShuttingDown ¶ added in v1.1.0
NodeIsShuttingDown returns true if this error is a node is shutting down error.
func (Error) NotPrimary ¶ added in v1.8.0
NotPrimary returns true if this error is a not primary error.
func (Error) RetryableRead ¶ added in v1.4.0
RetryableRead returns true if the error is retryable for a read operation
func (Error) RetryableWrite ¶ added in v1.4.0
func (e Error) RetryableWrite(wireVersion *description.VersionRange) bool
RetryableWrite returns true if the error is retryable for a write operation
func (Error) UnsupportedStorageEngine ¶ added in v1.1.0
UnsupportedStorageEngine returns whether e came as a result of an unsupported storage engine
type ErrorProcessor ¶ added in v1.1.0
type ErrorProcessor interface {
ProcessError(err error, conn Connection) ProcessErrorResult
}
ErrorProcessor implementations can handle processing errors, which may modify their internal state. If this type is implemented by a Server, then Operation.Execute will call it's ProcessError method after it decodes a wire message.
type HandshakeInformation ¶ added in v1.5.0
type HandshakeInformation struct { Description description.Server SpeculativeAuthenticate bsoncore.Document ServerConnectionID *int32 SaslSupportedMechs []string }
HandshakeInformation contains information extracted from a MongoDB connection handshake. This is a helper type that augments description.Server by also tracking server connection ID and authentication-related fields. We use this type rather than adding authentication-related fields to description.Server to avoid retaining sensitive information in a user-facing type. The server connection ID is stored in this type because unlike description.Server, all handshakes are correlated with a single network connection.
type Handshaker ¶ added in v1.1.0
type Handshaker interface { GetHandshakeInformation(context.Context, address.Address, Connection) (HandshakeInformation, error) FinishHandshake(context.Context, Connection) error }
Handshaker is the interface implemented by types that can perform a MongoDB handshake over a provided driver.Connection. This is used during connection initialization. Implementations must be goroutine safe.
type InvalidOperationError ¶ added in v1.1.0
type InvalidOperationError struct{ MissingField string }
InvalidOperationError is returned from Validate and indicates that a required field is missing from an instance of Operation.
func (InvalidOperationError) Error ¶ added in v1.1.0
func (err InvalidOperationError) Error() string
type KeyRetrieverFn ¶ added in v1.2.0
type KeyRetrieverFn func(ctx context.Context, filter bsoncore.Document) ([]bsoncore.Document, error)
KeyRetrieverFn is a callback used to retrieve keys from the key vault.
type LegacyOperationKind ¶ added in v1.1.0
type LegacyOperationKind uint
LegacyOperationKind indicates if an operation is a legacy find, getMore, or killCursors. This is used in Operation.Execute, which will create legacy OP_QUERY, OP_GET_MORE, or OP_KILL_CURSORS instead of sending them as a command.
const ( LegacyNone LegacyOperationKind = iota LegacyFind LegacyGetMore LegacyKillCursors LegacyListCollections LegacyListIndexes )
These constants represent the three different kinds of legacy operations.
type ListCollectionsBatchCursor ¶ added in v0.3.0
type ListCollectionsBatchCursor struct {
// contains filtered or unexported fields
}
ListCollectionsBatchCursor is a special batch cursor returned from ListCollections that properly handles current and legacy ListCollections operations.
func NewLegacyListCollectionsBatchCursor ¶ added in v0.3.0
func NewLegacyListCollectionsBatchCursor(bc *BatchCursor) (*ListCollectionsBatchCursor, error)
NewLegacyListCollectionsBatchCursor creates a new legacy ListCollectionsCursor.
func NewListCollectionsBatchCursor ¶ added in v0.3.0
func NewListCollectionsBatchCursor(bc *BatchCursor) (*ListCollectionsBatchCursor, error)
NewListCollectionsBatchCursor creates a new non-legacy ListCollectionsCursor.
func (*ListCollectionsBatchCursor) Batch ¶ added in v0.3.0
func (lcbc *ListCollectionsBatchCursor) Batch() *bsoncore.DocumentSequence
Batch will return a DocumentSequence for the current batch of documents. The returned DocumentSequence is only valid until the next call to Next or Close.
func (*ListCollectionsBatchCursor) Close ¶ added in v0.3.0
func (lcbc *ListCollectionsBatchCursor) Close(ctx context.Context) error
Close closes this batch cursor.
func (*ListCollectionsBatchCursor) Err ¶ added in v0.3.0
func (lcbc *ListCollectionsBatchCursor) Err() error
Err returns the latest error encountered.
func (*ListCollectionsBatchCursor) ID ¶ added in v0.3.0
func (lcbc *ListCollectionsBatchCursor) ID() int64
ID returns the cursor ID for this batch cursor.
func (*ListCollectionsBatchCursor) Next ¶ added in v0.3.0
func (lcbc *ListCollectionsBatchCursor) Next(ctx context.Context) bool
Next indicates if there is another batch available. Returning false does not necessarily indicate that the cursor is closed. This method will return false when an empty batch is returned.
If Next returns true, there is a valid batch of documents available. If Next returns false, there is not a valid batch of documents available.
func (*ListCollectionsBatchCursor) Server ¶ added in v1.0.0
func (lcbc *ListCollectionsBatchCursor) Server() Server
Server returns a pointer to the cursor's server.
type LocalAddresser ¶ added in v1.1.0
LocalAddresser is a type that is able to supply its local address
type MarkCommandFn ¶ added in v1.2.0
type MarkCommandFn func(ctx context.Context, db string, cmd bsoncore.Document) (bsoncore.Document, error)
MarkCommandFn is a callback used to add encryption markings to a command.
type Operation ¶ added in v1.1.0
type Operation struct { // CommandFn is used to create the command that will be wrapped in a wire message and sent to // the server. This function should only add the elements of the command and not start or end // the enclosing BSON document. Per the command API, the first element must be the name of the // command to run. This field is required. CommandFn func(dst []byte, desc description.SelectedServer) ([]byte, error) // Database is the database that the command will be run against. This field is required. Database string // Deployment is the MongoDB Deployment to use. While most of the time this will be multiple // servers, commands that need to run against a single, preselected server can use the // SingleServerDeployment type. Commands that need to run on a preselected connection can use // the SingleConnectionDeployment type. Deployment Deployment // ProcessResponseFn is called after a response to the command is returned. The server is // provided for types like Cursor that are required to run subsequent commands using the same // server. ProcessResponseFn func(ResponseInfo) error // Selector is the server selector that's used during both initial server selection and // subsequent selection for retries. Depending on the Deployment implementation, the // SelectServer method may not actually be called. Selector description.ServerSelector // ReadPreference is the read preference that will be attached to the command. If this field is // not specified a default read preference of primary will be used. ReadPreference *readpref.ReadPref // ReadConcern is the read concern used when running read commands. This field should not be set // for write operations. If this field is set, it will be encoded onto the commands sent to the // server. ReadConcern *readconcern.ReadConcern // MinimumReadConcernWireVersion specifies the minimum wire version to add the read concern to // the command being executed. MinimumReadConcernWireVersion int32 // WriteConcern is the write concern used when running write commands. This field should not be // set for read operations. If this field is set, it will be encoded onto the commands sent to // the server. WriteConcern *writeconcern.WriteConcern // MinimumWriteConcernWireVersion specifies the minimum wire version to add the write concern to // the command being executed. MinimumWriteConcernWireVersion int32 // Client is the session used with this operation. This can be either an implicit or explicit // session. If the server selected does not support sessions and Client is specified the // behavior depends on the session type. If the session is implicit, the session fields will not // be encoded onto the command. If the session is explicit, an error will be returned. The // caller is responsible for ensuring that this field is nil if the Deployment does not support // sessions. Client *session.Client // Clock is a cluster clock, different from the one contained within a session.Client. This // allows updating cluster times for a global cluster clock while allowing individual session's // cluster clocks to be only updated as far as the last command that's been run. Clock *session.ClusterClock // RetryMode specifies how to retry. There are three modes that enable retry: RetryOnce, // RetryOncePerCommand, and RetryContext. For more information about what these modes do, please // refer to their definitions. Both RetryMode and Type must be set for retryability to be enabled. // If Timeout is set on the Client, the operation will automatically retry as many times as // possible unless RetryNone is used. RetryMode *RetryMode // Type specifies the kind of operation this is. There is only one mode that enables retry: Write. // For more information about what this mode does, please refer to it's definition. Both Type and // RetryMode must be set for retryability to be enabled. Type Type // Batches contains the documents that are split when executing a write command that potentially // has more documents than can fit in a single command. This should only be specified for // commands that are batch compatible. For more information, please refer to the definition of // Batches. Batches *Batches // Legacy sets the legacy type for this operation. There are only 3 types that require legacy // support: find, getMore, and killCursors. For more information about LegacyOperationKind, // please refer to it's definition. Legacy LegacyOperationKind // CommandMonitor specifies the monitor to use for APM events. If this field is not set, // no events will be reported. CommandMonitor *event.CommandMonitor // Crypt specifies a Crypt object to use for automatic client side encryption and decryption. Crypt Crypt // ServerAPI specifies options used to configure the API version sent to the server. ServerAPI *ServerAPIOptions // IsOutputAggregate specifies whether this operation is an aggregate with an output stage. If true, // read preference will not be added to the command on wire versions < 13. IsOutputAggregate bool // MaxTime specifies the maximum amount of time to allow the operation to run on the server. MaxTime *time.Duration // Timeout is the amount of time that this operation can execute before returning an error. The default value // nil, which means that the timeout of the operation's caller will be used. Timeout *time.Duration // contains filtered or unexported fields }
Operation is used to execute an operation. It contains all of the common code required to select a server, transform an operation into a command, write the command to a connection from the selected server, read a response from that connection, process the response, and potentially retry.
The required fields are Database, CommandFn, and Deployment. All other fields are optional.
While an Operation can be constructed manually, drivergen should be used to generate an implementation of an operation instead. This will ensure that there are helpers for constructing the operation and that this type isn't configured incorrectly.
func (Operation) ExecuteExhaust ¶ added in v1.4.0
func (op Operation) ExecuteExhaust(ctx context.Context, conn StreamerConnection) error
ExecuteExhaust reads a response from the provided StreamerConnection. This will error if the connection's CurrentlyStreaming function returns false.
type PinnedConnection ¶ added in v1.6.0
type PinnedConnection interface { Connection PinToCursor() error PinToTransaction() error UnpinFromCursor() error UnpinFromTransaction() error }
PinnedConnection represents a Connection that can be pinned by one or more cursors or transactions. Implementations of this interface should maintain the following invariants:
1. Each Pin* call should increment the number of references for the connection. 2. Each Unpin* call should decrement the number of references for the connection. 3. Calls to Close() should be ignored until all resources have unpinned the connection.
type ProcessErrorResult ¶ added in v1.5.0
type ProcessErrorResult int
ProcessErrorResult represents the result of a ErrorProcessor.ProcessError() call. Exact values for this type can be checked directly (e.g. res == ServerMarkedUnknown), but it is recommended that applications use the ServerChanged() function instead.
const ( // NoChange indicates that the error did not affect the state of the server. NoChange ProcessErrorResult = iota // ServerMarkedUnknown indicates that the error only resulted in the server being marked as Unknown. ServerMarkedUnknown // ConnectionPoolCleared indicates that the error resulted in the server being marked as Unknown and its connection // pool being cleared. ConnectionPoolCleared )
func (ProcessErrorResult) ServerChanged ¶ added in v1.5.0
func (p ProcessErrorResult) ServerChanged() bool
ServerChanged returns true if the ProcessErrorResult indicates that the server changed from an SDAM perspective during a ProcessError() call.
type QueryFailureError ¶ added in v1.1.0
QueryFailureError is an error representing a command failure as a document.
func (QueryFailureError) Error ¶ added in v1.1.0
func (e QueryFailureError) Error() string
Error implements the error interface.
func (QueryFailureError) Unwrap ¶ added in v1.4.0
func (e QueryFailureError) Unwrap() error
Unwrap returns the underlying error.
type RTTMonitor ¶ added in v1.11.0
type RTTMonitor interface { // EWMA returns the exponentially weighted moving average observed round-trip time. EWMA() time.Duration // Min returns the minimum observed round-trip time over the window period. Min() time.Duration // P90 returns the 90th percentile observed round-trip time over the window period. P90() time.Duration // Stats returns stringified stats of the current state of the monitor. Stats() string }
RTTMonitor represents a round-trip-time monitor.
type ResponseError ¶ added in v1.1.0
ResponseError is an error parsing the response to a command.
func NewCommandResponseError ¶ added in v1.1.0
func NewCommandResponseError(msg string, err error) ResponseError
NewCommandResponseError creates a CommandResponseError.
func (ResponseError) Error ¶ added in v1.1.0
func (e ResponseError) Error() string
Error implements the error interface.
type ResponseInfo ¶ added in v1.6.0
type ResponseInfo struct { ServerResponse bsoncore.Document Server Server Connection Connection ConnectionDescription description.Server CurrentIndex int }
ResponseInfo contains the context required to parse a server response.
type RetryMode ¶ added in v1.1.0
type RetryMode uint
RetryMode specifies the way that retries are handled for retryable operations.
const ( // RetryNone disables retrying. RetryNone RetryMode = iota // RetryOnce will enable retrying the entire operation once if Timeout is not specified. RetryOnce // RetryOncePerCommand will enable retrying each command associated with an operation if Timeout // is not specified. For example, if an insert is batch split into 4 commands then each of // those commands is eligible for one retry. RetryOncePerCommand // RetryContext will enable retrying until the context.Context's deadline is exceeded or it is // cancelled. RetryContext )
These are the modes available for retrying. Note that if Timeout is specified on the Client, the operation will automatically retry as many times as possible within the context's deadline unless RetryNone is used.
type RetryablePoolError ¶ added in v1.9.0
type RetryablePoolError interface {
Retryable() bool
}
RetryablePoolError is a connection pool error that can be retried while executing an operation.
type Server ¶ added in v1.1.0
type Server interface { Connection(context.Context) (Connection, error) // RTTMonitor returns the round-trip time monitor associated with this server. RTTMonitor() RTTMonitor }
Server represents a MongoDB server. Implementations should pool connections and handle the retrieving and returning of connections.
type ServerAPIOptions ¶ added in v1.6.0
ServerAPIOptions represents options used to configure the API version sent to the server when running commands.
func NewServerAPIOptions ¶ added in v1.6.0
func NewServerAPIOptions(serverAPIVersion string) *ServerAPIOptions
NewServerAPIOptions creates a new ServerAPIOptions configured with the provided serverAPIVersion.
func (*ServerAPIOptions) SetDeprecationErrors ¶ added in v1.6.0
func (s *ServerAPIOptions) SetDeprecationErrors(deprecationErrors bool) *ServerAPIOptions
SetDeprecationErrors specifies whether the server should return errors for deprecated features.
func (*ServerAPIOptions) SetStrict ¶ added in v1.6.0
func (s *ServerAPIOptions) SetStrict(strict bool) *ServerAPIOptions
SetStrict specifies whether the server should return errors for features that are not part of the API version.
type SingleConnectionDeployment ¶ added in v1.1.0
type SingleConnectionDeployment struct{ C Connection }
SingleConnectionDeployment is an implementation of Deployment that always returns the same Connection. This implementation should only be used for connection handshakes and server heartbeats as it does not implement ErrorProcessor, which is necessary for application operations.
func (SingleConnectionDeployment) Connection ¶ added in v1.1.0
func (ssd SingleConnectionDeployment) Connection(context.Context) (Connection, error)
Connection implements the Server interface. It always returns the embedded connection.
func (SingleConnectionDeployment) Kind ¶ added in v1.1.0
func (ssd SingleConnectionDeployment) Kind() description.TopologyKind
Kind implements the Deployment interface. It always returns description.Single.
func (SingleConnectionDeployment) RTTMonitor ¶ added in v1.11.0
func (ssd SingleConnectionDeployment) RTTMonitor() RTTMonitor
RTTMonitor implements the driver.Server interface.
func (SingleConnectionDeployment) SelectServer ¶ added in v1.1.0
func (ssd SingleConnectionDeployment) SelectServer(context.Context, description.ServerSelector) (Server, error)
SelectServer implements the Deployment interface. This method does not use the description.SelectedServer provided and instead returns itself. The Connections returned from the Connection method have a no-op Close method.
type SingleServerDeployment ¶ added in v1.1.0
type SingleServerDeployment struct{ Server }
SingleServerDeployment is an implementation of Deployment that always returns a single server.
func (SingleServerDeployment) Kind ¶ added in v1.1.0
func (SingleServerDeployment) Kind() description.TopologyKind
Kind implements the Deployment interface. It always returns description.Single.
func (SingleServerDeployment) SelectServer ¶ added in v1.1.0
func (ssd SingleServerDeployment) SelectServer(context.Context, description.ServerSelector) (Server, error)
SelectServer implements the Deployment interface. This method does not use the description.SelectedServer provided and instead returns the embedded Server.
type StreamerConnection ¶ added in v1.4.0
type StreamerConnection interface { Connection SetStreaming(bool) CurrentlyStreaming() bool SupportsStreaming() bool }
StreamerConnection represents a Connection that supports streaming wire protocol messages using the moreToCome and exhaustAllowed flags.
The SetStreaming and CurrentlyStreaming functions correspond to the moreToCome flag on server responses. If a response has moreToCome set, SetStreaming(true) will be called and CurrentlyStreaming() should return true.
CanStream corresponds to the exhaustAllowed flag. The operations layer will set exhaustAllowed on outgoing wire messages to inform the server that the driver supports streaming.
type Subscriber ¶ added in v1.2.0
type Subscriber interface { Subscribe() (*Subscription, error) Unsubscribe(*Subscription) error }
Subscriber represents a type to which another type can subscribe. A subscription contains a channel that is updated with topology descriptions.
type Subscription ¶ added in v1.2.0
type Subscription struct { Updates <-chan description.Topology ID uint64 }
Subscription represents a subscription to topology updates. A subscriber can receive updates through the Updates field.
type Type ¶ added in v1.1.0
type Type uint
Type specifies whether an operation is a read, write, or unknown.
const ( Write Type Read )
THese are the availables types of Type.
type WriteCommandError ¶ added in v1.1.0
type WriteCommandError struct { WriteConcernError *WriteConcernError WriteErrors WriteErrors Labels []string Raw bsoncore.Document }
WriteCommandError is an error for a write command.
func (WriteCommandError) Error ¶ added in v1.1.0
func (wce WriteCommandError) Error() string
func (WriteCommandError) HasErrorLabel ¶ added in v1.11.0
func (wce WriteCommandError) HasErrorLabel(label string) bool
HasErrorLabel returns true if the error contains the specified label.
func (WriteCommandError) Retryable ¶ added in v1.1.0
func (wce WriteCommandError) Retryable(wireVersion *description.VersionRange) bool
Retryable returns true if the error is retryable
func (WriteCommandError) UnsupportedStorageEngine ¶ added in v1.1.0
func (wce WriteCommandError) UnsupportedStorageEngine() bool
UnsupportedStorageEngine returns whether or not the WriteCommandError comes from a retryable write being attempted against a server that has a storage engine where they are not supported
type WriteConcernError ¶ added in v1.1.0
type WriteConcernError struct { Name string Code int64 Message string Details bsoncore.Document Labels []string TopologyVersion *description.TopologyVersion Raw bsoncore.Document }
WriteConcernError is a write concern failure that occurred as a result of a write operation.
func (WriteConcernError) Error ¶ added in v1.1.0
func (wce WriteConcernError) Error() string
func (WriteConcernError) NodeIsRecovering ¶ added in v1.1.0
func (wce WriteConcernError) NodeIsRecovering() bool
NodeIsRecovering returns true if this error is a node is recovering error.
func (WriteConcernError) NodeIsShuttingDown ¶ added in v1.1.0
func (wce WriteConcernError) NodeIsShuttingDown() bool
NodeIsShuttingDown returns true if this error is a node is shutting down error.
func (WriteConcernError) NotPrimary ¶ added in v1.8.0
func (wce WriteConcernError) NotPrimary() bool
NotPrimary returns true if this error is a not primary error.
func (WriteConcernError) Retryable ¶ added in v1.1.0
func (wce WriteConcernError) Retryable() bool
Retryable returns true if the error is retryable
type WriteError ¶ added in v1.1.0
type WriteError struct { Index int64 Code int64 Message string Details bsoncore.Document Raw bsoncore.Document }
WriteError is a non-write concern failure that occurred as a result of a write operation.
func (WriteError) Error ¶ added in v1.1.0
func (we WriteError) Error() string
type WriteErrors ¶ added in v1.1.0
type WriteErrors []WriteError
WriteErrors is a group of non-write concern failures that occurred as a result of a write operation.
func (WriteErrors) Error ¶ added in v1.1.0
func (we WriteErrors) Error() string
Source Files ¶
Directories ¶
Path | Synopsis |
---|---|
Package auth is not for public use.
|
Package auth is not for public use. |
internal/awsv4
Package awsv4 implements signing for AWS V4 signer with static credentials, and is based on and modified from code in the package aws-sdk-go.
|
Package awsv4 implements signing for AWS V4 signer with static credentials, and is based on and modified from code in the package aws-sdk-go. |
Package topology contains types that handles the discovery, monitoring, and selection of servers.
|
Package topology contains types that handles the discovery, monitoring, and selection of servers. |