profiler

Documentation

Index

• Variables
• type Profile
  • func (p *Profile) FlushQueries()
  • func (p *Profile) GetLastError() error
  • func (p *Profile) QueriesChan() chan stats.Queries
  • func (p *Profile) Start(ctx context.Context)
  • func (p *Profile) Stop()
  • func (p *Profile) TimeoutsChan() <-chan time.Time
• type Profiler
  • func NewProfiler(cursor *mongo.Cursor, filters []filter.Filter, ticker <-chan time.Time, ...) Profiler
• type Stats

Variables

var (
	// DocsBufferSize is the buffer size to store documents from the MongoDB profiler
	DocsBufferSize = 100
)

Types

type Profile

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

Profile has unexported variables for the profiler

func (*Profile) FlushQueries

func (p *Profile) FlushQueries()

FlushQueries clean all the queries from the queries chan

func (*Profile) GetLastError

func (p *Profile) GetLastError() error

GetLastError return the latest error

func (*Profile) QueriesChan

func (p *Profile) QueriesChan() chan stats.Queries

QueriesChan returns the channels used to read the queries from the profiler

func (*Profile) Start

func (p *Profile) Start(ctx context.Context)

Start the profiler

func (*Profile) Stop

func (p *Profile) Stop()

Stop the profiler

func (*Profile) TimeoutsChan

func (p *Profile) TimeoutsChan() <-chan time.Time

TimeoutsChan returns the channels to receive timeout signals

type Profiler

type Profiler interface {
	GetLastError() error
	QueriesChan() chan stats.Queries
	TimeoutsChan() <-chan time.Time
	FlushQueries()
	Start(context.Context)
	Stop()
}

Profiler interface

func NewProfiler

func NewProfiler(cursor *mongo.Cursor, filters []filter.Filter, ticker <-chan time.Time, stats Stats) Profiler

NewProfiler returns a new instance of the profiler interface

type Stats

type Stats interface {
	Reset()
	Add(doc proto.SystemProfile) error
	Queries() stats.Queries
}