defaults

package
v0.0.8 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 5, 2023 License: MIT Imports: 5 Imported by: 0

README

defaults

This plugin sets various defaults for messages

Documentation

Index

Constants

View Source
const Name = "defaults"

Variables

This section is empty.

Functions

This section is empty.

Types

type DefaultPlugin

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

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

func (*DefaultPlugin) Configure

func (p *DefaultPlugin) 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 (*DefaultPlugin) Name

func (p *DefaultPlugin) Name() string

func (*DefaultPlugin) Process

func (p *DefaultPlugin) 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 DefaultPluginConfig

type DefaultPluginConfig struct {
	DefaultReadConcern *command.ReadConcern `bson:"defaultReadConcern"`
	DefaultMaxTimeMS   *int64               `bson:"defaultMaxTimeMS"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL