INNER CODE UNIT · Go

resumeFail

rwynn/gtm · gtm.go:543

func resumeFail(err error) bool {
	var serverErr mongo.ServerError
	if errors.As(err, &serverErr) {
		for _, code := range []int{40576, 40585, 40615, 260, 280, 286, 257, 10334} {
			if serverErr.HasErrorCode(code) {
				return true
			}
		}
	}
	return false
}

func positionLost(err error) bool {
	var serverErr mongo.ServerError
	if errors.As(err, &serverErr) {
		// 136  : cursor capped position lost
		// 286  : change stream history lost
		// 280  : change stream fatal error

View source record →