mongodb

Documentation

Index

• type Interceptor
  • func NewInterceptor(addr, upstreamAddr string, reg *registry.MockRegistry) *Interceptor
  • func (p *Interceptor) Start(ctx context.Context) error

Types

type Interceptor

type Interceptor struct {
	// contains filtered or unexported fields
}

Interceptor is a MongoDB wire-protocol proxy. It sits between the service under test and a real MongoDB container. For each OP_MSG command it checks the mock registry; if a mock is found it synthesises a BSON response, otherwise the bytes are forwarded to the real upstream.

func NewInterceptor

func NewInterceptor(addr, upstreamAddr string, reg *registry.MockRegistry) *Interceptor

NewInterceptor creates a new MongoDB interceptor.

func (*Interceptor) Start

func (p *Interceptor) Start(ctx context.Context) error

Start begins accepting connections. It blocks until ctx is cancelled.