INNER CODE UNIT · Go

changeStreamNotEnabled

rwynn/gtm · gtm.go:534

func changeStreamNotEnabled(err error) bool {
	var serverErr mongo.ServerError
	if errors.As(err, &serverErr) {
		// The $changeStream stage is only supported on replica sets
		return serverErr.HasErrorCode(40573)
	}
	return false
}

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
			}
		}
	}

View source record →