drivertest

Documentation

Index

• func MakeReply(doc bsoncore.Document) []byte
• type ChannelConn
  • func (c *ChannelConn) Address() address.Address
  • func (c *ChannelConn) Close() error
  • func (c *ChannelConn) Description() description.Server
  • func (c *ChannelConn) ID() string
  • func (c *ChannelConn) ReadWireMessage(ctx context.Context, dst []byte) ([]byte, error)
  • func (c *ChannelConn) WriteWireMessage(ctx context.Context, wm []byte) error

Functions

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) WriteWireMessage

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

WriteWireMessage implements the driver.Connection interface.