Method ReportError

error_handler.go:25–67

(from string, err error)

}

func (this *PanicErrorHandler) ReportError(from string, err error) {
	logger := LogWithField("tag", "error_handler")

	stateJSON, jsonErr := this.Ferry.SerializeStateToJSON()
	if jsonErr != nil {
		logger.WithError(jsonErr).Error("failed to dump state to JSON...")
	} else {
		if this.DumpStateToStdoutOnError {
			fmt.Fprintln(os.Stdout, stateJSON)
		}
	}

	// Invoke ErrorCallback if defined
	if this.ErrorCallback != (HTTPCallback{}) {
		client := &http.Client{}

		errorData := make(map[string]string)
		errorData["ErrFrom"] = from
		errorData["ErrMessage"] = err.Error()
		errorData["StateDump"] = stateJSON

		errorDataBytes, jsonErr := json.MarshalIndent(errorData, "", "  ")
		if jsonErr != nil {
			logger.WithField("error", jsonErr).Errorf("ghostferry failed to marshal error data")
		} else {
			this.ErrorCallback.Payload = string(errorDataBytes)

			postErr := this.ErrorCallback.Post(client)
			if postErr != nil {
				logger.WithField("error", postErr).Errorf("ghostferry failed to notify error")
			}
		}
	}

	var errmsg string
	if this.DumpStateToStdoutOnError {
		errmsg = "fatal error detected, state dump in stdout"
	} else {
		errmsg = "fatal error detected"
	}
	// Print error to STDERR
	logger.WithError(err).WithField("errfrom", from).Error(errmsg)
}

func (this *PanicErrorHandler) Fatal(from string, err error) {
	if atomic.AddInt32(&this.errorCount, 1) > 1 {