Versions in this module Expand all Collapse all v1 v1.4.1 Sep 27, 2020 Changes in this version + func MakeReply(doc bsoncore.Document) []byte + type ChannelConn struct + Desc description.Server + ReadErr chan error + ReadResp chan []byte + WriteErr error + Written chan []byte + 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 + type ChannelNetConn struct + ReadErr chan error + ReadResp chan []byte + WriteErr error + Written chan []byte + func (c *ChannelNetConn) AddResponse(resp []byte) error + func (c *ChannelNetConn) Close() error + func (c *ChannelNetConn) GetWrittenMessage() []byte + func (c *ChannelNetConn) LocalAddr() net.Addr + func (c *ChannelNetConn) Read(b []byte) (int, error) + func (c *ChannelNetConn) RemoteAddr() net.Addr + func (c *ChannelNetConn) SetDeadline(_ time.Time) error + func (c *ChannelNetConn) SetReadDeadline(_ time.Time) error + func (c *ChannelNetConn) SetWriteDeadline(_ time.Time) error + func (c *ChannelNetConn) Write(b []byte) (int, error)
Go to main page