package conntest

import "go.mongodb.org/mongo-driver/mongo/internal/conntest"

Index ¶

• type MockConnection
• func (c *MockConnection) Alive() bool
• func (c *MockConnection) Close() error
• func (c *MockConnection) CloseIgnoreError()
• func (c *MockConnection) Expired() bool
• func (c *MockConnection) LocalAddr() net.Addr
• func (c *MockConnection) MarkDead()
• func (c *MockConnection) Model() *model.Conn
• func (c *MockConnection) Read(ctx context.Context, responseTo int32) (msg.Response, error)
• func (c *MockConnection) Write(ctx context.Context, reqs ...msg.Request) error

Types ¶

type MockConnection ¶

type MockConnection struct {
	Dead      bool
	Sent      []msg.Request
	ResponseQ []*msg.Reply
	ReadErr   error
	WriteErr  error

	SkipResponseToFixup bool
}

MockConnection is used to mock a connection for testing purposes.

func (*MockConnection) Alive ¶

func (c *MockConnection) Alive() bool

Alive returns whether a MockConnection is alive.

func (*MockConnection) Close ¶

func (c *MockConnection) Close() error

Close closes a MockConnection.

func (*MockConnection) CloseIgnoreError ¶

func (c *MockConnection) CloseIgnoreError()

CloseIgnoreError closes a MockConnection and ignores any error that occurs.

func (*MockConnection) Expired ¶

func (c *MockConnection) Expired() bool

Expired returns whether a MockConnection is expired.

func (*MockConnection) LocalAddr ¶

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

LocalAddr returns nil.

func (*MockConnection) MarkDead ¶

func (c *MockConnection) MarkDead()

MarkDead marks a MockConnection as dead.

func (*MockConnection) Model ¶

func (c *MockConnection) Model() *model.Conn

Model returns the description of a MockConnection.

func (*MockConnection) Read ¶

func (c *MockConnection) Read(ctx context.Context, responseTo int32) (msg.Response, error)

Read reads a server response from the MockConnection.

func (*MockConnection) Write ¶

func (c *MockConnection) Write(ctx context.Context, reqs ...msg.Request) error

Write writes a wire protocol message to MockConnection.

Source Files ¶

mock.go