Documentation
¶
Index ¶
- Variables
- func MakeReply(t *testing.T, doc *bson.Document) wiremessage.WireMessage
- func MultiError(errors ...error) error
- func RolledUpErrorMessage(err error) string
- func UnwrapError(err error) error
- func WrapError(inner error, message string) error
- func WrapErrorf(inner error, format string, args ...interface{}) error
- type BuildInfoResult
- type ChannelConn
- func (c *ChannelConn) Alive() bool
- func (c *ChannelConn) Close() error
- func (c *ChannelConn) Expired() bool
- func (c *ChannelConn) ID() string
- func (c *ChannelConn) ReadWireMessage(ctx context.Context) (wiremessage.WireMessage, error)
- func (c *ChannelConn) WriteWireMessage(ctx context.Context, wm wiremessage.WireMessage) error
- type GetLastErrorResult
- type IsMasterResult
- type Semaphore
- type WrappedError
Constants ¶
This section is empty.
Variables ¶
var Version = "local build"
Version is the current version of the driver.
Functions ¶
func MakeReply ¶ added in v0.0.9
func MakeReply(t *testing.T, doc *bson.Document) wiremessage.WireMessage
Create a OP_REPLY wiremessage from a BSON document
func MultiError ¶
MultiError combines multiple errors into a single error. If there are no errors, nil is returned. If there is 1 error, it is returned. Otherwise, they are combined.
func RolledUpErrorMessage ¶
RolledUpErrorMessage gets a flattened error message.
func UnwrapError ¶
UnwrapError attempts to unwrap the error down to its root cause.
func WrapErrorf ¶
WrapErrorf wraps an error with a message.
Types ¶
type BuildInfoResult ¶
type BuildInfoResult struct {
OK bool `bson:"ok"`
GitVersion string `bson:"gitVersion,omitempty"`
Version string `bson:"version,omitempty"`
VersionArray []uint8 `bson:"versionArray,omitempty"`
}
BuildInfoResult is the result of executing the buildInfo command.
type ChannelConn ¶ added in v0.0.9
type ChannelConn struct {
T *testing.T
WriteErr error
Written chan wiremessage.WireMessage
ReadResp chan wiremessage.WireMessage
ReadErr chan error
}
Implements the connection.Connection interface by reading and writing wire messages to a channel
func (*ChannelConn) Alive ¶ added in v0.0.9
func (c *ChannelConn) Alive() bool
func (*ChannelConn) Close ¶ added in v0.0.9
func (c *ChannelConn) Close() error
func (*ChannelConn) Expired ¶ added in v0.0.9
func (c *ChannelConn) Expired() bool
func (*ChannelConn) ID ¶ added in v0.0.9
func (c *ChannelConn) ID() string
func (*ChannelConn) ReadWireMessage ¶ added in v0.0.9
func (c *ChannelConn) ReadWireMessage(ctx context.Context) (wiremessage.WireMessage, error)
func (*ChannelConn) WriteWireMessage ¶ added in v0.0.9
func (c *ChannelConn) WriteWireMessage(ctx context.Context, wm wiremessage.WireMessage) error
type GetLastErrorResult ¶
type GetLastErrorResult struct {
ConnectionID uint32 `bson:"connectionId"`
}
GetLastErrorResult is the result of executing the getLastError command.
type IsMasterResult ¶
type IsMasterResult struct {
Arbiters []string `bson:"arbiters,omitempty"`
ArbiterOnly bool `bson:"arbiterOnly,omitempty"`
ElectionID objectid.ObjectID `bson:"electionId,omitempty"`
Hidden bool `bson:"hidden,omitempty"`
Hosts []string `bson:"hosts,omitempty"`
IsMaster bool `bson:"ismaster,omitempty"`
IsReplicaSet bool `bson:"isreplicaset,omitempty"`
LastWriteTimestamp time.Time `bson:"lastWriteDate,omitempty"`
MaxBSONObjectSize uint32 `bson:"maxBsonObjectSize,omitempty"`
MaxMessageSizeBytes uint32 `bson:"maxMessageSizeBytes,omitempty"`
MaxWriteBatchSize uint16 `bson:"maxWriteBatchSize,omitempty"`
Me string `bson:"me,omitempty"`
MaxWireVersion int32 `bson:"maxWireVersion,omitempty"`
MinWireVersion int32 `bson:"minWireVersion,omitempty"`
Msg string `bson:"msg,omitempty"`
OK int32 `bson:"ok"`
Passives []string `bson:"passives,omitempty"`
ReadOnly bool `bson:"readOnly,omitempty"`
Secondary bool `bson:"secondary,omitempty"`
SetName string `bson:"setName,omitempty"`
SetVersion uint32 `bson:"setVersion,omitempty"`
Tags map[string]string `bson:"tags,omitempty"`
}
IsMasterResult is the result of executing this ismaster command.
type Semaphore ¶
type Semaphore struct {
// contains filtered or unexported fields
}
Semaphore is a synchronization primitive that controls access to a common resource.
func NewSemaphore ¶
NewSemaphore creates a new semaphore.
type WrappedError ¶
type WrappedError interface {
// Message gets the basic message of the error.
Message() string
// Inner gets the inner error if one exists.
Inner() error
}
WrappedError represents an error that contains another error.
Source Files
Directories