fault

Documentation

Overview

Package fault defines named internal fault points used by integration and crash-recovery tests. Production components default to None.

Index

• Variables
• func Injected(point Point) error
• type Func
  • func (f Func) Hit(ctx context.Context, point Point) error
• type Hook
• type None
  • func (None) Hit(context.Context, Point) error
• type Point

Variables

var ErrInjected = errors.New("flow: injected fault")

Functions

func Injected

func Injected(point Point) error

Types

type Func

type Func func(context.Context, Point) error

func (Func) Hit

func (f Func) Hit(ctx context.Context, point Point) error

type Hook

type Hook interface {
	Hit(context.Context, Point) error
}

type None

type None struct{}

func (None) Hit

func (None) Hit(context.Context, Point) error

type Point

type Point string

const (
	ProbeReturn                Point = "probe_return"
	ClaimRunLock               Point = "claim_run_lock"
	ClaimBeforeJournal         Point = "claim_before_journal"
	ClaimBeforeCommit          Point = "claim_before_commit"
	HandlerStart               Point = "handler_start"
	HandlerReturn              Point = "handler_return"
	SettleAfterFence           Point = "settle_after_fence"
	SettleAfterAttempt         Point = "settle_after_attempt"
	SettleAfterEvents          Point = "settle_after_events"
	SettleAfterChildren        Point = "settle_after_children"
	SettleBeforeCommitFunction Point = "settle_before_commit_function"
	SettleAfterCommitFunction  Point = "settle_after_commit_function"
	SettleBeforeCommit         Point = "settle_before_commit"
	SettleCommitAmbiguous      Point = "settle_commit_ambiguous"
	RenewBeforeResult          Point = "renew_before_result"
	RenewAfterStore            Point = "renew_after_store"
	MaintenanceAfterProbe      Point = "maintenance_after_probe"
	NotifyConnect              Point = "notify_connect"
	NotifyBeforeWait           Point = "notify_before_wait"
	IngressBeforeJournal       Point = "ingress_before_journal"
	IngressBeforeCommit        Point = "ingress_before_commit"
	IngressCommitAmbiguous     Point = "ingress_commit_ambiguous"
	ClaimCommitAmbiguous       Point = "claim_commit_ambiguous"
)