Documentation ¶
Index ¶
- Variables
- type ConnState
- type Proxy
- func (p *Proxy) Addr() string
- func (p *Proxy) CloseCursor(cursorID int64)
- func (p *Proxy) GetCursor(cursorID int64) *plugins.CursorCacheEntry
- func (p *Proxy) HandleMongo(ctx context.Context, req *plugins.Request, d bson.D) (bson.D, error)
- func (p *Proxy) Serve() error
- func (p *Proxy) Shutdown(ctx context.Context) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrServerClosed = errors.New("server closed") SKIP_RECOVER = false )
Functions ¶
This section is empty.
Types ¶
type Proxy ¶
type Proxy struct {
// contains filtered or unexported fields
}
func (*Proxy) CloseCursor ¶
func (*Proxy) HandleMongo ¶
HandleMongo needs to actually disbatch the command. This includes loading the command into a struct, processing the pipeline, and then returning
Click to show internal directories.
Click to hide internal directories.