dedupe

README

dedupe

This plugin dedupes inflight secondary read queries

Documentation

Index

• Constants
• func DedupeKey(f *command.Find) string
• type DedupePlugin
  • func (p *DedupePlugin) Configure(d bson.D) error
  • func (p *DedupePlugin) Name() string
  • func (p *DedupePlugin) Process(ctx context.Context, r *plugins.Request, next plugins.PipelineFunc) (bson.D, error)
• type DedupePluginConfig

Constants

const Name = "dedupe"

Functions

func DedupeKey

func DedupeKey(f *command.Find) string

DedupeKey returns a string to use as the key for deduplication

Types

type DedupePlugin

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

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

func (*DedupePlugin) Configure

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

func (p *DedupePlugin) Name() string

func (*DedupePlugin) Process

func (p *DedupePlugin) 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 DedupePluginConfig

type DedupePluginConfig struct {
}