logpattern

Documentation

Index

• func GetBlockedNodes(ctx context.Context, taskID model.TaskID) ([]string, error)
• func Monitor(ctx context.Context, taskID model.TaskID, logs []*model.TaskLog, ...) error
• func SetDefault(p *LogPatternPolicies)
• func TaskLogsFromDontRetryTriggers(taskID model.TaskID, t []DontRetryTrigger) []*model.TaskLog
• type DontRetryTrigger
  • func ShouldRetry(ctx context.Context, taskID model.TaskID) ([]DontRetryTrigger, error)
• type LogPatternPolicies
  • func New(ctx context.Context) (*LogPatternPolicies, error)

Functions

func GetBlockedNodes

func GetBlockedNodes(ctx context.Context, taskID model.TaskID) ([]string, error)

GetBlockedNodes returns nodes you can't schedule on due to log pattern policies.

func Monitor

func Monitor(ctx context.Context,
	taskID model.TaskID, logs []*model.TaskLog, policies expconf.LogPoliciesConfig,
) error

Monitor checks for logs against any log_pattern_policies and takes action according to the policy.

func SetDefault

func SetDefault(p *LogPatternPolicies)

SetDefault sets the package level default for log pattern policies.

func TaskLogsFromDontRetryTriggers

func TaskLogsFromDontRetryTriggers(taskID model.TaskID, t []DontRetryTrigger) []*model.TaskLog

TaskLogsFromDontRetryTriggers returns informational task logs from dont retry triggers.

Types

type DontRetryTrigger

type DontRetryTrigger struct {
	Regex         string
	TriggeringLog string
}

DontRetryTrigger has information about don't retry policies that have been triggered.

func ShouldRetry

func ShouldRetry(ctx context.Context, taskID model.TaskID) ([]DontRetryTrigger, error)

ShouldRetry returns a list of any triggered log policies that prevent retrying a trial. Returns an empty list if taskID doesn't exist. Order is not guaranteed. Only returns first log that triggered each regex. Multiple policies with the same regex will only have one DontRetryTrigger.

type LogPatternPolicies

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

LogPatternPolicies performs log pattern checks.

func New

func New(ctx context.Context) (*LogPatternPolicies, error)

New create the log pattern policies singleton.