single_flight

Documentation

Index

• Constants
• func Init(bp *handler.BP, args interface{}) (p handler.Plugin, err error)
• type Args
• type SingleFlightPlugin
  • func NewSF(bp *handler.BP) *SingleFlightPlugin
  • func (p *SingleFlightPlugin) Exec(ctx context.Context, qCtx *handler.Context, next handler.ExecutableChainNode) error

Constants

const (
	PluginType = "single_flight"
)

Functions

func Init

func Init(bp *handler.BP, args interface{}) (p handler.Plugin, err error)

Types

type Args

type Args struct{}

type SingleFlightPlugin

type SingleFlightPlugin struct {
	*handler.BP
	// contains filtered or unexported fields
}

func NewSF

func NewSF(bp *handler.BP) *SingleFlightPlugin

func (*SingleFlightPlugin) Exec

func (p *SingleFlightPlugin) Exec(ctx context.Context, qCtx *handler.Context, next handler.ExecutableChainNode) error