defaults

README

slowlog

This plugin will simply log queries above a latency threshold on their return

Documentation

Index

• Constants
• type SlowlogPlugin
  • func (p *SlowlogPlugin) Configure(d bson.D) error
  • func (p *SlowlogPlugin) Name() string
  • func (p *SlowlogPlugin) Process(ctx context.Context, r *plugins.Request, next plugins.PipelineFunc) (bson.D, error)
• type SlowlogPluginConfig

Constants

const (
	Name = "slowlog"
)

Types

type SlowlogPlugin

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

This is a plugin that handles sending the request to the acutual downstream mongo

func (*SlowlogPlugin) Configure

func (p *SlowlogPlugin) Configure(d bson.D) error

Configure configures this plugin with the given configuration object. Returns an error if the configuration is invalid for the plugin.

func (*SlowlogPlugin) Name

func (p *SlowlogPlugin) Name() string

func (*SlowlogPlugin) Process

func (p *SlowlogPlugin) Process(ctx context.Context, r *plugins.Request, next plugins.PipelineFunc) (bson.D, error)

Process is the function executed when a message is called in the pipeline.

type SlowlogPluginConfig

type SlowlogPluginConfig struct {
	SlowlogThreshold string `bson:"slowlogThreshold"`

	RequestLengthLimit int `bson:"requestLengthLimit"`
	// contains filtered or unexported fields
}