mongodb

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(addr, upstreamAddr string, reg *registry.MockRegistry) *Interceptor

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