Function waitForInjectionCompleted

pkg/test_executor/executor.go:142–187

(ctx context.Context, session *chaos_mesh.FaultSession)

}

func waitForInjectionCompleted(ctx context.Context, session *chaos_mesh.FaultSession) error {
	// First, wait 10 seconds to allow chaos-mesh to inject into the cluster.
	// If injection isn't complete after 10 seconds, something is  wrong and we should terminate.
	timeoutAt := time.Now().Add(time.Second * 10)

	targetingGracePeriod := time.Now().Add(time.Second * 5)

	for {
		if time.Now().After(timeoutAt) {
			errmsg := "chaos-mesh is still in a 'starting' state after 10 seconds. Check kubernetes events to see what's wrong."
			return stacktrace.NewError(errmsg)
		}

		status, err := session.GetStatus(ctx)
		if err != nil {
			time.Sleep(250 * time.Millisecond)
			continue
		}

		switch status {
		case chaos_mesh.InProgress:
			log.Info("Fault injected successfully")
			return nil
		case chaos_mesh.Stopping:
			log.Warn("Fault changed to 'stopping' state immediately after injection. May indicate something is wrong.")
			return nil
		case chaos_mesh.Starting:
			if !session.TargetSelectionCompleted {
				if time.Now().After(targetingGracePeriod) {
					errmsg := "chaos-mesh was unable to identify any pods for injection based on the configured criteria"
					return stacktrace.NewError(errmsg)
				}
			}
		case chaos_mesh.Error:
			errmsg := "there was an unspecified error returned by chaos-mesh. inspect the fault resource"
			return stacktrace.NewError(errmsg)
		case chaos_mesh.Completed:
			// occurs for faults that perform an action immediately then terminate. (killing pods, etc)
			log.Info("Fault injected successfully")
			return nil
		default:
			return stacktrace.NewError("unknown chaos session state %s", status)
		}
		time.Sleep(250 * time.Millisecond)
	}
}

func waitForFaultRecovery(ctx context.Context, session *chaos_mesh.FaultSession) error {
	for {