mongodb

Documentation

Index

• type Extractor
  • func NewExtractor(context multiplexer.DialogContext, writer backends.LedgerWriter, ...) *Extractor
  • func (e *Extractor) Write(p []byte) (int, error)
• type ExtractorConfig
• type ExtractorFactory
  • func NewExtractorFactory(writer backends.LedgerWriter, config *ExtractorConfig) *ExtractorFactory
  • func (e ExtractorFactory) GetInstance(context multiplexer.DialogContext) multiplexer.Observer
• type ExtractorInterface
• type ExtractorObserver
  • func (e *ExtractorObserver) GetIncomingWriter() io.Writer
  • func (e *ExtractorObserver) GetOutgoingWriter() io.Writer
• type Pool
  • func NewPool(url string, maxConn int) *Pool
  • func (pool *Pool) Acquire() net.Conn
  • func (pool *Pool) Release(c net.Conn) error

Types

type Extractor

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

func NewExtractor

func NewExtractor(context multiplexer.DialogContext, writer backends.LedgerWriter, config *ExtractorConfig) *Extractor

func (*Extractor) Write

func (e *Extractor) Write(p []byte) (int, error)

type ExtractorConfig

type ExtractorConfig struct {
	IgnoreMetaQuery bool
}

type ExtractorFactory

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

func NewExtractorFactory

func NewExtractorFactory(writer backends.LedgerWriter, config *ExtractorConfig) *ExtractorFactory

func (ExtractorFactory) GetInstance

func (e ExtractorFactory) GetInstance(context multiplexer.DialogContext) multiplexer.Observer

type ExtractorInterface

type ExtractorInterface interface {
	Write(p []byte) (n int, err error)
	// contains filtered or unexported methods
}

type ExtractorObserver

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

func (*ExtractorObserver) GetIncomingWriter

func (e *ExtractorObserver) GetIncomingWriter() io.Writer

func (*ExtractorObserver) GetOutgoingWriter

func (e *ExtractorObserver) GetOutgoingWriter() io.Writer

type Pool

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

func NewPool

func NewPool(url string, maxConn int) *Pool

func (*Pool) Acquire

func (pool *Pool) Acquire() net.Conn

func (*Pool) Release

func (pool *Pool) Release(c net.Conn) error