executable_seq

Documentation

Index

• Variables
• func ExecRoot(ctx context.Context, qCtx *handler.Context, logger *zap.Logger, ...) error
• func NagateMatcher(m handler.Matcher) handler.Matcher
• type BatchMatherAnd
  • func (bm BatchMatherAnd) Match(ctx context.Context, qCtx *handler.Context) (bool, error)
• type BatchMatherOr
  • func (bm BatchMatherOr) Match(ctx context.Context, qCtx *handler.Context) (bool, error)
• type ExecutableCmd
  • func ParseExecutableCmd(in interface{}) (ExecutableCmd, error)
• type ExecutableCmdSequence
  • func ParseExecutableCmdSequence(in []interface{}) (ExecutableCmdSequence, error)
  • func (es ExecutableCmdSequence) ExecCmd(ctx context.Context, qCtx *handler.Context, logger *zap.Logger) (earlyStop bool, err error)
• type FallbackConfig
• type FallbackECS
  • func ParseFallbackECS(c *FallbackConfig) (*FallbackECS, error)
  • func (f *FallbackECS) ExecCmd(ctx context.Context, qCtx *handler.Context, logger *zap.Logger) (earlyStop bool, err error)
• type IfBlock
  • func ParseIfBlock(c *IfBlockConfig) (*IfBlock, error)
  • func (b *IfBlock) ExecCmd(ctx context.Context, qCtx *handler.Context, logger *zap.Logger) (earlyStop bool, err error)
• type IfBlockConfig
• type NagativeMatcher
  • func (n *NagativeMatcher) Match(ctx context.Context, qCtx *handler.Context) (matched bool, err error)
• type ParallelECS
  • func ParseParallelECS(c *ParallelECSConfig) (*ParallelECS, error)
  • func (p *ParallelECS) ExecCmd(ctx context.Context, qCtx *handler.Context, logger *zap.Logger) (earlyStop bool, err error)
• type ParallelECSConfig
• type RefESExecutablePlugin
  • func (ref RefESExecutablePlugin) ExecCmd(ctx context.Context, qCtx *handler.Context, logger *zap.Logger) (earlyStop bool, err error)
  • func (ref RefESExecutablePlugin) ExecES(ctx context.Context, qCtx *handler.Context) (earlyStop bool, err error)
• type RefMatcherPlugin
  • func (ref RefMatcherPlugin) Match(ctx context.Context, qCtx *handler.Context) (matched bool, err error)

Variables

var EarlyStop earlyStop

EarlyStop is a noop ExecutableCmd that returns earlyStop == true.

Functions

func ExecRoot

func ExecRoot(ctx context.Context, qCtx *handler.Context, logger *zap.Logger, entry ExecutableCmd) error

ExecRoot executes the ExecutableCmd and qCtx.ExecDefer(). This intends for root cmd node.

func NagateMatcher

func NagateMatcher(m handler.Matcher) handler.Matcher

Types

type BatchMatherAnd

type BatchMatherAnd []handler.Matcher

func (BatchMatherAnd) Match

func (bm BatchMatherAnd) Match(ctx context.Context, qCtx *handler.Context) (bool, error)

type BatchMatherOr

type BatchMatherOr []handler.Matcher

func (BatchMatherOr) Match

func (bm BatchMatherOr) Match(ctx context.Context, qCtx *handler.Context) (bool, error)

type ExecutableCmd

type ExecutableCmd interface {
	ExecCmd(ctx context.Context, qCtx *handler.Context, logger *zap.Logger) (earlyStop bool, err error)
}

func ParseExecutableCmd

func ParseExecutableCmd(in interface{}) (ExecutableCmd, error)

ParseExecutableCmd parses in into a ExecutableCmd. in can be: a handler.Executable or a handler.ESExecutable or a string or a map[string]interface{}, which can be parsed to FallbackConfig, ParallelECSConfig or IfBlockConfig, or a slice of all of above.

