mirror of
https://github.com/mainflux/mainflux.git
synced 2025-05-02 22:17:10 +08:00
158 lines
6.2 KiB
Go
158 lines
6.2 KiB
Go
package driver // import "go.mongodb.org/mongo-driver/x/mongo/driver"
|
|
|
|
import (
|
|
"context"
|
|
|
|
"go.mongodb.org/mongo-driver/x/mongo/driver/address"
|
|
"go.mongodb.org/mongo-driver/x/mongo/driver/description"
|
|
)
|
|
|
|
// Deployment is implemented by types that can select a server from a deployment.
|
|
type Deployment interface {
|
|
SelectServer(context.Context, description.ServerSelector) (Server, error)
|
|
SupportsRetryWrites() bool
|
|
Kind() description.TopologyKind
|
|
}
|
|
|
|
// Server represents a MongoDB server. Implementations should pool connections and handle the
|
|
// retrieving and returning of connections.
|
|
type Server interface {
|
|
Connection(context.Context) (Connection, error)
|
|
}
|
|
|
|
// Connection represents a connection to a MongoDB server.
|
|
type Connection interface {
|
|
WriteWireMessage(context.Context, []byte) error
|
|
ReadWireMessage(ctx context.Context, dst []byte) ([]byte, error)
|
|
Description() description.Server
|
|
Close() error
|
|
ID() string
|
|
Address() address.Address
|
|
}
|
|
|
|
// LocalAddresser is a type that is able to supply its local address
|
|
type LocalAddresser interface {
|
|
LocalAddress() address.Address
|
|
}
|
|
|
|
// Expirable represents an expirable object.
|
|
type Expirable interface {
|
|
Expire() error
|
|
Alive() bool
|
|
}
|
|
|
|
// 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 Compressor interface {
|
|
CompressWireMessage(src, dst []byte) ([]byte, error)
|
|
}
|
|
|
|
// 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 ErrorProcessor interface {
|
|
ProcessError(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 Handshaker interface {
|
|
GetDescription(context.Context, address.Address, Connection) (description.Server, error)
|
|
FinishHandshake(context.Context, Connection) error
|
|
}
|
|
|
|
// SingleServerDeployment is an implementation of Deployment that always returns a single server.
|
|
type SingleServerDeployment struct{ Server }
|
|
|
|
var _ Deployment = SingleServerDeployment{}
|
|
|
|
// SelectServer implements the Deployment interface. This method does not use the
|
|
// description.SelectedServer provided and instead returns the embedded Server.
|
|
func (ssd SingleServerDeployment) SelectServer(context.Context, description.ServerSelector) (Server, error) {
|
|
return ssd.Server, nil
|
|
}
|
|
|
|
// SupportsRetryWrites implements the Deployment interface. It always returns Type(0), because a single
|
|
// server does not support retryability.
|
|
func (SingleServerDeployment) SupportsRetryWrites() bool { return false }
|
|
|
|
// Kind implements the Deployment interface. It always returns description.Single.
|
|
func (SingleServerDeployment) Kind() description.TopologyKind { return description.Single }
|
|
|
|
// SingleConnectionDeployment is an implementation of Deployment that always returns the same
|
|
// Connection.
|
|
type SingleConnectionDeployment struct{ C Connection }
|
|
|
|
var _ Deployment = SingleConnectionDeployment{}
|
|
var _ Server = SingleConnectionDeployment{}
|
|
|
|
// 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.
|
|
func (ssd SingleConnectionDeployment) SelectServer(context.Context, description.ServerSelector) (Server, error) {
|
|
return ssd, nil
|
|
}
|
|
|
|
// SupportsRetryWrites implements the Deployment interface. It always returns Type(0), because a single
|
|
// connection does not support retryability.
|
|
func (ssd SingleConnectionDeployment) SupportsRetryWrites() bool { return false }
|
|
|
|
// Kind implements the Deployment interface. It always returns description.Single.
|
|
func (ssd SingleConnectionDeployment) Kind() description.TopologyKind { return description.Single }
|
|
|
|
// Connection implements the Server interface. It always returns the embedded connection.
|
|
//
|
|
// This method returns a Connection with a no-op Close method. This ensures that a
|
|
// SingleConnectionDeployment can be used across multiple operation executions.
|
|
func (ssd SingleConnectionDeployment) Connection(context.Context) (Connection, error) {
|
|
return nopCloserConnection{ssd.C}, nil
|
|
}
|
|
|
|
// nopCloserConnection is an adapter used in a SingleConnectionDeployment. It passes through all
|
|
// functionality expcect for closing, which is a no-op. This is done so the connection can be used
|
|
// across multiple operations.
|
|
type nopCloserConnection struct{ Connection }
|
|
|
|
func (ncc nopCloserConnection) Close() error { return nil }
|
|
|
|
// TODO(GODRIVER-617): We can likely use 1 type for both the Type and the RetryMode by using
|
|
// 2 bits for the mode and 1 bit for the type. Although in the practical sense, we might not want to
|
|
// do that since the type of retryability is tied to the operation itself and isn't going change,
|
|
// e.g. and insert operation will always be a write, however some operations are both reads and
|
|
// writes, for instance aggregate is a read but with a $out parameter it's a write.
|
|
|
|
// Type specifies whether an operation is a read, write, or unknown.
|
|
type Type uint
|
|
|
|
// THese are the availables types of Type.
|
|
const (
|
|
_ Type = iota
|
|
Write
|
|
Read
|
|
)
|
|
|
|
// RetryMode specifies the way that retries are handled for retryable operations.
|
|
type RetryMode uint
|
|
|
|
// These are the modes available for retrying.
|
|
const (
|
|
// RetryNone disables retrying.
|
|
RetryNone RetryMode = iota
|
|
// RetryOnce will enable retrying the entire operation once.
|
|
RetryOnce
|
|
// RetryOncePerCommand will enable retrying each command associated with an operation. 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
|
|
)
|
|
|
|
// Enabled returns if this RetryMode enables retrying.
|
|
func (rm RetryMode) Enabled() bool {
|
|
return rm == RetryOnce || rm == RetryOncePerCommand || rm == RetryContext
|
|
}
|