mongoproxy

Documentation

Index

• Variables
• type ConnState
  • func (c ConnState) String() string
• type Proxy
  • func NewProxy(l net.Listener, cfg *config.Config) (*Proxy, error)
  • 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

Variables

var (
	ErrServerClosed = errors.New("server closed")
	SKIP_RECOVER    = false
)

Types

type ConnState

type ConnState int

const (
	StateNew ConnState = iota
	StateActive
	StateIdle
	StateClosed
)

func (ConnState) String

func (c ConnState) String() string

type Proxy

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

func NewProxy

func NewProxy(l net.Listener, cfg *config.Config) (*Proxy, error)

func (*Proxy) Addr

func (p *Proxy) Addr() string

func (*Proxy) CloseCursor

func (p *Proxy) CloseCursor(cursorID int64)

func (*Proxy) GetCursor

func (p *Proxy) GetCursor(cursorID int64) *plugins.CursorCacheEntry

func (*Proxy) HandleMongo

func (p *Proxy) HandleMongo(ctx context.Context, req *plugins.Request, d bson.D) (bson.D, error)

HandleMongo needs to actually disbatch the command. This includes loading the command into a struct, processing the pipeline, and then returning

func (*Proxy) Serve

func (p *Proxy) Serve() error

func (*Proxy) Shutdown

func (p *Proxy) Shutdown(ctx context.Context) error