type ExecutableCmdSequence

type ExecutableCmdSequence []ExecutableCmd

func ParseExecutableCmdSequence

func ParseExecutableCmdSequence(in []interface{}) (ExecutableCmdSequence, error)

func (ExecutableCmdSequence) ExecCmd

func (es ExecutableCmdSequence) ExecCmd(ctx context.Context, qCtx *handler.Context, logger *zap.Logger) (earlyStop bool, err error)

ExecCmd executes the sequence.

type FallbackConfig

type FallbackConfig struct {
	// Primary exec sequence.
	Primary interface{} `yaml:"primary"`
	// Secondary exec sequence.
	Secondary interface{} `yaml:"secondary"`

	StatLength int `yaml:"stat_length"` // An Zero value disables the normal fallback.
	Threshold  int `yaml:"threshold"`

	// FastFallback threshold in milliseconds. Zero means fast fallback is disabled.
	FastFallback int `yaml:"fast_fallback"`

	// AlwaysStandby: secondary should always standby in fast fallback.
	AlwaysStandby bool `yaml:"always_standby"`
}

type FallbackECS

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

func ParseFallbackECS

func ParseFallbackECS(c *FallbackConfig) (*FallbackECS, error)

func (*FallbackECS) ExecCmd

func (f *FallbackECS) ExecCmd(ctx context.Context, qCtx *handler.Context, logger *zap.Logger) (earlyStop bool, err error)

type IfBlock

type IfBlock struct {
	IfMatcher     handler.Matcher
	IfAndMatcher  handler.Matcher
	ExecutableCmd ExecutableCmd
}

func ParseIfBlock

func ParseIfBlock(c *IfBlockConfig) (*IfBlock, error)

func (*IfBlock) ExecCmd

func (b *IfBlock) ExecCmd(ctx context.Context, qCtx *handler.Context, logger *zap.Logger) (earlyStop bool, err error)

type IfBlockConfig

type IfBlockConfig struct {
	// Available type are string and handler.Matcher, or a slice of them.
	If interface{} `yaml:"if"`
	// Available type are string and handler.Matcher, or a slice of them.
	IfAnd interface{} `yaml:"if_and"`
	// See ParseExecutableCmd.
	Exec interface{} `yaml:"exec"`
}

IfBlockConfig is a config to build a IfBlock.

type NagativeMatcher

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

func (*NagativeMatcher) Match

func (n *NagativeMatcher) Match(ctx context.Context, qCtx *handler.Context) (matched bool, err error)

type ParallelECS

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

func ParseParallelECS

func ParseParallelECS(c *ParallelECSConfig) (*ParallelECS, error)

func (*ParallelECS) ExecCmd

func (p *ParallelECS) ExecCmd(ctx context.Context, qCtx *handler.Context, logger *zap.Logger) (earlyStop bool, err error)

type ParallelECSConfig

type ParallelECSConfig struct {
	Parallel []interface{} `yaml:"parallel"`
	Timeout  uint          `yaml:"timeout"`
}

type RefESExecutablePlugin

type RefESExecutablePlugin string

RefESExecutablePlugin is a handler.ESExecutablePlugin reference tag.

func (RefESExecutablePlugin) ExecCmd

func (ref RefESExecutablePlugin) ExecCmd(ctx context.Context, qCtx *handler.Context, logger *zap.Logger) (earlyStop bool, err error)

func (RefESExecutablePlugin) ExecES

func (ref RefESExecutablePlugin) ExecES(ctx context.Context, qCtx *handler.Context) (earlyStop bool, err error)

type RefMatcherPlugin

type RefMatcherPlugin string

RefMatcherPlugin is a handler.MatcherPlugin reference tag.

func (RefMatcherPlugin) Match

func (ref RefMatcherPlugin) Match(ctx context.Context, qCtx *handler.Context) (matched bool, err error)