dual_selector

Documentation

Index

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

Constants

const PluginType = "dual_selector"

Functions

func Init

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

Types

type Args

type Args struct {
	Mode        int `yaml:"mode"`
	WaitTimeout int `yaml:"wait_timeout"`
}

type Selector

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

func NewDualSelector

func NewDualSelector(bp *handler.BP, args *Args) *Selector

func (*Selector) Exec

func (s *Selector) Exec(ctx context.Context, qCtx *handler.Context, next handler.ExecutableChainNode) error

Exec implements handler.Executable.