Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetCommandFromMsgWireMessage

func GetCommandFromMsgWireMessage(wm []byte) (bsoncore.Document, error)

    GetCommandFromMsgWireMessage returns the command document sent in an OP_MSG wire message.

    func GetCommandFromQueryWireMessage

    func GetCommandFromQueryWireMessage(wm []byte) (bsoncore.Document, error)

      GetCommandFromQueryWireMessage returns the command sent in an OP_QUERY wire message.

      func MakeReply

      func MakeReply(doc bsoncore.Document) []byte

        MakeReply creates an OP_REPLY wiremessage from a BSON document

        Types

        type ChannelConn

        type ChannelConn struct {
        	WriteErr error
        	Written  chan []byte
        	ReadResp chan []byte
        	ReadErr  chan error
        	Desc     description.Server
        }

          ChannelConn implements the driver.Connection interface by reading and writing wire messages to a channel

          func (*ChannelConn) Address

          func (c *ChannelConn) Address() address.Address

            Address implements the driver.Connection interface.

            func (*ChannelConn) Close

            func (c *ChannelConn) Close() error

              Close implements the driver.Connection interface.

              func (*ChannelConn) Description

              func (c *ChannelConn) Description() description.Server

                Description implements the driver.Connection interface.

                func (*ChannelConn) ID

                func (c *ChannelConn) ID() string

                  ID implements the driver.Connection interface.

                  func (*ChannelConn) ReadWireMessage

                  func (c *ChannelConn) ReadWireMessage(ctx context.Context, dst []byte) ([]byte, error)

                    ReadWireMessage implements the driver.Connection interface.

                    func (*ChannelConn) Stale

                    func (c *ChannelConn) Stale() bool

                      Stale implements the driver.Connection interface.

                      func (*ChannelConn) WriteWireMessage

                      func (c *ChannelConn) WriteWireMessage(ctx context.Context, wm []byte) error

                        WriteWireMessage implements the driver.Connection interface.

                        type ChannelNetConn

                        type ChannelNetConn struct {
                        	WriteErr error
                        	Written  chan []byte
                        	ReadResp chan []byte
                        	ReadErr  chan error
                        }

                          ChannelNetConn implements the net.Conn interface by reading and writing wire messages to a channel.

                          func (*ChannelNetConn) AddResponse

                          func (c *ChannelNetConn) AddResponse(resp []byte) error

                            AddResponse adds a response to the connection.

                            func (*ChannelNetConn) Close

                            func (c *ChannelNetConn) Close() error

                              Close closes the connection.

                              func (*ChannelNetConn) GetWrittenMessage

                              func (c *ChannelNetConn) GetWrittenMessage() []byte

                                GetWrittenMessage gets the last wire message written to the connection

                                func (*ChannelNetConn) LocalAddr

                                func (c *ChannelNetConn) LocalAddr() net.Addr

                                  LocalAddr returns the local network address.

                                  func (*ChannelNetConn) Read

                                  func (c *ChannelNetConn) Read(b []byte) (int, error)

                                    Read reads data from the connection

                                    func (*ChannelNetConn) RemoteAddr

                                    func (c *ChannelNetConn) RemoteAddr() net.Addr

                                      RemoteAddr returns the remote network address.

                                      func (*ChannelNetConn) SetDeadline

                                      func (c *ChannelNetConn) SetDeadline(_ time.Time) error

                                        SetDeadline sets the read and write deadlines associated with the connection.

                                        func (*ChannelNetConn) SetReadDeadline

                                        func (c *ChannelNetConn) SetReadDeadline(_ time.Time) error

                                          SetReadDeadline sets the read and write deadlines associated with the connection.

                                          func (*ChannelNetConn) SetWriteDeadline

                                          func (c *ChannelNetConn) SetWriteDeadline(_ time.Time) error

                                            SetWriteDeadline sets the read and write deadlines associated with the connection.

                                            func (*ChannelNetConn) Write

                                            func (c *ChannelNetConn) Write(b []byte) (int, error)

                                              Write writes data to the connection.